[flink] branch master updated: [FLINK-32664][table] Fix TableSourceJsonPlanTest.testReuseSourceWithoutProjectionPushDown

[twalthr]

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
+}