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 <[email protected]> Authored: Tue Jan 10 11:06:50 2017 -0800 Committer: Christian Kadner <[email protected]> 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
