This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 28110ed [FLINK-19645][tests] Increase akka rpc timeout for
ShuffleCompressionITCase
add eb05e50 [FLINK-19993] Remove flink-connector-filesystem module
No new revisions were added by this update.
Summary of changes:
docs/dev/connectors/filesystem_sink.md | 154 ---
docs/dev/connectors/filesystem_sink.zh.md | 136 --
docs/dev/connectors/guarantees.md | 5 -
docs/dev/connectors/guarantees.zh.md | 5 -
docs/dev/datastream_api.md | 2 +-
docs/dev/datastream_api.zh.md | 2 +-
docs/fig/program_dataflow.svg | 6 +-
.../flink-connector-filesystem/pom.xml | 201 ---
.../connectors/fs/AvroKeyValueSinkWriter.java | 341 -----
.../flink/streaming/connectors/fs/Clock.java | 34 -
.../connectors/fs/SequenceFileWriter.java | 174 ---
.../streaming/connectors/fs/StreamWriterBase.java | 108 --
.../streaming/connectors/fs/StringWriter.java | 121 --
.../flink/streaming/connectors/fs/SystemClock.java | 30 -
.../flink/streaming/connectors/fs/Writer.java | 76 --
.../connectors/fs/bucketing/BasePathBucketer.java | 42 -
.../connectors/fs/bucketing/Bucketer.java | 51 -
.../connectors/fs/bucketing/BucketingSink.java | 1318 --------------------
.../connectors/fs/bucketing/DateTimeBucketer.java | 131 --
.../connectors/fs/AvroKeyValueSinkWriterTest.java | 55 -
.../connectors/fs/SequenceFileWriterTest.java | 44 -
.../connectors/fs/StreamWriterBaseComparator.java | 61 -
.../streaming/connectors/fs/StringWriterTest.java | 131 --
.../BucketingSinkFaultToleranceITCase.java | 306 -----
.../fs/bucketing/BucketingSinkFsInitTest.java | 83 --
.../fs/bucketing/BucketingSinkMigrationTest.java | 255 ----
.../connectors/fs/bucketing/BucketingSinkTest.java | 1027 ---------------
.../fs/bucketing/BucketingSinkTestUtils.java | 83 --
.../fs/bucketing/DateTimeBucketerTest.java | 60 -
...ucketing-sink-migration-test-flink1.10-snapshot | Bin 1658 -> 0 bytes
...ucketing-sink-migration-test-flink1.11-snapshot | Bin 1684 -> 0 bytes
...bucketing-sink-migration-test-flink1.3-snapshot | Bin 1862 -> 0 bytes
...bucketing-sink-migration-test-flink1.4-snapshot | Bin 1862 -> 0 bytes
...bucketing-sink-migration-test-flink1.5-snapshot | Bin 1596 -> 0 bytes
...bucketing-sink-migration-test-flink1.6-snapshot | Bin 1700 -> 0 bytes
...bucketing-sink-migration-test-flink1.7-snapshot | Bin 1952 -> 0 bytes
...bucketing-sink-migration-test-flink1.8-snapshot | Bin 1676 -> 0 bytes
...bucketing-sink-migration-test-flink1.9-snapshot | Bin 1664 -> 0 bytes
.../src/test/resources/log4j2-test.properties | 28 -
flink-connectors/pom.xml | 1 -
flink-end-to-end-tests/README.md | 6 -
.../flink-bucketing-sink-test/pom.xml | 115 --
.../streaming/tests/BucketingSinkTestProgram.java | 201 ---
flink-end-to-end-tests/pom.xml | 1 -
flink-end-to-end-tests/run-nightly-tests.sh | 5 +-
.../test-scripts/test_streaming_bucketing.sh | 166 ---
.../flink/streaming/api/datastream/DataStream.java | 3 +-
tools/ci/stage.sh | 1 -
48 files changed, 8 insertions(+), 5561 deletions(-)
delete mode 100644 docs/dev/connectors/filesystem_sink.md
delete mode 100644 docs/dev/connectors/filesystem_sink.zh.md
delete mode 100644 flink-connectors/flink-connector-filesystem/pom.xml
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriter.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/Clock.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/SequenceFileWriter.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/StreamWriterBase.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/StringWriter.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/SystemClock.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/Writer.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BasePathBucketer.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/DateTimeBucketer.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriterTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/SequenceFileWriterTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/StreamWriterBaseComparator.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/StringWriterTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFsInitTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTestUtils.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/DateTimeBucketerTest.java
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.10-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.11-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.3-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.4-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.5-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.6-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.7-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.8-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.9-snapshot
delete mode 100644
flink-connectors/flink-connector-filesystem/src/test/resources/log4j2-test.properties
delete mode 100644 flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml
delete mode 100644
flink-end-to-end-tests/flink-bucketing-sink-test/src/main/java/org/apache/flink/streaming/tests/BucketingSinkTestProgram.java
delete mode 100755
flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh
