You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2016/11/30 17:14:26 UTC

hbase git commit: HBASE-17211 Add more details in log when UnknownScannerException thrown in ScannerCallable

Repository: hbase
Updated Branches:
  refs/heads/master ea912478e -> 8adf6857c


HBASE-17211 Add more details in log when UnknownScannerException thrown in ScannerCallable


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8adf6857
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8adf6857
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8adf6857

Branch: refs/heads/master
Commit: 8adf6857c7a4ee6b7cb1ebe9dd53af56fe7f61e8
Parents: ea91247
Author: Yu Li <li...@apache.org>
Authored: Thu Dec 1 01:13:18 2016 +0800
Committer: Yu Li <li...@apache.org>
Committed: Thu Dec 1 01:13:18 2016 +0800

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/client/ScannerCallable.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/8adf6857/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallable.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallable.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallable.java
index 7a22648..642fae0 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallable.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallable.java
@@ -359,7 +359,10 @@ public class ScannerCallable extends ClientServiceCallable<Result[]> {
         throw ProtobufUtil.handleRemoteException(e);
       }
     } catch (IOException e) {
-      LOG.warn("Ignore, probably already closed", e);
+      TableName table = getTableName();
+      String tableDetails = (table == null) ? "" : (" on table: " + table.getNameAsString());
+      LOG.warn("Ignore, probably already closed. Current scan: " + getScan().toString()
+          + tableDetails, e);
     }
     this.scannerId = -1L;
   }