[ 
https://issues.apache.org/jira/browse/KAFKA-16960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855167#comment-17855167
 ] 

Matthias J. Sax commented on KAFKA-16960:
-----------------------------------------

I applied Justine's patch locally and could run the tests. They passed.

> StreamsUpgradeTest system tests fail in v3.7.1 RC1
> --------------------------------------------------
>
>                 Key: KAFKA-16960
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16960
>             Project: Kafka
>          Issue Type: Improvement
>            Reporter: Luke Chen
>            Assignee: Matthias J. Sax
>            Priority: Major
>
> logs: 
> https://www.dropbox.com/scl/fi/ihairvyzudrm5vppu9l9x/2024-06-14-002.zip?rlkey=tn4sesl4g8fj5l4jylccno604&e=1&st=zjavznyb&dl=0
> {code:java}
> ================================================================================
> SESSION REPORT (ALL TESTS)
> ducktape version: 0.11.4
> session_id:       2024-06-14--002
> run time:         32 minutes 6.131 seconds
> tests run:        14
> passed:           10
> flaky:            0
> failed:           4
> ignored:          0
> ================================================================================
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.2.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     FAIL
> run time:   5 minutes 2.298 seconds
>     TimeoutError("Did expect to read 'processed [0-9]* records' from 
> ducker@ducker05")
> Traceback (most recent call last):
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 186, in _do_run
>     data = self.run_test()
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 246, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 
> 433, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 101, in test_app_upgrade
>     self.start_all_nodes_with(from_version)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 157, in start_all_nodes_with
>     self.wait_for_verification(self.processor1, self.processed_msg, 
> self.processor1.STDOUT_FILE)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 209, in wait_for_verification
>     wait_until(lambda: self.verify_from_file(processor, message, file) >= 
> num_lines,
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/utils/util.py", line 
> 58, in wait_until
>     raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from 
> last_exception
> ducktape.errors.TimeoutError: Did expect to read 'processed [0-9]* records' 
> from 
> ducker@ducker05--------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.3.1.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     FAIL
> run time:   4 minutes 37.443 seconds
>     TimeoutError("Did expect to read 'SMOKE-TEST-CLIENT-STARTED' from 
> ducker@ducker11")
> Traceback (most recent call last):
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 186, in _do_run
>     data = self.run_test()
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 246, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 
> 433, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 101, in test_app_upgrade
>     self.start_all_nodes_with(from_version)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 152, in start_all_nodes_with
>     self.wait_for_verification(self.processor1, "SMOKE-TEST-CLIENT-STARTED", 
> self.processor1.STDOUT_FILE)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 209, in wait_for_verification
>     wait_until(lambda: self.verify_from_file(processor, message, file) >= 
> num_lines,
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/utils/util.py", line 
> 58, in wait_until
>     raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from 
> last_exception
> ducktape.errors.TimeoutError: Did expect to read 'SMOKE-TEST-CLIENT-STARTED' 
> from 
> ducker@ducker11--------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.4.1.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     FAIL
> run time:   4 minutes 41.172 seconds
>     TimeoutError("Did expect to read 'SMOKE-TEST-CLIENT-STARTED' from 
> ducker@ducker04")
> Traceback (most recent call last):
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 186, in _do_run
>     data = self.run_test()
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 246, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 
> 433, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 101, in test_app_upgrade
>     self.start_all_nodes_with(from_version)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 152, in start_all_nodes_with
>     self.wait_for_verification(self.processor1, "SMOKE-TEST-CLIENT-STARTED", 
> self.processor1.STDOUT_FILE)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 209, in wait_for_verification
>     wait_until(lambda: self.verify_from_file(processor, message, file) >= 
> num_lines,
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/utils/util.py", line 
> 58, in wait_until
>     raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from 
> last_exception
> ducktape.errors.TimeoutError: Did expect to read 'SMOKE-TEST-CLIENT-STARTED' 
> from 
> ducker@ducker04--------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.5.1.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     FAIL
> run time:   5 minutes 1.811 seconds
>     TimeoutError("Did expect to read 'processed [0-9]* records' from 
> ducker@ducker10")
> Traceback (most recent call last):
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 186, in _do_run
>     data = self.run_test()
>   File 
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", 
> line 246, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 
> 433, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 101, in test_app_upgrade
>     self.start_all_nodes_with(from_version)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 157, in start_all_nodes_with
>     self.wait_for_verification(self.processor1, self.processed_msg, 
> self.processor1.STDOUT_FILE)
>   File 
> "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_application_upgrade_test.py",
>  line 209, in wait_for_verification
>     wait_until(lambda: self.verify_from_file(processor, message, file) >= 
> num_lines,
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/utils/util.py", line 
> 58, in wait_until
>     raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from 
> last_exception
> ducktape.errors.TimeoutError: Did expect to read 'processed [0-9]* records' 
> from 
> ducker@ducker10--------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.6.3.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 18.426 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.7.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 9.421 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=2.8.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 14.776 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.0.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 17.446 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.1.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 14.404 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.2.3.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 13.951 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.3.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 20.795 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.4.1.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 16.313 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.5.2.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 17.429 seconds
> --------------------------------------------------------------------------------
> test_id:    
> kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.from_version=3.6.1.to_version=3.7.1-SNAPSHOT.bounce_type=full
> status:     PASS
> run time:   1 minute 20.143 seconds
> --------------------------------------------------------------------------------
> ================================================================================
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to