You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2016/08/06 10:00:22 UTC
[05/20] incubator-carbondata git commit: [CARBONDATA-111] No retry
when compaction failure, so that it will not continuously retry (#896)
[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 <ra...@gmail.com>
Authored: Tue Aug 2 01:08:40 2016 +0530
Committer: Venkata Ramana G <g....@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.")
}
}
}