git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (FLINK-9750) Create new StreamingFileSink that works on Flink's FileSystem abstraction


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)



( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-development/msg07981.html on line 92
Call Stack
#TimeMemoryFunctionLocation
10.0008358376{main}( ).../msg07981.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-development/msg07981.html on line 92
Call Stack
#TimeMemoryFunctionLocation
10.0008358376{main}( ).../msg07981.html:0