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 <k...@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;