fix: class-loading-issue

ammu20-dev · Nov 19, 2024 · c0f3072 · c0f3072
1 parent aa20e5b
commit c0f3072
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -2437,7 +2437,8 @@ public JobClient executeAsync(StreamGraph streamGraph) throws Exception {
         final PipelineExecutor executor = getPipelineExecutor();
 
         CompletableFuture<JobClient> jobClientFuture =
-                executor.execute(streamGraph, configuration, Thread.currentThread().getContextClassLoader());
+                executor.execute(
+                        streamGraph, configuration, Thread.currentThread().getContextClassLoader());
 
         try {
             JobClient jobClient = jobClientFuture.get();