You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by ck...@apache.org on 2017/01/10 19:06:58 UTC
bahir git commit: [BAHIR-83] temporarily ignore flaky test case
"Recovering offset from the last processed offset." in BasicMQTTSourceSuite
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 <ck...@apache.org>
Authored: Tue Jan 10 11:06:50 2017 -0800
Committer: Christian Kadner <ck...@us.ibm.com>
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