flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [flink] 03/06: [FLINK-17339][sql-client] Change default planner to blink.
Date Sun, 26 Apr 2020 11:56:54 GMT
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 <kurt@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)) {


Mime
View raw message