flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java [125:151]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createScalaBlinkStreamTableEnvironment(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 org.apache.flink.table.api.bridge.scala.internal.StreamTableEnvironmentImpl(catalogManager,
            moduleManager, resourceManager,
            functionCatalog, tableConfig, new org.apache.flink.streaming.api.scala.StreamExecutionEnvironment(senv),
            planner, executor, environmentSettings.isStreamingMode());
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java [125:151]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createScalaBlinkStreamTableEnvironment(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 org.apache.flink.table.api.bridge.scala.internal.StreamTableEnvironmentImpl(catalogManager,
            moduleManager, resourceManager,
            functionCatalog, tableConfig, new org.apache.flink.streaming.api.scala.StreamExecutionEnvironment(senv),
            planner, executor, environmentSettings.isStreamingMode());
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -