[ 
https://issues.apache.org/jira/browse/FLINK-30627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687680#comment-17687680
 ] 

Yuxin Tan commented on FLINK-30627:
-----------------------------------

[~martijnvisser] Sorry that I underestimated the complexity of this problem at 
the beginning. I don't have a good solution yet.

> Refactor FileSystemTableSink to use FileSink instead of StreamingFileSink
> -------------------------------------------------------------------------
>
>                 Key: FLINK-30627
>                 URL: https://issues.apache.org/jira/browse/FLINK-30627
>             Project: Flink
>          Issue Type: Technical Debt
>          Components: Connectors / FileSystem
>            Reporter: Martijn Visser
>            Priority: Major
>
> {{FileSystemTableSink}} currently depends on most of the capabilities from 
> {{StreamingFileSink}}, for example 
> https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSink.java#L223-L243
> This is necessary to complete FLINK-28641



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to