You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2017/08/27 16:46:51 UTC
carbondata git commit: [CARBONDATA-1403] Compaction log is not correct
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 <ch...@huawei.com>
Authored: Wed Aug 23 17:23:38 2017 +0800
Committer: Jacky Li <ja...@qq.com>
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.")
}
}