You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2018/07/23 11:10:58 UTC
spark git commit: [SQL][HIVE] Correct an assert message in function
makeRDDForTable
Repository: spark
Updated Branches:
refs/heads/master f59de52a2 -> ab18b02e6
[SQL][HIVE] Correct an assert message in function makeRDDForTable
## What changes were proposed in this pull request?
according to the context, "makeRDDForTablePartitions" in assert message should be "makeRDDForPartitionedTable", because "makeRDDForTablePartitions" does't exist in spark code.
## How was this patch tested?
unit tests
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: SongYadong <so...@zte.com.cn>
Closes #21836 from SongYadong/assert_info_modify.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ab18b02e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ab18b02e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ab18b02e
Branch: refs/heads/master
Commit: ab18b02e66fd04bc8f1a4fb7b6a7f2773902a494
Parents: f59de52
Author: SongYadong <so...@zte.com.cn>
Authored: Mon Jul 23 19:10:53 2018 +0800
Committer: hyukjinkwon <gu...@apache.org>
Committed: Mon Jul 23 19:10:53 2018 +0800
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/hive/TableReader.scala | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/ab18b02e/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
index b5444a4..7d57389 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
@@ -110,8 +110,9 @@ class HadoopTableReader(
deserializerClass: Class[_ <: Deserializer],
filterOpt: Option[PathFilter]): RDD[InternalRow] = {
- assert(!hiveTable.isPartitioned, """makeRDDForTable() cannot be called on a partitioned table,
- since input formats may differ across partitions. Use makeRDDForTablePartitions() instead.""")
+ assert(!hiveTable.isPartitioned,
+ "makeRDDForTable() cannot be called on a partitioned table, since input formats may " +
+ "differ across partitions. Use makeRDDForPartitionedTable() instead.")
// Create local references to member variables, so that the entire `this` object won't be
// serialized in the closure below.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org