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/27 03:06:27 UTC
[1/2] incubator-carbondata git commit: Fix the bug that table not
exist exception occured when using sparksql and beeline the same time
Repository: incubator-carbondata
Updated Branches:
refs/heads/master dfa768a6f -> 8e932cba1
Fix the bug that table not exist exception occured when using sparksql and beeline the same time
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/27705c17
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/27705c17
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/27705c17
Branch: refs/heads/master
Commit: 27705c17838e3a1a426aee185bcf21db250315f5
Parents: dfa768a
Author: Zhangshunyu <zh...@huawei.com>
Authored: Thu Aug 25 11:40:35 2016 +0800
Committer: ravipesala <ra...@gmail.com>
Committed: Sat Aug 27 08:34:17 2016 +0530
----------------------------------------------------------------------
.../spark/sql/execution/command/carbonTableSchema.scala | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/27705c17/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 2c76126..ca95512 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
@@ -1341,6 +1341,13 @@ private[sql] case class ShowLoads(
override def run(sqlContext: SQLContext): Seq[Row] = {
val databaseName = getDB.getDatabaseName(databaseNameOp, sqlContext)
val tableUniqueName = databaseName + "_" + tableName
+ // Here using checkSchemasModifiedTimeAndReloadTables in tableExists to reload metadata if
+ // schema is changed by other process, so that tableInfoMap woulb be refilled.
+ val tableExists = CarbonEnv.getInstance(sqlContext).carbonCatalog
+ .tableExists(TableIdentifier(tableName, databaseNameOp))(sqlContext)
+ if (!tableExists) {
+ sys.error(s"$databaseName.$tableName is not found")
+ }
val carbonTable = org.apache.carbondata.core.carbon.metadata.CarbonMetadata.getInstance()
.getCarbonTable(tableUniqueName)
if (carbonTable == null) {
[2/2] incubator-carbondata git commit: [CARBONDATA-178]Fix bug that
table not exist when execute show segments using spark-sql and beeline the
same time. This closes #94
Posted by ra...@apache.org.
[CARBONDATA-178]Fix bug that table not exist when execute show segments using spark-sql and beeline the same time. This closes #94
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/8e932cba
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/8e932cba
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/8e932cba
Branch: refs/heads/master
Commit: 8e932cba1596311210dbeec9d27f391600903ef5
Parents: dfa768a 27705c1
Author: ravipesala <ra...@gmail.com>
Authored: Sat Aug 27 08:35:56 2016 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Sat Aug 27 08:35:56 2016 +0530
----------------------------------------------------------------------
.../spark/sql/execution/command/carbonTableSchema.scala | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------