(flink) branch master updated: [FLINK-34013][runtime] Remove duplicated stopProfiling() in `ProfilingService`

[tangyun]

This is an automated email from the ASF dual-hosted git repository.

tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new c09f07a4063 [FLINK-34013][runtime] Remove duplicated stopProfiling() 
in `ProfilingService`
c09f07a4063 is described below

commit c09f07a406398bc4b2320e9b5ae0a8f5f27a00dc
Author: Yu Chen <yuchen.e...@gmail.com>
AuthorDate: Tue Jan 9 08:57:31 2024 +0800

    [FLINK-34013][runtime] Remove duplicated stopProfiling() in 
`ProfilingService`
---
 .../java/org/apache/flink/runtime/util/profiler/ProfilingService.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/util/profiler/ProfilingService.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/util/profiler/ProfilingService.java
index 5ae07047fe4..d8a67339810 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/util/profiler/ProfilingService.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/util/profiler/ProfilingService.java
@@ -114,8 +114,6 @@ public class ProfilingService implements Closeable {
                     profilingInfo.fail("Start profiler failed. " + e));
         }
 
-        scheduledExecutor.schedule(() -> stopProfiling(resourceID), duration, 
TimeUnit.SECONDS);
-
         this.profilingFuture = new ProfilingFuture(duration, () -> 
stopProfiling(resourceID));
         return CompletableFuture.completedFuture(profilingInfo);
     }