Repository: bahir
Updated Branches:
refs/heads/master eb9136f8b -> 461a85ce7
[BAHIR-83] temporarily ignore flaky test case "Recovering offset from the last
processed offset." in BasicMQTTSourceSuite
Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/461a85ce
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/461a85ce
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/461a85ce
Branch: refs/heads/master
Commit: 461a85ce7b0885b37a1bad2d42294007e4a91152
Parents: eb9136f
Author: Christian Kadner
Authored: Tue Jan 10 11:06:50 2017 -0800
Committer: Christian Kadner
Committed: Tue Jan 10 11:06:50 2017 -0800
--
.../apache/bahir/sql/streaming/mqtt/MQTTStreamSourceSuite.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/bahir/blob/461a85ce/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 4c1c75f..111a44b 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
@@ -143,7 +143,8 @@ class BasicMQTTSourceSuite extends MQTTStreamSourceSuite {
}
}
- test("Recovering offset from the last processed offset.") {
+ // TODO: reinstate this test after fixing BAHIR-83
+ ignore("Recovering offset from the last processed offset.") {
val sendMessage = "MQTT is a message queue."
import scala.concurrent.ExecutionContext.Implicits.global