Repository: spark
Updated Branches:
refs/heads/master 40f49795e -> ec30c1782
[SPARK-6279][Streaming]In KafkaRDD.scala, Miss expressions flag "s" at logging
string
In KafkaRDD.scala, Miss expressions flag "s" at logging string
In logging file, it print `Beginning offset $
{part.fromOffset}
is the same as ending offset ` but not `Beginning offset 111 is the same as
ending offset `.
Author: zzcclp <[email protected]>
Closes #4979 from zzcclp/SPARK-6279 and squashes the following commits:
768f88e [zzcclp] Miss expressions flag "s"
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ec30c178
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ec30c178
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ec30c178
Branch: refs/heads/master
Commit: ec30c17822329e6d2b8c85625b31ba8bd8679fcf
Parents: 40f4979
Author: zzcclp <[email protected]>
Authored: Wed Mar 11 12:22:24 2015 +0000
Committer: Sean Owen <[email protected]>
Committed: Wed Mar 11 12:22:24 2015 +0000
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/ec30c178/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
----------------------------------------------------------------------
diff --git
a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
index d56cc01..6d465bc 100644
---
a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
+++
b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
@@ -86,7 +86,7 @@ class KafkaRDD[
val part = thePart.asInstanceOf[KafkaRDDPartition]
assert(part.fromOffset <= part.untilOffset, errBeginAfterEnd(part))
if (part.fromOffset == part.untilOffset) {
- log.warn("Beginning offset ${part.fromOffset} is the same as ending
offset " +
+ log.warn(s"Beginning offset ${part.fromOffset} is the same as ending
offset " +
s"skipping ${part.topic} ${part.partition}")
Iterator.empty
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
