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 2018/09/06 08:38:15 UTC
[flink] branch release-1.6 updated: [FLINK-10283][runtime] Remove
misleading logging in FileCache
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.6 by this push:
new 2866c8b [FLINK-10283][runtime] Remove misleading logging in FileCache
2866c8b is described below
commit 2866c8b90355e8525cc64215a791cbc55d14d7c6
Author: zentol <ch...@apache.org>
AuthorDate: Wed Sep 5 12:52:29 2018 +0200
[FLINK-10283][runtime] Remove misleading logging in FileCache
---
.../src/main/java/org/apache/flink/runtime/filecache/FileCache.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java b/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java
index 0019acf..041fea0 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java
@@ -226,7 +226,6 @@ public class FileCache {
Set<ExecutionAttemptID> jobRefCounter = jobRefHolders.get(jobId);
if (jobRefCounter == null || jobRefCounter.isEmpty()) {
- LOG.warn("improper use of releaseJob() without a matching number of createTmpFiles() calls for jobId " + jobId);
return;
}