This is an automated email from the ASF dual-hosted git repository. rhauch pushed a commit to branch 2.3 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push: new b2c77b9 MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838) b2c77b9 is described below commit b2c77b980c29437f521d2e2741bbbe3ac742e639 Author: Alex Diachenko <sansanic...@gmail.com> AuthorDate: Wed May 29 15:33:24 2019 -0700 MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838) Author: Alex Diachenko <sansanic...@gmail.com> Reviewer: Randall Hauch <rha...@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): """