Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task FLINK-20180

FLINK-19510 Translation the FileSink Document into Chinese

Yun Gao Yun Gao Major Closed Implemented  
Sub-task FLINK-20141

FLINK-19510 Add documentation about the FileSink

Kostas Kloudas Kostas Kloudas Major Closed Fixed  
Sub-task FLINK-20032

FLINK-19510 Make FileSink support processing time

Yun Gao Yun Gao Major Closed Implemented  
Sub-task FLINK-20031

FLINK-19510 Keep the UID of SinkWriter same as the SinkTransformation

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-20007

FLINK-19510 SinkTransformationTranslator fail to handle the PartitionTransformation

Guowei Ma Guowei Ma Major Closed Fixed  
Sub-task FLINK-19963

FLINK-19510 Give SinkWriter access to processing-time service

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19958

FLINK-19510 Add the IOException to all the I/O related methods' signature in Sink API.

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19936

FLINK-19510 Make SinkITCase stable

Guowei Ma Guowei Ma Major Closed Fixed  
Sub-task FLINK-19850

FLINK-19510 Add E2E tests for the new streaming case of the new FileSink

Yun Gao Yun Gao Major Closed Implemented  
Sub-task FLINK-19841

FLINK-19510 Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19836

FLINK-19510 Add SimpleVersionedSerializerTypeSerializerProxy

Aljoscha Krettek Guowei Ma Major Closed Fixed  
Sub-task FLINK-19834

FLINK-19510 Make the TestSink reusable in all the sink related tests.

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19833

FLINK-19510 Rename Sink API Writer interface to SinkWriter

Guowei Ma Aljoscha Krettek Major Closed Implemented  
Sub-task FLINK-19760

FLINK-19510 Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19758

FLINK-19510 Implement a new unified File Sink based on the new Sink API

Yun Gao Yun Gao Major Closed Implemented  
Sub-task FLINK-19736

FLINK-19510 Implement the `SinkTransformation`

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19696

FLINK-19510 Implement Batch committer for the new API

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19586

FLINK-19510 Implement StreamCommitterOperator for new Sink API

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19531

FLINK-19510 Implement writer operator for new Sink API

Guowei Ma Guowei Ma Major Closed Fixed  
Sub-task FLINK-19512

FLINK-19510 Introduce new Sink API interfaces

Guowei Ma Guowei Ma Major Closed Implemented  
Sub-task FLINK-19511

FLINK-19510 Rename the `SinkTransformation` to `LegacySinkTransformation`

Guowei Ma Guowei Ma Major Closed Implemented  

Cancel