flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java [101:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createResourceManager(List<URL> jars, Object tableConfig) {
    Configuration configuration = ((TableConfig) tableConfig).getConfiguration().clone();
    ClientWrapperClassLoader userClassLoader =
            new ClientWrapperClassLoader(
                    ClientClassloaderUtil.buildUserClassLoader(
                            jars,
                            Thread.currentThread().getContextClassLoader(),
                            new Configuration(configuration)),
                    configuration);
    return new ClientResourceManager(configuration, userClassLoader);
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java [101:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Object createResourceManager(List<URL> jars, Object tableConfig) {
    Configuration configuration = ((TableConfig) tableConfig).getConfiguration().clone();
    ClientWrapperClassLoader userClassLoader =
            new ClientWrapperClassLoader(
                    ClientClassloaderUtil.buildUserClassLoader(
                            jars,
                            Thread.currentThread().getContextClassLoader(),
                            new Configuration(configuration)),
                    configuration);
    return new ClientResourceManager(configuration, userClassLoader);
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -