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 a56134df9d0 [FLINK-38797][python] Fixed
CsvSchemaBuilder.set_null_value to return self
new bfcf13b86aa [FLINK-38765] Fix persisted metadata handling in sink
new c02879020fc [hotfix] Pull legacyUidsEnabled as an abstract method to
CommonExecTableSourceScan
The 2 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:
.../table/tests/jsonplan/testGetJsonPlan.out | 2 +-
.../flink/table/test/program/TableTestProgram.java | 15 +++
.../table/planner/connectors/DynamicSinkUtils.java | 2 +-
.../plan/nodes/exec/batch/BatchExecSink.java | 26 ++--
.../nodes/exec/batch/BatchExecTableSourceScan.java | 7 +-
.../plan/nodes/exec/common/CommonExecSink.java | 23 +++-
.../exec/common/CommonExecTableSourceScan.java | 11 +-
.../plan/nodes/exec/stream/StreamExecSink.java | 29 ++++
.../exec/stream/StreamExecTableSourceScan.java | 11 +-
.../plan/nodes/exec/TransformationsTest.java | 6 +-
.../nodes/exec/common/TableSinkTestPrograms.java | 75 +++++++++++
.../nodes/exec/stream/TableSinkRestoreTest.java | 13 +-
.../plan/nodes/exec/testutils/RestoreTestBase.java | 25 +++-
.../test/resources/jsonplan/testGetJsonPlan.out | 2 +-
.../jsonplan/testInvalidTypeJsonPlan.json | 2 +-
.../resources/jsonplan/testSinkTableWithHints.out | 2 +-
.../jsonplan/testSourceTableWithHints.out | 2 +-
.../testPythonCalc.out | 2 +-
.../testPythonFunctionInWhereClause.out | 2 +-
.../testJoinWithFilter.out | 2 +-
.../testPythonTableFunction.out | 2 +-
.../tesPythonAggCallsWithGroupBy.out | 2 +-
.../testEventTimeHopWindow.out | 2 +-
.../testEventTimeSessionWindow.out | 2 +-
.../testEventTimeTumbleWindow.out | 2 +-
.../testProcTimeHopWindow.out | 2 +-
.../testProcTimeSessionWindow.out | 2 +-
.../testProcTimeTumbleWindow.out | 2 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 2 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 2 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 2 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 2 +-
.../testRowTimeBoundedPartitionedRowsOver.out | 2 +-
.../testJsonPlanWithTableHints.out | 2 +-
...k-upsert-materializer-writable-metadata-v1.json | 149 +++++++++++++++++++++
.../savepoint/_metadata | Bin 0 -> 8665 bytes
...k-upsert-materializer-writable-metadata-v1.json | 149 +++++++++++++++++++++
.../savepoint/_metadata | Bin 0 -> 9499 bytes
...sink-upsert-materializer-writable-metadata.json | 149 +++++++++++++++++++++
.../savepoint/_metadata | Bin 0 -> 9502 bytes
.../sink-bucketing_hash-with-keys-with-count.json | 21 ++-
.../savepoint/_metadata | Bin 8379 -> 8439 bytes
...nk-bucketing_range_with_keys_without_count.json | 21 ++-
.../savepoint/_metadata | Bin 8379 -> 8437 bytes
.../plan/sink-bucketing_with-count.json | 21 ++-
.../sink-bucketing_with-count/savepoint/_metadata | Bin 8379 -> 8435 bytes
.../plan/sink-bucketing_with-keys-and-count.json | 21 ++-
.../savepoint/_metadata | Bin 8379 -> 8437 bytes
.../plan/sink-ndf-primary-key.json | 34 +++--
.../sink-ndf-primary-key/savepoint/_metadata | Bin 5080 -> 5212 bytes
.../sink-overwrite/plan/sink-overwrite.json | 30 ++---
.../sink-overwrite}/savepoint/_metadata | Bin 8379 -> 8441 bytes
.../plan/sink-partial-insert.json | 40 +++---
.../sink-partial-insert/savepoint/_metadata | Bin 11034 -> 11115 bytes
.../sink-partition/plan/sink-partition.json | 33 +++--
.../sink-partition/savepoint/_metadata | Bin 9435 -> 9561 bytes
.../sink-upsert/plan/sink-upsert.json} | 57 ++++----
.../sink-upsert}/savepoint/_metadata | Bin 5080 -> 5102 bytes
.../plan/sink-writing-metadata.json | 30 ++---
.../sink-writing-metadata}/savepoint/_metadata | Bin 8379 -> 8393 bytes
60 files changed, 815 insertions(+), 227 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_1/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1/plan/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_1/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_2/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1/plan/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_2/insert-into-upsert-with-sink-upsert-materializer-writable-metadata-v1/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_2/insert-into-upsert-with-sink-upsert-materializer-writable-metadata/plan/insert-into-upsert-with-sink-upsert-materializer-writable-metadata.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-sink_2/insert-into-upsert-with-sink-upsert-materializer-writable-metadata/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=>
stream-exec-sink_2}/sink-bucketing_hash-with-keys-with-count/plan/sink-bucketing_hash-with-keys-with-count.json
(86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-bucketing_range_with_keys_without_count
=>
stream-exec-sink_2/sink-bucketing_hash-with-keys-with-count}/savepoint/_metadata
(75%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=>
stream-exec-sink_2}/sink-bucketing_range_with_keys_without_count/plan/sink-bucketing_range_with_keys_without_count.json
(86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-bucketing_with-keys-and-count
=>
stream-exec-sink_2/sink-bucketing_range_with_keys_without_count}/savepoint/_metadata
(75%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=>
stream-exec-sink_2}/sink-bucketing_with-count/plan/sink-bucketing_with-count.json
(86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-bucketing_with-count/savepoint/_metadata (79%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=>
stream-exec-sink_2}/sink-bucketing_with-keys-and-count/plan/sink-bucketing_with-keys-and-count.json
(86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-bucketing_with-keys-and-count/savepoint/_metadata
(75%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-ndf-primary-key/plan/sink-ndf-primary-key.json
(85%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-ndf-primary-key/savepoint/_metadata (57%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-overwrite/plan/sink-overwrite.json (81%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-bucketing_with-count
=> stream-exec-sink_2/sink-overwrite}/savepoint/_metadata (79%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-partial-insert/plan/sink-partial-insert.json (86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-partial-insert/savepoint/_metadata (80%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-partition/plan/sink-partition.json (86%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-partition/savepoint/_metadata (88%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-table-source-scan_2/table-source-scan-filter-pushdown/plan/table-source-scan-filter-pushdown.json
=> stream-exec-sink_2/sink-upsert/plan/sink-upsert.json} (65%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-ndf-primary-key
=> stream-exec-sink_2/sink-upsert}/savepoint/_metadata (50%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1
=> stream-exec-sink_2}/sink-writing-metadata/plan/sink-writing-metadata.json
(82%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-bucketing_with-count
=> stream-exec-sink_2/sink-writing-metadata}/savepoint/_metadata (80%)
