openwhisk-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cbic...@apache.org
Subject [incubator-openwhisk] branch master updated: Add some logs statements to the test to hunt heisenbug #3022. (#3033)
Date Fri, 01 Dec 2017 10:16:52 GMT
This is an automated email from the ASF dual-hosted git repository.

cbickel pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk.git


The following commit(s) were added to refs/heads/master by this push:
     new 88c6ed2  Add some logs statements to the test to hunt heisenbug #3022. (#3033)
88c6ed2 is described below

commit 88c6ed2ce033c9512dfc5fabbbd21d1e6c3739e0
Author: Jeremias Werner <jeremias.werner@gmail.com>
AuthorDate: Fri Dec 1 11:16:48 2017 +0100

    Add some logs statements to the test to hunt heisenbug #3022. (#3033)
---
 tests/src/test/scala/services/KafkaConnectorTests.scala | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/tests/src/test/scala/services/KafkaConnectorTests.scala b/tests/src/test/scala/services/KafkaConnectorTests.scala
index 8974be3..b3c6552 100644
--- a/tests/src/test/scala/services/KafkaConnectorTests.scala
+++ b/tests/src/test/scala/services/KafkaConnectorTests.scala
@@ -78,7 +78,10 @@ class KafkaConnectorTests extends FlatSpec with Matchers with WskActorSystem
wit
                             waitForSend: FiniteDuration,
                             waitForReceive: FiniteDuration): Iterable[String] = {
     val start = java.lang.System.currentTimeMillis
+    println(s"Send message to topic.\n")
     val sent = Await.result(producer.send(topic, message), waitForSend)
+    println(s"Successfully sent message to topic: ${sent}\n")
+    println(s"Receiving message from topic.\n")
     val received = consumer.peek(waitForReceive).map { case (_, _, _, msg) => new String(msg,
"utf-8") }
     val end = java.lang.System.currentTimeMillis
     val elapsed = end - start

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <commits@openwhisk.apache.org>'].

Mime
View raw message