[flink] 01/06: [FLINK-17339][table-api] Change default planner to blink

[kurt]

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;