heesung-sn commented on code in PR #16011:
URL: https://github.com/apache/pulsar/pull/16011#discussion_r895237689
##########
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java:
##########
@@ -1584,7 +1584,7 @@ private void publishAndConsumeMessages(String inputTopic,
}
for (int i = 0; i < numMessages; i++) {
- Message<byte[]> msg = consumer.receive(30, TimeUnit.SECONDS);
+ Message<byte[]> msg = consumer.receive();
Review Comment:
I don't have the clear answer here.
To me, 2 vCPUs might not be enough for the e2e tests, especially when
running all pulsar components with dockers. I could be wrong here.
If this timeout issue started happening only recently, then I agree that we
have a bug here. Please let me know if we do not want this change. The
intention is to make the test more stable for other PRs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
