This is an automated email from the ASF dual-hosted git repository.
jark 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 e2fe4fb [hotfix][table-planner-blink] Fix the failed
FileSystemTableSinkTest
e2fe4fb is described below
commit e2fe4fb2c9e121385b01d65392ed7e4d2df4e4b6
Author: Jark Wu <j...@apache.org>
AuthorDate: Wed Feb 24 16:16:20 2021 +0800
[hotfix][table-planner-blink] Fix the failed FileSystemTableSinkTest
---
...stFileSystemTableSinkWithParallelismInBatch.out | 19 +++----------
...stemTableSinkWithParallelismInStreamingSql0.out | 23 +++++-----------
...stemTableSinkWithParallelismInStreamingSql1.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 4cf716b..81df7d7 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 4be2d33..6ab8bc2 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 b63945f..fcfe456 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
