[hotfix][table-planner-blink] Fix the failed FileSystemTableSinkTest

tongcheng-elong · Feb 24, 2021 · e2fe4fb · e2fe4fb
1 parent 3ac8364
commit e2fe4fb
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 53 deletions.
diff --git a/...k/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out b/...k/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"
  } ]
  } ]
-}
+}
diff --git a/...st/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out b/...st/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"
  } ]
  } ]
-}
+}
diff --git a/...st/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out b/...st/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"
  } ]
  } ]
-}
+}