You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/10/19 03:02:02 UTC

[15/50] [abbrv] kylin git commit: allow cleanupOldStorage() be overwritted

allow cleanupOldStorage() be overwritted


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

Branch: refs/heads/master-hbase1.x
Commit: 4be729e0f7616b24cb289ead635b882abc515e1b
Parents: fad9e81
Author: shaofengshi <sh...@apache.org>
Authored: Tue Oct 11 17:21:08 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Tue Oct 11 17:21:08 2016 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/provision/BuildCubeWithStream.java   | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/4be729e0/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java
----------------------------------------------------------------------
diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java
index d2e46a5..2faa8d0 100644
--- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java
+++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java
@@ -301,7 +301,7 @@ public class BuildCubeWithStream {
         HBaseMetadataTestCase.staticCleanupTestMetadata();
     }
 
-    private static void cleanupOldStorage() throws Exception {
+    protected void cleanupOldStorage() throws Exception {
         String[] args = { "--delete", "true" };
         StorageCleanupJob cli = new StorageCleanupJob();
         cli.execute(args);
@@ -321,10 +321,6 @@ public class BuildCubeWithStream {
         } catch (Throwable e) {
             logger.error("error", e);
             System.exit(1);
-        } finally {
-            if (buildCubeWithStream != null) {
-                buildCubeWithStream.after();
-            }
         }
 
     }