diff --git a/tests/rptest/clients/rpk.py b/tests/rptest/clients/rpk.py index b5b0c5bfb1286..75ef8633ecacd 100644 --- a/tests/rptest/clients/rpk.py +++ b/tests/rptest/clients/rpk.py @@ -1135,7 +1135,6 @@ def _execute(self, cmd, stdin=None, timeout=None, log_cmd=True, env=None): self._redpanda.logger.debug(f'\n{output}') if p.returncode: - self._redpanda.logger.error(stderror) raise RpkException( 'command %s returned %d, output: %s' % (' '.join(cmd) if log_cmd else '[redacted]', p.returncode, diff --git a/tests/rptest/services/rpk_producer.py b/tests/rptest/services/rpk_producer.py index bad9861550ed2..9c5ea6d028765 100644 --- a/tests/rptest/services/rpk_producer.py +++ b/tests/rptest/services/rpk_producer.py @@ -90,3 +90,6 @@ def output_line_count(self): def stop_node(self, node): self._stopping.set() node.account.kill_process("rpk", clean_shutdown=False) + + def clean_node(self, node): + pass