Repository: bahir Updated Branches: refs/heads/master a351549cf -> 28f034f49
[HOTFIX] Fix MQTT test case configuration Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/ab62371e Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/ab62371e Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/ab62371e Branch: refs/heads/master Commit: ab62371e06824e4388eccc15e32b619a11997490 Parents: a351549 Author: Luciano Resende <[email protected]> Authored: Mon Aug 22 12:37:56 2016 -0700 Committer: Luciano Resende <[email protected]> Committed: Mon Aug 22 12:37:56 2016 -0700 ---------------------------------------------------------------------- .../apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/ab62371e/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala ---------------------------------------------------------------------- diff --git a/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala b/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala index 257bd0b..4c1c75f 100644 --- a/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala +++ b/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala @@ -161,7 +161,7 @@ class BasicMQTTSourceSuite extends MQTTStreamSourceSuite { // previously running stream left off. val provider = new MQTTStreamSourceProvider val parameters = Map("brokerUrl" -> ("tcp://" + mqttTestUtils.brokerUri), "topic" -> "test", - "localStorage" -> tmpDir, "clientId" -> "clientId") + "localStorage" -> tmpDir, "clientId" -> "clientId", "QoS" -> "2") val offset: Long = provider.createSource(sqlContext, "", None, "", parameters) .getOffset.get.asInstanceOf[LongOffset].offset assert(offset == 100L)
