This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new f0aec3a69fa [FLINK-32664][table] Fix TableSourceJsonPlanTest.testReuseSourceWithoutProjectionPushDown f0aec3a69fa is described below commit f0aec3a69fa0eadaa96d7b52aaaaa476a6a886e1 Author: Sergey Nuyanzin <snuyan...@gmail.com> AuthorDate: Tue Jul 25 01:43:09 2023 +0200 [FLINK-32664][table] Fix TableSourceJsonPlanTest.testReuseSourceWithoutProjectionPushDown --- .../testReuseSourceWithoutProjectionPushDown.out | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReuseSourceWithoutProjectionPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReuseSourceWithoutProjectionPushDown.out index dab90460df4..ca32541a5cc 100644 --- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReuseSourceWithoutProjectionPushDown.out +++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReuseSourceWithoutProjectionPushDown.out @@ -40,10 +40,11 @@ "description" : "Calc(select=[x, ts])" }, { "id" : 3, - "type" : "stream-exec-sink_2", + "type" : "stream-exec-sink_1", "configuration" : { "table.exec.sink.keyed-shuffle" : "AUTO", "table.exec.sink.not-null-enforcer" : "ERROR", + "table.exec.sink.rowtime-inserter" : "ENABLED", "table.exec.sink.type-length-enforcer" : "IGNORE", "table.exec.sink.upsert-materialize" : "AUTO" }, @@ -92,10 +93,11 @@ "description" : "Calc(select=[y, CAST(tags AS VARCHAR(2147483647)) AS tags])" }, { "id" : 5, - "type" : "stream-exec-sink_2", + "type" : "stream-exec-sink_1", "configuration" : { "table.exec.sink.keyed-shuffle" : "AUTO", "table.exec.sink.not-null-enforcer" : "ERROR", + "table.exec.sink.rowtime-inserter" : "ENABLED", "table.exec.sink.type-length-enforcer" : "IGNORE", "table.exec.sink.upsert-materialize" : "AUTO" }, @@ -144,4 +146,4 @@ }, "shuffleMode" : "PIPELINED" } ] -} \ No newline at end of file +}