From e2fe4fb2c9e121385b01d65392ed7e4d2df4e4b6 Mon Sep 17 00:00:00 2001
From: Jark Wu <jark@apache.org>
Date: Wed, 24 Feb 2021 16:16:20 +0800
Subject: [PATCH] [hotfix][table-planner-blink] Fix the failed
 FileSystemTableSinkTest

---
 ...eSystemTableSinkWithParallelismInBatch.out | 19 +++---------
 ...ableSinkWithParallelismInStreamingSql0.out | 23 ++++----------
 ...ableSinkWithParallelismInStreamingSql1.out | 31 ++++++-------------
 3 files changed, 20 insertions(+), 53 deletions(-)

diff --git a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out
index 4cf716b45fc7c..81df7d70d0e77 100644
--- a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out
+++ b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out
@@ -14,32 +14,21 @@ Sink(table=[default_catalog.default_database.test_sink_table], fields=[id, real_
 == Physical Execution Plan ==
 {
   "nodes" : [ {
-    "id" : 1,
+    "id" : ,
     "type" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "pact" : "Data Source",
     "contents" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "parallelism" : 1
   }, {
-    "id" : 2,
-    "type" : "Filter",
-    "pact" : "Operator",
-    "contents" : "Filter",
-    "parallelism" : 8,
-    "predecessors" : [ {
-      "id" : 1,
-      "ship_strategy" : "REBALANCE",
-      "side" : "second"
-    } ]
-  }, {
-    "id" : 3,
+    "id" : ,
     "type" : "Sink: Filesystem",
     "pact" : "Data Sink",
     "contents" : "Sink: Filesystem",
     "parallelism" : 5,
     "predecessors" : [ {
-      "id" : 2,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   } ]
-}
+}
\ No newline at end of file
diff --git a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out
index 4be2d3312e2a8..6ab8bc207b55c 100644
--- a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out
+++ b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out
@@ -14,43 +14,32 @@ Sink(table=[default_catalog.default_database.test_sink_table], fields=[id, real_
 == Physical Execution Plan ==
 {
   "nodes" : [ {
-    "id" : 1,
+    "id" : ,
     "type" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "pact" : "Data Source",
     "contents" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "parallelism" : 1
   }, {
-    "id" : 2,
-    "type" : "Filter",
-    "pact" : "Operator",
-    "contents" : "Filter",
-    "parallelism" : 8,
-    "predecessors" : [ {
-      "id" : 1,
-      "ship_strategy" : "REBALANCE",
-      "side" : "second"
-    } ]
-  }, {
-    "id" : 3,
+    "id" : ,
     "type" : "StreamingFileWriter",
     "pact" : "Operator",
     "contents" : "StreamingFileWriter",
     "parallelism" : 5,
     "predecessors" : [ {
-      "id" : 2,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   }, {
-    "id" : 4,
+    "id" : ,
     "type" : "Sink: end",
     "pact" : "Data Sink",
     "contents" : "Sink: end",
     "parallelism" : 1,
     "predecessors" : [ {
-      "id" : 3,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   } ]
-}
+}
\ No newline at end of file
diff --git a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out
index b63945fa8fdc3..fcfe456bea521 100644
--- a/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out
+++ b/flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out
@@ -14,65 +14,54 @@ Sink(table=[default_catalog.default_database.test_compact_sink_table], fields=[i
 == Physical Execution Plan ==
 {
   "nodes" : [ {
-    "id" : 5,
+    "id" : ,
     "type" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "pact" : "Data Source",
     "contents" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
     "parallelism" : 1
   }, {
-    "id" : 6,
-    "type" : "Filter",
-    "pact" : "Operator",
-    "contents" : "Filter",
-    "parallelism" : 8,
-    "predecessors" : [ {
-      "id" : 5,
-      "ship_strategy" : "REBALANCE",
-      "side" : "second"
-    } ]
-  }, {
-    "id" : 7,
+    "id" : ,
     "type" : "streaming-writer",
     "pact" : "Operator",
     "contents" : "streaming-writer",
     "parallelism" : 5,
     "predecessors" : [ {
-      "id" : 6,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   }, {
-    "id" : 8,
+    "id" : ,
     "type" : "compact-coordinator",
     "pact" : "Operator",
     "contents" : "compact-coordinator",
     "parallelism" : 1,
     "predecessors" : [ {
-      "id" : 7,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   }, {
-    "id" : 10,
+    "id" : ,
     "type" : "compact-operator",
     "pact" : "Operator",
     "contents" : "compact-operator",
     "parallelism" : 5,
     "predecessors" : [ {
-      "id" : 8,
+      "id" : ,
       "ship_strategy" : "BROADCAST",
       "side" : "second"
     } ]
   }, {
-    "id" : 11,
+    "id" : ,
     "type" : "Sink: end",
     "pact" : "Data Sink",
     "contents" : "Sink: end",
     "parallelism" : 1,
     "predecessors" : [ {
-      "id" : 10,
+      "id" : ,
       "ship_strategy" : "REBALANCE",
       "side" : "second"
     } ]
   } ]
-}
+}
\ No newline at end of file