[flink] branch master updated (d0859f6 -> fcb3f7c)

[ga...@apache.org]

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 d0859f6  [FLINK-25046][runtime] Convert unspecified edge to rescale when using adaptive batch scheduler
     add fcb3f7c  [FLINK-25583][connectors/filesystem] Prepare resources for serializer migration tests.

No new revisions were added by this update.

Summary of changes:
 ...FileSinkCommittableSerializerMigrationTest.java | 171 +++++++++++++++++++++
 ...inprogress.03b44884-d031-4811-bafe-26db9cf04c6f |   1 +
 .../in-progress-v1/committable                     | Bin 0 -> 243 bytes
 ...inprogress.88a4993f-e3f5-4342-90c9-86e2bf5c2089 |   1 +
 .../pending-v1/committable                         | Bin 0 -> 235 bytes
 ...treamBasedPartFileRecoverableMigrationTest.java | 161 +++++++++++++++++++
 ...inprogress.061d2bbd-9b62-4884-9d4b-60aa08e53f41 |   1 +
 .../in-progress-v1/recoverable                     | Bin 0 -> 229 bytes
 ...inprogress.c3d60263-031f-41c8-84d0-59ad35374ce0 |   1 +
 .../pending-v1/recoverable                         | Bin 0 -> 221 bytes
 ...dingFileRecoverableSerializerMigrationTest.java |  95 ++++++++++++
 .../common-v1                                      | Bin 0 -> 36 bytes
 12 files changed, 431 insertions(+)
 create mode 100644 flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkCommittableSerializerMigrationTest.java
 create mode 100644 flink-connectors/flink-connector-files/src/test/resources/committable-serializer-migration/in-progress-v1/.content.inprogress.03b44884-d031-4811-bafe-26db9cf04c6f
 create mode 100644 flink-connectors/flink-connector-files/src/test/resources/committable-serializer-migration/in-progress-v1/committable
 create mode 100644 flink-connectors/flink-connector-files/src/test/resources/committable-serializer-migration/pending-v1/.content.inprogress.88a4993f-e3f5-4342-90c9-86e2bf5c2089
 create mode 100644 flink-connectors/flink-connector-files/src/test/resources/committable-serializer-migration/pending-v1/committable
 create mode 100644 flink-connectors/flink-file-sink-common/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputStreamBasedPartFileRecoverableMigrationTest.java
 create mode 100644 flink-connectors/flink-file-sink-common/src/test/resources/recoverable-serializer-migration/in-progress-v1/.content.inprogress.061d2bbd-9b62-4884-9d4b-60aa08e53f41
 create mode 100644 flink-connectors/flink-file-sink-common/src/test/resources/recoverable-serializer-migration/in-progress-v1/recoverable
 create mode 100644 flink-connectors/flink-file-sink-common/src/test/resources/recoverable-serializer-migration/pending-v1/.content.inprogress.c3d60263-031f-41c8-84d0-59ad35374ce0
 create mode 100644 flink-connectors/flink-file-sink-common/src/test/resources/recoverable-serializer-migration/pending-v1/recoverable
 create mode 100644 flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPendingFileRecoverableSerializerMigrationTest.java
 create mode 100644 flink-formats/flink-hadoop-bulk/src/test/resources/pending-file-recoverable-serializer-migration/common-v1