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>'].
|