carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vimal...@apache.org
Subject [1/2] incubator-carbondata git commit: stop compaction flow after failure
Date Tue, 06 Sep 2016 08:24:40 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master d174d59e1 -> c7999c14e


stop compaction flow after failure


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/21bc8326
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/21bc8326
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/21bc8326

Branch: refs/heads/master
Commit: 21bc832624f7020c6bbd49a990a748e461ac92ea
Parents: d174d59
Author: QiangCai <david.caiq@gmail.com>
Authored: Wed Aug 31 17:04:12 2016 +0800
Committer: Vimal-Das <vimaldas@apache.org>
Committed: Tue Sep 6 13:46:52 2016 +0530

----------------------------------------------------------------------
 .../src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/21bc8326/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
index 5aaa55f..5eebede 100644
--- a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
+++ b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
@@ -127,6 +127,8 @@ object Compactor {
           .error("Compaction request failed for table " + carbonLoadModel
             .getDatabaseName + "." + carbonLoadModel.getTableName
           )
+        throw new Exception("Compaction failed to update metadata for table " + carbonLoadModel
+            .getDatabaseName + "." + carbonLoadModel.getTableName)
       }
       else {
         logger


Mime
View raw message