You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/04/23 19:33:16 UTC
spark git commit: [minor][streaming]fixed scala string interpolation
error
Repository: spark
Updated Branches:
refs/heads/master a7d65d38f -> 975f53e4f
[minor][streaming]fixed scala string interpolation error
Author: Prabeesh K <pr...@namshi.com>
Closes #5653 from prabeesh/fix and squashes the following commits:
9d7a9f5 [Prabeesh K] fixed scala string interpolation error
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/975f53e4
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/975f53e4
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/975f53e4
Branch: refs/heads/master
Commit: 975f53e4f978759db7639cd08498ad8cd0ae2a56
Parents: a7d65d3
Author: Prabeesh K <pr...@namshi.com>
Authored: Thu Apr 23 10:33:13 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Thu Apr 23 10:33:13 2015 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/examples/streaming/MQTTWordCount.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/975f53e4/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
----------------------------------------------------------------------
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
index f40caad..85b9a54 100644
--- a/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala
@@ -56,7 +56,7 @@ object MQTTPublisher {
while (true) {
try {
msgtopic.publish(message)
- println(s"Published data. topic: {msgtopic.getName()}; Message: {message}")
+ println(s"Published data. topic: ${msgtopic.getName()}; Message: $message")
} catch {
case e: MqttException if e.getReasonCode == MqttException.REASON_CODE_MAX_INFLIGHT =>
Thread.sleep(10)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org