diff options
| author | Prabeesh K <prabeesh.k@namshi.com> | 2015-04-23 10:33:13 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-23 10:33:13 -0700 |
| commit | 975f53e4f978759db7639cd08498ad8cd0ae2a56 (patch) | |
| tree | 59a6b2b9dde704109238bad57bd8d9d492a77f01 /examples | |
| parent | a7d65d38f934c5c751ba32aa7ab648c6d16044ab (diff) | |
| download | spark-975f53e4f978759db7639cd08498ad8cd0ae2a56.tar.gz spark-975f53e4f978759db7639cd08498ad8cd0ae2a56.tar.bz2 spark-975f53e4f978759db7639cd08498ad8cd0ae2a56.zip | |
[minor][streaming]fixed scala string interpolation error
Author: Prabeesh K <prabeesh.k@namshi.com>
Closes #5653 from prabeesh/fix and squashes the following commits:
9d7a9f5 [Prabeesh K] fixed scala string interpolation error
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 f40caad322..85b9a54b40 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) |