This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dfd2a55 [FLINK-19850] Add e2e tests for the new FileSink in streaming
mode
add 80598ca [hotfix] In FileBucketWriter, change the bucket part id to
UUID
add 19eb503 [FLINK-20006] Fix the unstable FileSinkITCase
No new revisions were added by this update.
Summary of changes:
.../file/sink/writer/FileWriterBucket.java | 4 +-
.../file/sink/BatchExecutionFileSinkITCase.java | 142 ++++++++
.../flink/connector/file/sink/FileSinkITBase.java | 210 +++++++++++
.../flink/connector/file/sink/FileSinkITCase.java | 386 ---------------------
.../sink/StreamingExecutionFileSinkITCase.java | 205 +++++++++++
5 files changed, 559 insertions(+), 388 deletions(-)
create mode 100644
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/BatchExecutionFileSinkITCase.java
create mode 100644
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkITBase.java
delete mode 100644
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkITCase.java
create mode 100644
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java
