From c0f3072d80f988fdafb6a947b771b36c9683a611 Mon Sep 17 00:00:00 2001
From: Ammu Parvathy <Ammu.Parvathy@ibm.com>
Date: Tue, 19 Nov 2024 10:01:57 +0530
Subject: [PATCH] fix: class-loading-issue

---
 .../streaming/api/environment/StreamExecutionEnvironment.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index 96e75e6ba6f09..1005eb5e8ae16 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ b/flink-streaming-java/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();