diff --git a/omnicache/omnicache-spark-extension/plugin/src/main/scala/com/huawei/boostkit/spark/util/ViewMetadata.scala b/omnicache/omnicache-spark-extension/plugin/src/main/scala/com/huawei/boostkit/spark/util/ViewMetadata.scala index 31b02b9325de07199c163c4592f62417162b1d34..6052e4ecd880ca316268dd642a621c96cf8ace9f 100644 --- a/omnicache/omnicache-spark-extension/plugin/src/main/scala/com/huawei/boostkit/spark/util/ViewMetadata.scala +++ b/omnicache/omnicache-spark-extension/plugin/src/main/scala/com/huawei/boostkit/spark/util/ViewMetadata.scala @@ -95,7 +95,7 @@ object ViewMetadata extends RewriteHelper { viewToTablePlan.putIfAbsent(viewName, mappedViewTablePlan) } catch { case e: Throwable => - logWarning(s"Failed to saveViewMetadataToMap. errmsg: ${e.getMessage}") + logDebug(s"Failed to saveViewMetadataToMap. errmsg: ${e.getMessage}") // reset preDatabase spark.sessionState.catalogManager.setCurrentNamespace(Array(preDatabase)) } @@ -159,7 +159,7 @@ object ViewMetadata extends RewriteHelper { } catch { // if db exists a table hive materialized view, will throw annalysis exception case e: Throwable => - logWarning(s"Failed to listTables in $mvDataBase, errmsg: ${e.getMessage}") + logDebug(s"Failed to listTables in $mvDataBase, errmsg: ${e.getMessage}") Seq.empty[(TableIdentifier, CatalogTable)] } } diff --git a/omnicache/omnicache-spark-extension/plugin/src/main/scala/org/apache/spark/sql/execution/command/OmniCacheCommand.scala b/omnicache/omnicache-spark-extension/plugin/src/main/scala/org/apache/spark/sql/execution/command/OmniCacheCommand.scala index 2df368cdb06c867be0ef24ea4adb3855cd8dc0c9..36f59ea21e2138fb341f8db759f1ecbd631b4624 100644 --- a/omnicache/omnicache-spark-extension/plugin/src/main/scala/org/apache/spark/sql/execution/command/OmniCacheCommand.scala +++ b/omnicache/omnicache-spark-extension/plugin/src/main/scala/org/apache/spark/sql/execution/command/OmniCacheCommand.scala @@ -52,7 +52,7 @@ case class OmniCacheCreateMvCommand( val identifier = TableIdentifier(name, Option(databaseName)) val (storageFormat, provider) = getStorageFormatAndProvider( - providerStr, properties, None + providerStr, Map.empty, None ) val table = buildCatalogTable(