This is an automated email from the ASF dual-hosted git repository. rhauch pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push: new 26ceec2 MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838) 26ceec2 is described below commit 26ceec262db659d81433dd1edb82418454eb8529 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): """