JetClassLoader extends ClassLoader { public boolean isShutdown() { return isShutdown; } JetClassLoader(
            @Nonnull NodeEngine nodeEngine,
            @Nullable ClassLoader parent,
            @Nullable String jobName,
            long jobId,
            @Nonnull JobRepository jobRepository
    ); void shutdown(); boolean isShutdown(); @Override String toString();  }
@Test public void when_jobCompleted_then_classLoaderShutDown() { DAG dag = new DAG(); dag.newVertex("v", LeakClassLoaderP::new).localParallelism(1); JetInstance instance = createJetMember(); instance.newJob(dag).join(); assertTrue("The classloader should have been shutdown after job completion", LeakClassLoaderP.classLoader.isShutdown() ); }