kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [39/50] incubator-kylin git commit: KYLIN-671 update corpocessors of those ii segments that are "NEW"
Date Sun, 26 Apr 2015 04:27:21 GMT
KYLIN-671 update corpocessors of those ii segments that are "NEW"


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/00d6839c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/00d6839c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/00d6839c

Branch: refs/heads/streaming-localdict
Commit: 00d6839cf6e98c047e1206b7fe4925bdebf72ae8
Parents: 5270605
Author: honma <honma@ebay.com>
Authored: Fri Apr 17 11:16:23 2015 +0800
Committer: honma <honma@ebay.com>
Committed: Wed Apr 22 16:46:02 2015 +0800

----------------------------------------------------------------------
 .../apache/kylin/job/tools/DeployCoprocessorCLI.java   | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/00d6839c/job/src/main/java/org/apache/kylin/job/tools/DeployCoprocessorCLI.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/tools/DeployCoprocessorCLI.java b/job/src/main/java/org/apache/kylin/job/tools/DeployCoprocessorCLI.java
index d325eab..fc52260 100644
--- a/job/src/main/java/org/apache/kylin/job/tools/DeployCoprocessorCLI.java
+++ b/job/src/main/java/org/apache/kylin/job/tools/DeployCoprocessorCLI.java
@@ -46,6 +46,7 @@ import org.apache.hadoop.hbase.TableNotFoundException;
 import org.apache.hadoop.hbase.client.HBaseAdmin;
 import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
 import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.kylin.metadata.realization.RealizationStatusEnum;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.apache.kylin.common.KylinConfig;
@@ -304,11 +305,13 @@ public class DeployCoprocessorCLI {
         }
 
         for (IIInstance ii : IIManager.getInstance(config).listAllIIs()) {
-            for (IISegment seg : ii.getSegments(SegmentStatusEnum.READY)) {
-                String tableName = seg.getStorageLocationIdentifier();
-                if (StringUtils.isBlank(tableName) == false) {
-                    result.add(tableName);
-                    System.out.println("added new table: " + tableName);
+            if(ii.getStatus()== RealizationStatusEnum.READY) {
+                for (IISegment seg : ii.getSegments()) {//streaming segment is never "READY"
+                    String tableName = seg.getStorageLocationIdentifier();
+                    if (StringUtils.isBlank(tableName) == false) {
+                        result.add(tableName);
+                        System.out.println("added new table: " + tableName);
+                    }
                 }
             }
         }


Mime
View raw message