You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by jb...@apache.org on 2016/06/23 14:16:32 UTC
[44/56] [abbrv] incubator-carbondata git commit: [issue-698]fix error
log message to be proper(#699)
[issue-698]fix error log message to be proper(#699)
fix table not found error message
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/9559a44b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/9559a44b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/9559a44b
Branch: refs/heads/master
Commit: 9559a44b4b4e6f84d9ef19b2cf9b19f4e0a9d5eb
Parents: 398250c
Author: Zhangshunyu <zh...@huawei.com>
Authored: Mon Jun 20 16:17:10 2016 +0800
Committer: david <Qi...@users.noreply.github.com>
Committed: Mon Jun 20 16:17:10 2016 +0800
----------------------------------------------------------------------
.../spark/sql/execution/command/carbonTableSchema.scala | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/9559a44b/integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala b/integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
index b70f9b1..655141c 100644
--- a/integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
+++ b/integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
@@ -1161,8 +1161,8 @@ private[sql] case class AlterTableCompaction(alterTableModel: AlterTableModel) e
val schemaName = getDB.getDatabaseName(alterTableModel.dbName, sqlContext)
if (null == org.carbondata.core.carbon.metadata.CarbonMetadata.getInstance
.getCarbonTable(schemaName + "_" + tableName)) {
- logError("alter table failed. table not found: " + schemaName + "_" + tableName)
- sys.error("alter table failed. table not found: " + schemaName + "_" + tableName)
+ logError("alter table failed. table not found: " + schemaName + "." + tableName)
+ sys.error("alter table failed. table not found: " + schemaName + "." + tableName)
}
val relation =
@@ -1418,9 +1418,9 @@ private[sql] case class LoadCube(
}
if (null == org.carbondata.core.carbon.metadata.CarbonMetadata.getInstance
.getCarbonTable(schemaName + "_" + tableName)) {
- logError("Data loading failed. table not found: " + schemaName + "_" + tableName)
- LOGGER.audit("Data loading failed. table not found: " + schemaName + "_" + tableName)
- sys.error("Data loading failed. table not found: " + schemaName + "_" + tableName)
+ logError("Data loading failed. table not found: " + schemaName + "." + tableName)
+ LOGGER.audit("Data loading failed. table not found: " + schemaName + "." + tableName)
+ sys.error("Data loading failed. table not found: " + schemaName + "." + tableName)
}
CarbonProperties.getInstance().addProperty("zookeeper.enable.lock", "false")
val carbonLock = CarbonLockFactory.getCarbonLockObj(org.carbondata.core.