You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openwhisk.apache.org by be...@apache.org on 2017/07/10 15:28:13 UTC
[incubator-openwhisk] branch master updated: Bump Kafka Connector
Test timeout to avoid build breaks (#2116)
This is an automated email from the ASF dual-hosted git repository.
berstler 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 d44f672 Bump Kafka Connector Test timeout to avoid build breaks (#2116)
d44f672 is described below
commit d44f6724a947b700202ad1986dac83392c626247
Author: Mark Deuser <md...@us.ibm.com>
AuthorDate: Mon Jul 10 11:28:11 2017 -0400
Bump Kafka Connector Test timeout to avoid build breaks (#2116)
- current limit of 10 seconds is too small on PG3 - causing build failures
- other PG3 connector test times have recently been observed at 8/9+ seconds
---
tests/src/test/scala/services/KafkaConnectorTests.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/src/test/scala/services/KafkaConnectorTests.scala b/tests/src/test/scala/services/KafkaConnectorTests.scala
index 6e6ae7d..60bb3d3 100644
--- a/tests/src/test/scala/services/KafkaConnectorTests.scala
+++ b/tests/src/test/scala/services/KafkaConnectorTests.scala
@@ -75,7 +75,7 @@ class KafkaConnectorTests
for (i <- 0 until 5) {
val message = new Message { override val serialize = Calendar.getInstance().getTime().toString }
val start = java.lang.System.currentTimeMillis
- val sent = Await.result(producer.send(topic, message), 10 seconds)
+ val sent = Await.result(producer.send(topic, message), 20 seconds)
val received = consumer.peek(10 seconds).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" <co...@openwhisk.apache.org>'].