You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/05/17 21:25:54 UTC
[flink] branch master updated (7abced6 -> f33819b)
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 7abced6 [FLINK-15102][datastream/api] Add continuousSource() methods to the StreamExecutionEvironment.
add f33819b Revert "[FLINK-17593] Turn BucketStateSerializerTest into an upgrade test"
No new revisions were added by this update.
Summary of changes:
.../api/functions/sink/filesystem/Bucket.java | 9 +-
.../sink/filesystem/BucketStateSerializerTest.java | 423 +++++++++------------
.../bucket-state-migration-test/empty-v1/snapshot | Bin 180 -> 0 bytes
.../bucket/test-bucket/part-0-0 | 2 -
.../bucket/test-bucket/part-0-1 | 2 -
.../bucket/test-bucket/part-0-2 | 2 -
.../bucket/test-bucket/part-0-3 | 2 -
.../bucket/test-bucket/part-0-4 | 2 -
.../full-no-in-progress-v1/snapshot | Bin 2059 -> 0 bytes
...inprogress.795d25e1-c9b1-4635-afc1-9334651de3c9 | 1 -
.../full-v1/bucket/test-bucket/part-0-0 | 2 -
.../full-v1/bucket/test-bucket/part-0-1 | 2 -
.../full-v1/bucket/test-bucket/part-0-2 | 2 -
.../full-v1/bucket/test-bucket/part-0-3 | 2 -
.../full-v1/bucket/test-bucket/part-0-4 | 2 -
.../bucket-state-migration-test/full-v1/snapshot | Bin 2229 -> 0 bytes
...inprogress.0ba167b7-76c7-4ba8-9e83-80c6000b5320 | 1 -
.../only-in-progress-v1/snapshot | Bin 550 -> 0 bytes
pom.xml | 1 -
19 files changed, 171 insertions(+), 284 deletions(-)
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/empty-v1/snapshot
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/bucket/test-bucket/part-0-0
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/bucket/test-bucket/part-0-1
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/bucket/test-bucket/part-0-2
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/bucket/test-bucket/part-0-3
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/bucket/test-bucket/part-0-4
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-no-in-progress-v1/snapshot
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/.part-0-5.inprogress.795d25e1-c9b1-4635-afc1-9334651de3c9
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/part-0-0
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/part-0-1
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/part-0-2
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/part-0-3
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/bucket/test-bucket/part-0-4
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/full-v1/snapshot
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/only-in-progress-v1/bucket/test-bucket/.part-0-0.inprogress.0ba167b7-76c7-4ba8-9e83-80c6000b5320
delete mode 100644 flink-streaming-java/src/test/resources/bucket-state-migration-test/only-in-progress-v1/snapshot