Stephan Ewen created FLINK-9750: ----------------------------------- Summary: Create new StreamingFileSink that works on Flink's FileSystem abstraction Key: FLINK-9750 URL: https://issues.apache.org/jira/browse/FLINK-9750 Project: Flink Issue Type: Sub-task Components: Streaming Connectors Reporter: Stephan Ewen Assignee: Kostas Kloudas Fix For: 1.6.0
Using Flink's own file system abstraction means that we can add additional streaming/checkpointing related behavior. In addition, the new StreamingFileSink should only rely on internal checkpointed state what files are possibly in progress or need to roll over, never assume enumeration of files in the file system. -- This message was sent by Atlassian JIRA (v7.6.3#76005)