From f0cda587fb80bf2f1ba53d35dc9dc87bf72ee338 Mon Sep 17 00:00:00 2001
From: Cheng Lian <lian@databricks.com>
Date: Thu, 6 Aug 2015 22:49:01 -0700
Subject: [PATCH] [SPARK-7550] [SQL] [MINOR] Fixes logs when persisting
DataFrames
Author: Cheng Lian <lian@databricks.com>
Closes #8021 from liancheng/spark-7550/fix-logs and squashes the following commits:
b7bd0ed [Cheng Lian] Fixes logs
---
.../org/apache/spark/sql/hive/HiveMetastoreCatalog.scala | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala
index 1523ebe9d5..7198a32df4 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala
@@ -317,19 +317,17 @@ private[hive] class HiveMetastoreCatalog(val client: ClientInterface, hive: Hive
case (Some(serde), relation: HadoopFsRelation) if relation.partitionColumns.nonEmpty =>
logWarning {
- val paths = relation.paths.mkString(", ")
"Persisting partitioned data source relation into Hive metastore in " +
s"Spark SQL specific format, which is NOT compatible with Hive. Input path(s): " +
- paths.mkString("\n", "\n", "")
+ relation.paths.mkString("\n", "\n", "")
}
newSparkSQLSpecificMetastoreTable()
case (Some(serde), relation: HadoopFsRelation) =>
logWarning {
- val paths = relation.paths.mkString(", ")
"Persisting data source relation with multiple input paths into Hive metastore in " +
s"Spark SQL specific format, which is NOT compatible with Hive. Input paths: " +
- paths.mkString("\n", "\n", "")
+ relation.paths.mkString("\n", "\n", "")
}
newSparkSQLSpecificMetastoreTable()
--
GitLab