This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5388d44 [FLINK-23948][python][doc] Fix the priority description of
the python client executable
add 5390e91 [FLINK-22710][formats] Explicitly set the bucket assigner to
avoid writing into two buckets in the tests
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-file-sink-common/pom.xml | 16 +++++++++++++
.../bucketassigners/UniqueBucketAssigner.java} | 27 ++++++++--------------
flink-formats/flink-avro/pom.xml | 9 ++++++++
.../formats/avro/AvroStreamingFileSinkITCase.java | 4 ++++
flink-formats/flink-compress/pom.xml | 8 +++++++
.../compress/CompressWriterFactoryTest.java | 19 ++-------------
.../formats/compress/CompressionFactoryITCase.java | 2 ++
flink-formats/flink-orc/pom.xml | 9 ++++++++
.../flink/orc/writer/OrcBulkRowDataWriterTest.java | 2 ++
.../flink/orc/writer/OrcBulkWriterITCase.java | 5 +++-
.../apache/flink/orc/writer/OrcBulkWriterTest.java | 2 ++
flink-formats/flink-parquet/pom.xml | 8 +++++++
.../avro/ParquetAvroStreamingFileSinkITCase.java | 4 ++++
.../ParquetProtoStreamingFileSinkITCase.java | 2 ++
flink-formats/flink-sequence-file/pom.xml | 8 +++++++
.../SequenceStreamingFileSinkITCase.java | 2 ++
16 files changed, 92 insertions(+), 35 deletions(-)
copy
flink-connectors/flink-file-sink-common/src/{main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/BasePathBucketAssigner.java
=>
test/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/UniqueBucketAssigner.java}
(64%)
