This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 58035ea658e [FLINK-38423][table-api] Add VECTOR_SEARCH connector API
(#27037)
new 1e177c92449 [hotfix] Introduce OperatorSnapshotFinalizer factory method
new 246e914e9a3 [hotfix] Introduce SinkUpsertMaterializer factory method
new 742730ff718 [hotfix] Refactor SinkUpsertMaterializer tests
new ca03ed435b1 [FLINK-38460] Add SinkUpsertMaterializer recovery test
new 3c581afdc5f [FLINK-38460] Add SinkUpsertMaterializer state growth test
new cdbf7bfe66c [FLINK-38460] Add SinkUpsertMaterializer retraction tests
new 69e858ffd26 [FLINK-38460] Add SinkUpsertMaterializer serializer and
equalizer tests
new 4cd638dbc58 [FLINK-38460] Add SinkUpsertMaterializerMigrationTest
new 4d1a611850b [FLINK-38460] Add SinkUpsertMaterializerRescalingTest
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/state/api/output/SnapshotUtils.java | 2 +-
.../api/operators/OperatorSnapshotFinalizer.java | 18 +-
.../runtime/tasks/AsyncCheckpointRunnable.java | 2 +-
.../operators/OperatorSnapshotFinalizerTest.java | 2 +-
.../util/AbstractStreamOperatorTestHarness.java | 2 +-
.../operators/sink/SinkUpsertMaterializer.java | 16 +
.../sink/SinkUpsertMaterializerMigrationTest.java | 189 +++++++++++
.../sink/SinkUpsertMaterializerRescalingTest.java | 353 +++++++++++++++++++
.../sink/SinkUpsertMaterializerStateBackend.java | 33 +-
.../operators/sink/SinkUpsertMaterializerTest.java | 373 ++++++++++++++++++---
.../table/runtime/util/RowDataHarnessAssertor.java | 8 +
.../migration-flink-2.2-HEAP-V1-snapshot | Bin 0 -> 2566 bytes
.../migration-flink-2.2-ROCKSDB-V1-snapshot | Bin 11944 -> 16099 bytes
pom.xml | 1 +
14 files changed, 934 insertions(+), 65 deletions(-)
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializerMigrationTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializerRescalingTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/HeapAsyncSnapshotTtlStateTest.java
=>
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializerStateBackend.java
(59%)
create mode 100644
flink-table/flink-table-runtime/src/test/resources/sink-upsert-materializer/migration-flink-2.2-HEAP-V1-snapshot
copy
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink2.1-rocksdb-checkpoint/4e3badab-50a7-4fae-a359-e423c48f174e
=>
flink-table/flink-table-runtime/src/test/resources/sink-upsert-materializer/migration-flink-2.2-ROCKSDB-V1-snapshot
(73%)
