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 bff7da1 [FLINK-18774][debezium-avro] Improve debezium-avro format
implementation
add a6bea22 [FLINK-19850] Add e2e tests for the new FileSink in streaming
mode
add dd17dc7 [FLINK-20031] Keep the UID of SinkWriter same as the
SinkTransformation
add 89bed42 [hotfix] Fix StreamingExecutionFileSinkITCase instability
No new revisions were added by this update.
Summary of changes:
.../sink/StreamingExecutionFileSinkITCase.java | 7 +++-
.../pom.xml | 16 +++++---
.../src/main/java/FileSinkProgram.java} | 46 +++++++++++++++-------
flink-end-to-end-tests/pom.xml | 2 +-
flink-end-to-end-tests/run-nightly-tests.sh | 7 +++-
...st_streaming_file_sink.sh => test_file_sink.sh} | 12 +++---
.../translators/SinkTransformationTranslator.java | 35 +++++++++++-----
.../graph/SinkTransformationTranslatorTest.java | 22 ++++++-----
8 files changed, 99 insertions(+), 48 deletions(-)
rename flink-end-to-end-tests/{flink-streaming-file-sink-test =>
flink-file-sink-test}/pom.xml (83%)
rename
flink-end-to-end-tests/{flink-streaming-file-sink-test/src/main/java/StreamingFileSinkProgram.java
=> flink-file-sink-test/src/main/java/FileSinkProgram.java} (79%)
rename flink-end-to-end-tests/test-scripts/{test_streaming_file_sink.sh =>
test_file_sink.sh} (94%)
