This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from b4810b5a0fd [FLINK-30584][docs] Document flame graph at the subtask
level
add 24a133c7bda [FLINK-30166][AVRO] Refactor deprecated StreamingFileSink
usage with target FileSink
add 21c44c0863b [FLINK-30166][Tests] Remove no longer necessary test
add 440a275cad1 [FLINK-30166][Tests] Remove StreamingFileSink as option
for tests
add 3ef68ae2d3b [FLINK-30166][Parquet] Refactor deprecated
StreamingFileSink usage with target FileSink
add 88c450b458e [FLINK-30166][SQL E2E Test] Refactor deprecated
StreamingFileSink usage with target FileSink
add 1a7a83b9639 [FLINK-30166][Hadoop Sequence Format] Refactor deprecated
StreamingFileSink usage with target FileSink
add cd54dfef4fc [FLINK-30166][Hadoop Compress] Refactor deprecated
StreamingFileSink usage with target FileSink
add 1ac202dd8c2 [FLINK-30166][ORC] Refactor deprecated StreamingFileSink
usage with target FileSink
No new revisions were added by this update.
Summary of changes:
.../f5e3e868-8d92-4258-9654-a605dc9c550f | 6 -
.../file/sink/writer/FileSinkMigrationITCase.java | 291 ---------------------
.../flink/connector/file/sink/FileSinkProgram.java | 21 +-
.../flink-stream-sql-test/pom.xml | 8 +-
.../flink/sql/tests/StreamSQLTestProgram.java | 8 +-
...FileSinkITCase.java => AvroFileSinkITCase.java} | 30 ++-
flink-formats/flink-compress/pom.xml | 8 +-
.../formats/compress/CompressionFactoryITCase.java | 10 +-
.../flink/orc/writer/OrcBulkWriterITCase.java | 8 +-
...kITCase.java => AvroParquetFileSinkITCase.java} | 32 +--
...ITCase.java => ParquetProtoFileSinkITCase.java} | 16 +-
flink-formats/flink-sequence-file/pom.xml | 6 +
.../SequenceStreamingFileSinkITCase.java | 9 +-
13 files changed, 81 insertions(+), 372 deletions(-)
delete mode 100644
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileSinkMigrationITCase.java
rename
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/{AvroStreamingFileSinkITCase.java
=> AvroFileSinkITCase.java} (91%)
rename
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/{AvroParquetStreamingFileSinkITCase.java
=> AvroParquetFileSinkITCase.java} (93%)
rename
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/protobuf/{ParquetProtoStreamingFileSinkITCase.java
=> ParquetProtoFileSinkITCase.java} (94%)
