[ 
https://issues.apache.org/jira/browse/KAFKA-18977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-18977.
------------------------------------
    Resolution: Duplicate

see KAFKA-19429

> Fix flaky streams_smoke_test
> ----------------------------
>
>                 Key: KAFKA-18977
>                 URL: https://issues.apache.org/jira/browse/KAFKA-18977
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams, system tests
>            Reporter: Chia-Ping Tsai
>            Assignee: Chia-Ping Tsai
>            Priority: Major
>
> {code:java}
> RemoteCommandError({'ssh_config': {'host': 'worker21', 'hostname': 
> '10.140.61.216', 'user': 'ubuntu', 'port': 22, 'password': None, 
> 'identityfile': '/home/semaphore/kafka-overlay/semaphore-muckrake.pem', 
> 'connecttimeout': None}, 'hostname': 'worker21', 'ssh_hostname': 
> '10.140.61.216', 'user': 'ubuntu', 'externally_routable_ip': '10.140.61.216', 
> '_logger': <Logger 
> kafkatest.tests.streams.streams_smoke_test.StreamsSmokeTest.test_streams.processing_guarantee=at_least_once.crash=True.metadata_quorum=COMBINED_KRAFT-905
>  (DEBUG)>, 'os': 'linux', '_ssh_client': <paramiko.client.SSHClient object at 
> 0x7f92b7365040>, '_sftp_client': <paramiko.sftp_client.SFTPClient object at 
> 0x7f92b758aa60>, '_custom_ssh_exception_checks': None}, 'grep SUCCESS 
> /mnt/streams/streams.stdout', 1, b'')
> Traceback (most recent call last):
>   File 
> "/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/tests/runner_client.py",
>  line 351, in _do_run
>     data = self.run_test()
>   File 
> "/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/tests/runner_client.py",
>  line 411, in run_test
>     return self.test_context.function(self.test)
>   File 
> "/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/mark/_mark.py",
>  line 438, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File 
> "/home/semaphore/kafka-overlay/kafka/tests/kafkatest/tests/streams/streams_smoke_test.py",
>  line 110, in test_streams
>     self.driver.node.account.ssh("grep SUCCESS %s" % self.driver.STDOUT_FILE, 
> allow_fail=False)
>   File 
> "/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/cluster/remoteaccount.py",
>  line 35, in wrapper
>     return method(self, *args, **kwargs)
>   File 
> "/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/cluster/remoteaccount.py",
>  line 310, in ssh
>     raise RemoteCommandError(self, cmd, exit_status, stderr.read())
> ducktape.cluster.remoteaccount.RemoteCommandError: ubuntu@worker21: Command 
> 'grep SUCCESS /mnt/streams/streams.stdout' returned non-zero exit status 1.
> {code}



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

Reply via email to