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:52 UTC
[flink] 01/06: [FLINK-17339][table-api] 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 f0a4b09319211391dcfd09198e360f48102a9991
Author: Kurt Young <ku...@apache.org>
AuthorDate: Thu Apr 23 21:50:04 2020 +0800
[FLINK-17339][table-api] Change default planner to blink
This closes #11910
---
.../apache/flink/table/api/EnvironmentSettings.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java
index 7eec4a3..bc6e8e0 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java
@@ -37,7 +37,7 @@ import java.util.Map;
* <p>Example:
* <pre>{@code
* EnvironmentSettings.newInstance()
- * .useOldPlanner()
+ * .useBlinkPlanner()
* .inStreamingMode()
* .withBuiltInCatalogName("default_catalog")
* .withBuiltInDatabaseName("default_database")
@@ -159,16 +159,15 @@ public class EnvironmentSettings {
private static final String BLINK_PLANNER_FACTORY = "org.apache.flink.table.planner.delegation.BlinkPlannerFactory";
private static final String BLINK_EXECUTOR_FACTORY = "org.apache.flink.table.planner.delegation.BlinkExecutorFactory";
- private String plannerClass = OLD_PLANNER_FACTORY;
- private String executorClass = OLD_EXECUTOR_FACTORY;
+ private String plannerClass = BLINK_PLANNER_FACTORY;
+ private String executorClass = BLINK_EXECUTOR_FACTORY;
private String builtInCatalogName = DEFAULT_BUILTIN_CATALOG;
private String builtInDatabaseName = DEFAULT_BUILTIN_DATABASE;
private boolean isStreamingMode = true;
/**
- * Sets the old Flink planner as the required module.
- *
- * <p>This is the default behavior.
+ * Sets the old Flink planner as the required module. By default, {@link #useBlinkPlanner()}
+ * is enabled.
*/
public Builder useOldPlanner() {
this.plannerClass = OLD_PLANNER_FACTORY;
@@ -177,8 +176,9 @@ public class EnvironmentSettings {
}
/**
- * Sets the Blink planner as the required module. By default, {@link #useOldPlanner()} is
- * enabled.
+ * Sets the Blink planner as the required module.
+ *
+ * <p>This is the default behavior.
*/
public Builder useBlinkPlanner() {
this.plannerClass = BLINK_PLANNER_FACTORY;
@@ -191,7 +191,7 @@ public class EnvironmentSettings {
*
* <p>A planner will be discovered automatically, if there is only one planner available.
*
- * <p>By default, {@link #useOldPlanner()} is enabled.
+ * <p>By default, {@link #useBlinkPlanner()} is enabled.
*/
public Builder useAnyPlanner() {
this.plannerClass = null;