[FLINK-17339][table-api] Change default planner to blink

This closes apache#11910
mbalassi · Apr 26, 2020 · f0a4b09 · f0a4b09
1 parent cbaea29
commit f0a4b09
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/...le/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java b/...le/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java
@@ -37,7 +37,7 @@
  * <p>Example:
  * <pre>{@code
  * EnvironmentSettings.newInstance()
- * .useOldPlanner()
+ * .useBlinkPlanner()
  * .inStreamingMode()
  * .withBuiltInCatalogName("default_catalog")
  * .withBuiltInDatabaseName("default_database")
@@ -159,16 +159,15 @@ public static class Builder {
  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 Builder useOldPlanner() {
  }
 
  /**
- * 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 Builder useBlinkPlanner() {
  *
  * <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;