[FLINK-17339][sql-client] Change default planner to blink.

Jin-H · Apr 26, 2020 · 2421f94 · 2421f94
1 parent 04c52f8
commit 2421f94
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java b/...sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java
@@ -175,7 +175,7 @@ public EnvironmentSettings getEnvironmentSettings() {
 		}
 
 		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 boolean inBatchMode() {
 
 	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 @@ else if (planner.equals(EXECUTION_PLANNER_VALUE_OLD)) {
 
 	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)) {