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)) {

Reply via email to