chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r1140831 - in /incubator/chukwa/trunk: CHANGES.txt src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
Date Tue, 28 Jun 2011 20:45:22 GMT
Author: eyang
Date: Tue Jun 28 20:45:22 2011
New Revision: 1140831

URL: http://svn.apache.org/viewvc?rev=1140831&view=rev
Log:
CHUKWA-591. Check for empty result from HBase Scanner. (Eric Yang)


Modified:
    incubator/chukwa/trunk/CHANGES.txt
    incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java

Modified: incubator/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/CHANGES.txt?rev=1140831&r1=1140830&r2=1140831&view=diff
==============================================================================
--- incubator/chukwa/trunk/CHANGES.txt (original)
+++ incubator/chukwa/trunk/CHANGES.txt Tue Jun 28 20:45:22 2011
@@ -87,6 +87,8 @@ Trunk (unreleased changes)
     CHUKWA-472. Added ability to configure timestamp format for the default Time Series Processor.
 (Bill Graham via Eric Yang)
 
   BUG FIXES
+
+    CHUKWA-591. Check for empty result from HBase Scanner. (Eric Yang)
  
     CHUKWA-585. Enable HICC server to bind to all IP addresses. (Eric Yang)
  

Modified: incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java?rev=1140831&r1=1140830&r2=1140831&view=diff
==============================================================================
--- incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
(original)
+++ incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
Tue Jun 28 20:45:22 2011
@@ -122,9 +122,11 @@ public class ChukwaHBaseStore {
 
   public static void getColumnNamesHelper(Set<String>columnNames, Iterator<Result>
it) {
     Result result = it.next();
-    List<KeyValue> kvList = result.list();
-    for(KeyValue kv : kvList) {
-      columnNames.add(new String(kv.getQualifier()));
+    if(result!=null) {
+      List<KeyValue> kvList = result.list();
+      for(KeyValue kv : kvList) {
+        columnNames.add(new String(kv.getQualifier()));
+      }
     }
   }
   



Mime
View raw message