flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java [154:178]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createJavaBlinkStreamTableEnvironment(Object environmentSettingsObj,
                                                      Object senvObj,
                                                      Object tableConfigObj,
                                                      Object moduleManagerObj,
                                                      Object functionCatalogObj,
                                                      Object catalogManagerObj,
                                                      List<URL> jars,
                                                      ClassLoader classLoader) {
    EnvironmentSettings environmentSettings = (EnvironmentSettings) environmentSettingsObj;
    StreamExecutionEnvironment senv = (StreamExecutionEnvironment) senvObj;
    TableConfig tableConfig = (TableConfig) tableConfigObj;
    ModuleManager moduleManager = (ModuleManager) moduleManagerObj;
    FunctionCatalog functionCatalog = (FunctionCatalog) functionCatalogObj;
    CatalogManager catalogManager = (CatalogManager) catalogManagerObj;
    ImmutablePair<Object, Object> pair = createPlannerAndExecutor(
            classLoader, environmentSettings, senv,
            tableConfig, moduleManager, functionCatalog, catalogManager);
    Planner planner = (Planner) pair.left;
    Executor executor = (Executor) pair.right;

    ResourceManager resourceManager = (ResourceManager) createResourceManager(jars, tableConfig);

    return new StreamTableEnvironmentImpl(catalogManager, moduleManager, resourceManager,
            functionCatalog, tableConfig, senv, planner, executor, environmentSettings.isStreamingMode());
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java [154:178]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createJavaBlinkStreamTableEnvironment(Object environmentSettingsObj,
                                                      Object senvObj,
                                                      Object tableConfigObj,
                                                      Object moduleManagerObj,
                                                      Object functionCatalogObj,
                                                      Object catalogManagerObj,
                                                      List<URL> jars,
                                                      ClassLoader classLoader) {
    EnvironmentSettings environmentSettings = (EnvironmentSettings) environmentSettingsObj;
    StreamExecutionEnvironment senv = (StreamExecutionEnvironment) senvObj;
    TableConfig tableConfig = (TableConfig) tableConfigObj;
    ModuleManager moduleManager = (ModuleManager) moduleManagerObj;
    FunctionCatalog functionCatalog = (FunctionCatalog) functionCatalogObj;
    CatalogManager catalogManager = (CatalogManager) catalogManagerObj;
    ImmutablePair<Object, Object> pair = createPlannerAndExecutor(
            classLoader, environmentSettings, senv,
            tableConfig, moduleManager, functionCatalog, catalogManager);
    Planner planner = (Planner) pair.left;
    Executor executor = (Executor) pair.right;

    ResourceManager resourceManager = (ResourceManager) createResourceManager(jars, tableConfig);

    return new StreamTableEnvironmentImpl(catalogManager, moduleManager, resourceManager,
            functionCatalog, tableConfig, senv, planner, executor, environmentSettings.isStreamingMode());
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -