flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java [366:378]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public ImmutablePair<Object, Object> createPlannerAndExecutor(
          ClassLoader classLoader, Object environmentSettings, Object sEnv,
          Object tableConfig, Object moduleManager, Object functionCatalog, Object catalogManager) {
    EnvironmentSettings settings = (EnvironmentSettings) environmentSettings;
    Executor executor = (Executor) lookupExecutor(classLoader, environmentSettings, sEnv);
    Planner planner = PlannerFactoryUtil.createPlanner(executor,
            (TableConfig) tableConfig,
            Thread.currentThread().getContextClassLoader(),
            (ModuleManager) moduleManager,
            (CatalogManager) catalogManager,
            (FunctionCatalog) functionCatalog);
    return ImmutablePair.of(planner, executor);
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java [366:378]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public ImmutablePair<Object, Object> createPlannerAndExecutor(
          ClassLoader classLoader, Object environmentSettings, Object sEnv,
          Object tableConfig, Object moduleManager, Object functionCatalog, Object catalogManager) {
    EnvironmentSettings settings = (EnvironmentSettings) environmentSettings;
    Executor executor = (Executor) lookupExecutor(classLoader, environmentSettings, sEnv);
    Planner planner = PlannerFactoryUtil.createPlanner(executor,
            (TableConfig) tableConfig,
            Thread.currentThread().getContextClassLoader(),
            (ModuleManager) moduleManager,
            (CatalogManager) catalogManager,
            (FunctionCatalog) functionCatalog);
    return ImmutablePair.of(planner, executor);
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -