XComp commented on code in PR #19351: URL: https://github.com/apache/flink/pull/19351#discussion_r844028946
########## flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotUtils.java: ########## @@ -71,11 +77,8 @@ public static ResourceProfile createTotalResourceProfile(int numberOfSlots) { return result; } - public static TimerService<AllocationID> createDefaultTimerService() { - return createDefaultTimerService(DEFAULT_SLOT_TIMEOUT); - } - public static TimerService<AllocationID> createDefaultTimerService(long shutdownTimeout) { - return new DefaultTimerService<>(TestingUtils.defaultExecutor(), shutdownTimeout); + return new DefaultTimerService<>( + Executors.newSingleThreadScheduledExecutor(), shutdownTimeout); Review Comment: Ok, fair enough. I went over the calling tests to verify that either the taskSlotTable or the TaskExecutor are stopped which would trigger the closing of the executor. 👍 (only the `TaskSubmissionTestEnvironment` should be checked as already mentioned in a [previous comment](https://github.com/apache/flink/pull/19351#discussion_r844016207). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org