You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2020/04/26 11:56:54 UTC
[flink] 03/06: [FLINK-17339][sql-client] Change default planner to
blink.
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 <ku...@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)) {