carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [05/20] incubator-carbondata git commit: [CARBONDATA-111] No retry when compaction failure, so that it will not continuously retry (#896)
Date Sat, 06 Aug 2016 10:00:22 GMT
[CARBONDATA-111] No retry when compaction failure, so that it will not continuously retry (#896)

if any thing fails in rdd and compaction is failed then throwing exception so that it will
not continuously retry

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

Branch: refs/heads/master
Commit: ac8d866ca76596a3054b3bd752894c38685658b0
Parents: f9c2e57
Author: ravikiran23 <ravikiran.sn042@gmail.com>
Authored: Tue Aug 2 01:08:40 2016 +0530
Committer: Venkata Ramana G <g.ramana.v1@gmail.com>
Committed: Tue Aug 2 01:08:40 2016 +0530

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


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ac8d866c/integration/spark/src/main/scala/org/carbondata/spark/rdd/Compactor.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/carbondata/spark/rdd/Compactor.scala b/integration/spark/src/main/scala/org/carbondata/spark/rdd/Compactor.scala
index 2b17d57..45e3ac8 100644
--- a/integration/spark/src/main/scala/org/carbondata/spark/rdd/Compactor.scala
+++ b/integration/spark/src/main/scala/org/carbondata/spark/rdd/Compactor.scala
@@ -148,6 +148,7 @@ object Compactor {
         .error("Compaction request failed for table " + carbonLoadModel
           .getDatabaseName + "." + carbonLoadModel.getTableName
         )
+      throw new Exception("Compaction Failure in Merger Rdd.")
     }
   }
 }


Mime
View raw message