flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsapu...@apache.org
Subject flink git commit: [FLINK-1805]The class IOManagerAsync should use its own Log instance
Date Tue, 31 Mar 2015 16:54:34 GMT
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 <hongsibao@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 <hongsibao@huawei.com>
Authored: Tue Mar 31 09:54:25 2015 -0700
Committer: Henry Saputra <henry.saputra@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
 	// -------------------------------------------------------------------------


Mime
View raw message