Repository: carbondata
Updated Branches:
  refs/heads/master 2c88bffdc -> cac650f01


[CARBONDATA-1403] Compaction log is not correct

The log of compaction is not correct, So change it.

This closes #1285


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

Branch: refs/heads/master
Commit: cac650f01636bc06d770f45c2f2b316e3d386530
Parents: 2c88bff
Author: chenerlu <[email protected]>
Authored: Wed Aug 23 17:23:38 2017 +0800
Committer: Jacky Li <[email protected]>
Committed: Mon Aug 28 00:46:38 2017 +0800

----------------------------------------------------------------------
 .../org/apache/carbondata/spark/rdd/Compactor.scala     | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/carbondata/blob/cac650f0/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
----------------------------------------------------------------------
diff --git 
a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
 
b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
index 4cebcd8..c13a942 100644
--- 
a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
+++ 
b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/Compactor.scala
@@ -131,15 +131,15 @@ object Compactor {
       } else {
         logger.audit(s"Compaction request completed for table " +
                      s"${ carbonLoadModel.getDatabaseName }.${ 
carbonLoadModel.getTableName }")
-        logger.info("Compaction request completed for table ${ 
carbonLoadModel.getDatabaseName } " +
-                    s".${ carbonLoadModel.getTableName }")
+        logger.info(s"Compaction request completed for table " +
+                    s"${ carbonLoadModel.getDatabaseName }.${ 
carbonLoadModel.getTableName }")
       }
     } else {
-      logger.audit("Compaction request failed for table ${ 
carbonLoadModel.getDatabaseName } " +
-                   s".${ carbonLoadModel.getTableName }"
+      logger.audit(s"Compaction request failed for table " +
+                   s"${ carbonLoadModel.getDatabaseName }.${ 
carbonLoadModel.getTableName }"
       )
-      logger.error("Compaction request failed for table ${ 
carbonLoadModel.getDatabaseName } " +
-                   s".${ carbonLoadModel.getTableName }")
+      logger.error(s"Compaction request failed for table " +
+                   s"${ carbonLoadModel.getDatabaseName }.${ 
carbonLoadModel.getTableName }")
       throw new Exception("Compaction Failure in Merger Rdd.")
     }
   }

Reply via email to