This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2421f94bbeed01d661d4c568f9c9370479223467 Author: Kurt Young <k...@apache.org> AuthorDate: Thu Apr 23 22:17:34 2020 +0800 [FLINK-17339][sql-client] Change default planner to blink. --- .../apache/flink/table/client/config/entries/ExecutionEntry.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java b/flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java index 04d81a2..dd7c322 100644 --- a/flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java +++ b/flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java @@ -175,7 +175,7 @@ public class ExecutionEntry extends ConfigEntry { } final String planner = properties.getOptionalString(EXECUTION_PLANNER) - .orElse(EXECUTION_PLANNER_VALUE_OLD); + .orElse(EXECUTION_PLANNER_VALUE_BLINK); if (planner.equals(EXECUTION_PLANNER_VALUE_OLD)) { builder.useOldPlanner(); @@ -200,7 +200,7 @@ public class ExecutionEntry extends ConfigEntry { public boolean isStreamingPlanner() { final String planner = properties.getOptionalString(EXECUTION_PLANNER) - .orElse(EXECUTION_PLANNER_VALUE_OLD); + .orElse(EXECUTION_PLANNER_VALUE_BLINK); // Blink planner is a streaming planner if (planner.equals(EXECUTION_PLANNER_VALUE_BLINK)) { @@ -216,7 +216,7 @@ public class ExecutionEntry extends ConfigEntry { public boolean isBatchPlanner() { final String planner = properties.getOptionalString(EXECUTION_PLANNER) - .orElse(EXECUTION_PLANNER_VALUE_OLD); + .orElse(EXECUTION_PLANNER_VALUE_BLINK); // Blink planner is not a batch planner if (planner.equals(EXECUTION_PLANNER_VALUE_BLINK)) {