flink/flink1.15-shims/src/main/java/org/apache/zeppelin/flink/Flink115Shims.java [325:343]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Object lookupExecutor(ClassLoader classLoader,
                                Object settings,
                                Object sEnv) {
    try {
      final ExecutorFactory executorFactory =
              FactoryUtil.discoverFactory(
                      classLoader, ExecutorFactory.class, ExecutorFactory.DEFAULT_IDENTIFIER);
      final Method createMethod =
              executorFactory
                      .getClass()
                      .getMethod("create", StreamExecutionEnvironment.class);

      return createMethod.invoke(executorFactory, sEnv);
    } catch (Exception e) {
      throw new TableException(
              "Could not instantiate the executor. Make sure a planner module is on the classpath",
              e);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java [345:363]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Object lookupExecutor(ClassLoader classLoader,
                                Object settings,
                                Object sEnv) {
    try {
      final ExecutorFactory executorFactory =
              FactoryUtil.discoverFactory(
                      classLoader, ExecutorFactory.class, ExecutorFactory.DEFAULT_IDENTIFIER);
      final Method createMethod =
              executorFactory
                      .getClass()
                      .getMethod("create", StreamExecutionEnvironment.class);

      return createMethod.invoke(executorFactory, sEnv);
    } catch (Exception e) {
      throw new TableException(
              "Could not instantiate the executor. Make sure a planner module is on the classpath",
              e);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java [345:363]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Object lookupExecutor(ClassLoader classLoader,
                                Object settings,
                                Object sEnv) {
    try {
      final ExecutorFactory executorFactory =
              FactoryUtil.discoverFactory(
                      classLoader, ExecutorFactory.class, ExecutorFactory.DEFAULT_IDENTIFIER);
      final Method createMethod =
              executorFactory
                      .getClass()
                      .getMethod("create", StreamExecutionEnvironment.class);

      return createMethod.invoke(executorFactory, sEnv);
    } catch (Exception e) {
      throw new TableException(
              "Could not instantiate the executor. Make sure a planner module is on the classpath",
              e);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -