Repository: flink Updated Branches: refs/heads/master b8aa49ce7 -> 224fa94c6
[FLINK-1805]The class IOManagerAsync should use its own Log instance Although class 'IOManagerAsync' is extended from 'IOManager' in package 'org.apache.flink.runtime.io.disk.iomanager', but I think it should has its own Log instance. Author: hongsibao <hongsi...@huawei.com> Closes #546 from matadorhong/FLINK-1805 and squashes the following commits: 89c0dd7 [hongsibao] Use private instead of protected 56b9dab [hongsibao] The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log instance Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/224fa94c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/224fa94c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/224fa94c Branch: refs/heads/master Commit: 224fa94c620491b364c715b10d7f627bb5c739dc Parents: b8aa49c Author: hongsibao <hongsi...@huawei.com> Authored: Tue Mar 31 09:54:25 2015 -0700 Committer: Henry Saputra <henry.sapu...@gmail.com> Committed: Tue Mar 31 09:54:25 2015 -0700 ---------------------------------------------------------------------- .../flink/runtime/io/disk/iomanager/IOManagerAsync.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/224fa94c/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java index e615913..4401d03 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java @@ -21,6 +21,8 @@ package org.apache.flink.runtime.io.disk.iomanager; import org.apache.flink.core.memory.MemorySegment; import org.apache.flink.runtime.io.network.buffer.Buffer; import org.apache.flink.runtime.util.EnvironmentInformation; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.IOException; import java.lang.Thread.UncaughtExceptionHandler; @@ -43,7 +45,10 @@ public class IOManagerAsync extends IOManager implements UncaughtExceptionHandle /** Flag to signify that the IOManager has been shut down already */ private final AtomicBoolean isShutdown = new AtomicBoolean(); - + + /** Logging */ + private static final Logger LOG = LoggerFactory.getLogger(IOManagerAsync.class); + // ------------------------------------------------------------------------- // Constructors / Destructors // -------------------------------------------------------------------------
