|
|
|
FLINK-20180
|
FLINK-19510
Translation the FileSink Document into Chinese
|
Yun Gao
|
Yun Gao
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-20141
|
FLINK-19510
Add documentation about the FileSink
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20032
|
FLINK-19510
Make FileSink support processing time
|
Yun Gao
|
Yun Gao
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-20031
|
FLINK-19510
Keep the UID of SinkWriter same as the SinkTransformation
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-20007
|
FLINK-19510
SinkTransformationTranslator fail to handle the PartitionTransformation
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19963
|
FLINK-19510
Give SinkWriter access to processing-time service
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19958
|
FLINK-19510
Add the IOException to all the I/O related methods' signature in Sink API.
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19936
|
FLINK-19510
Make SinkITCase stable
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19850
|
FLINK-19510
Add E2E tests for the new streaming case of the new FileSink
|
Yun Gao
|
Yun Gao
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19841
|
FLINK-19510
Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19836
|
FLINK-19510
Add SimpleVersionedSerializerTypeSerializerProxy
|
Aljoscha Krettek
|
Guowei Ma
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19834
|
FLINK-19510
Make the TestSink reusable in all the sink related tests.
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19833
|
FLINK-19510
Rename Sink API Writer interface to SinkWriter
|
Guowei Ma
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19760
|
FLINK-19510
Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19758
|
FLINK-19510
Implement a new unified File Sink based on the new Sink API
|
Yun Gao
|
Yun Gao
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19736
|
FLINK-19510
Implement the `SinkTransformation`
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19696
|
FLINK-19510
Implement Batch committer for the new API
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19586
|
FLINK-19510
Implement StreamCommitterOperator for new Sink API
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19531
|
FLINK-19510
Implement writer operator for new Sink API
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19512
|
FLINK-19510
Introduce new Sink API interfaces
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19511
|
FLINK-19510
Rename the `SinkTransformation` to `LegacySinkTransformation`
|
Guowei Ma
|
Guowei Ma
|
|
Closed |
Implemented
|
|
|
|
|