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-cdh5.7 Commit: 4be729e0f7616b24cb289ead635b882abc515e1b Parents: fad9e81 Author: shaofengshi <shaofeng...@apache.org> Authored: Tue Oct 11 17:21:08 2016 +0800 Committer: shaofengshi <shaofeng...@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(); - } } }
