This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a4ad86fb083 [FLINK-33341][state] Add support for rescaling from local
keyed state to PrioritizedOperatorSubtaskState.
add dcce3764a45 [FLINK-33375] Make it possible to run ValuesSource
infinitely
add a5b4e60e563 [FLINK-33375] Improve TestValues utilities for restore
tests
add aa7519b91b8 [hotfix] Adapt the SinkTestStep to give plain access to
expected results
add d863ff38c06 [FLINK-33375] Implement restore test base
No new revisions were added by this update.
Summary of changes:
.../flink/table/test/program/SinkTestStep.java | 52 ++++-
.../flink/table/test/program/TableTestProgram.java | 44 ++--
.../planner/plan/utils/ExecNodeMetadataUtil.java | 2 +-
.../source/DynamicFilteringValuesSource.java | 16 +-
.../source/DynamicFilteringValuesSourceReader.java | 34 ++-
.../flink/connector/source/TerminatingLogic.java | 37 ++--
.../flink/connector/source/ValuesSource.java | 17 +-
.../flink/connector/source/ValuesSourceReader.java | 26 ++-
.../DynamicFilteringValuesSourceEnumerator.java | 16 +-
.../source/enumerator/ValuesSourceEnumerator.java | 8 +-
.../source/split/ValuesSourcePartitionSplit.java | 16 ++
.../ValuesSourcePartitionSplitSerializer.java | 6 +-
.../connector/source/split/ValuesSourceSplit.java | 15 ++
.../source/split/ValuesSourceSplitSerializer.java | 5 +-
.../factories/TestValuesRuntimeFunctions.java | 34 ++-
.../planner/factories/TestValuesTableFactory.java | 104 +++++++--
.../plan/nodes/exec/testutils/CalcRestoreTest.java | 21 +-
.../nodes/exec/testutils/CalcTestPrograms.java | 42 ++++
.../plan/nodes/exec/testutils/RestoreTestBase.java | 245 +++++++++++++++++++++
.../calc-simple/plan/calc-simple.json} | 85 ++++---
.../calc-simple/savepoint/_metadata | Bin 0 -> 7032 bytes
pom.xml | 1 +
22 files changed, 670 insertions(+), 156 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/TestingConnectionManager.java
=>
flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/TerminatingLogic.java
(51%)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitsChange.java
=>
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/CalcRestoreTest.java
(63%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/CalcTestPrograms.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestBase.java
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out
=> restore-tests/stream-exec-calc_1/calc-simple/plan/calc-simple.json} (55%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-calc_1/calc-simple/savepoint/_metadata
