This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 09e3daabe5599e314be87ae0eb6a337f37113d64 Author: Chesnay Schepler <[email protected]> AuthorDate: Thu Jun 11 18:59:51 2020 +0200 [FLINK-17977][runtime] Log FS safety-net lifecycle on DEBUG --- .../src/main/java/org/apache/flink/runtime/taskmanager/Task.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java index bd4671f..f0bff66 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java @@ -598,7 +598,7 @@ public class Task implements Runnable, TaskSlotPayload, TaskActions, PartitionPr // ---------------------------- // activate safety net for task thread - LOG.info("Creating FileSystem stream leak safety net for task {}", this); + LOG.debug("Creating FileSystem stream leak safety net for task {}", this); FileSystemSafetyNet.initializeSafetyNetForThread(); // first of all, get a user-code classloader @@ -836,7 +836,7 @@ public class Task implements Runnable, TaskSlotPayload, TaskActions, PartitionPr fileCache.releaseJob(jobId, executionId); // close and de-activate safety net for task thread - LOG.info("Ensuring all FileSystem streams are closed for task {}", this); + LOG.debug("Ensuring all FileSystem streams are closed for task {}", this); FileSystemSafetyNet.closeSafetyNetAndGuardedResourcesForThread(); notifyFinalState();
