You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2019/05/29 22:35:49 UTC
[kafka] branch 2.2 updated: MINOR: Fix red herring when
ConnectDistributedTest.test_bounce fails. (#6838)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push:
new 0779740 MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838)
0779740 is described below
commit 0779740f9b676af7704f8211b6929d161c1baa89
Author: Alex Diachenko <sa...@gmail.com>
AuthorDate: Wed May 29 15:33:24 2019 -0700
MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838)
Author: Alex Diachenko <sa...@gmail.com>
Reviewer: Randall Hauch <rh...@gmail.com>
---
tests/kafkatest/tests/connect/connect_distributed_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/kafkatest/tests/connect/connect_distributed_test.py b/tests/kafkatest/tests/connect/connect_distributed_test.py
index da7d1de..a27b54d 100644
--- a/tests/kafkatest/tests/connect/connect_distributed_test.py
+++ b/tests/kafkatest/tests/connect/connect_distributed_test.py
@@ -339,7 +339,7 @@ class ConnectDistributedTest(Test):
node.account.ssh("echo -e -n " + repr(self.SECOND_INPUTS) + " >> " + self.INPUT_FILE)
wait_until(lambda: self._validate_file_output(self.FIRST_INPUT_LIST + self.SECOND_INPUT_LIST), timeout_sec=70, err_msg="Sink output file never converged to the same state as the input file")
- @cluster(num_nodes=5)
+ @cluster(num_nodes=6)
@matrix(clean=[True, False])
def test_bounce(self, clean):
"""