You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/06/12 12:16:00 UTC
[flink] 02/10: [FLINK-17977][runtime] Log FS safety-net lifecycle
on DEBUG
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 <ch...@apache.org>
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();