Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-16990

Unrecognised flag passed to kafka-storage.sh in system test

    XMLWordPrintableJSON

Details

    • Test
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 3.8.0
    • 3.8.0, 3.9.0
    • None
    • None

    Description

      Running TC_PATHS="tests/kafkatest/tests/core/kraft_upgrade_test.py::TestKRaftUpgrade" bash tests/docker/run_tests.sh on trunk (c4a3d2475f) fails with the following:

      [INFO:2024-06-18 09:16:03,139]: Triggering test 2 of 32...
      [INFO:2024-06-18 09:16:03,147]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/core', 'file_name': 'kraft_upgrade_test.py', 'cls_name': 'TestKRaftUpgrade', 'method_name': 'test_isolated_mode_upgrade', 'injected_args': {'from_kafka_version': '3.1.2', 'use_new_coordinator': True, 'metadata_quorum': 'ISOLATED_KRAFT'}}
      [INFO:2024-06-18 09:16:03,151]: RunnerClient: kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT: on run 1/1
      [INFO:2024-06-18 09:16:03,153]: RunnerClient: kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT: Setting up...
      [INFO:2024-06-18 09:16:03,153]: RunnerClient: kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT: Running...
      [INFO:2024-06-18 09:16:05,999]: RunnerClient: kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT: Tearing down...
      [INFO:2024-06-18 09:16:12,366]: RunnerClient: kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT: FAIL: RemoteCommandError({'ssh_config': {'host': 'ducker10', 'hostname': 'ducker10', 'user': 'ducker', 'port': 22, 'password': '', 'identityfile': '/home/ducker/.ssh/id_rsa', 'connecttimeout': None}, 'hostname': 'ducker10', 'ssh_hostname': 'ducker10', 'user': 'ducker', 'externally_routable_ip': 'ducker10', '_logger': <Logger kafkatest.tests.core.kraft_upgrade_test.TestKRaftUpgrade.test_isolated_mode_upgrade.from_kafka_version=3.1.2.use_new_coordinator=True.metadata_quorum=ISOLATED_KRAFT-2 (DEBUG)>, 'os': 'linux', '_ssh_client': <paramiko.client.SSHClient object at 0xffff85bccc70>, '_sftp_client': <paramiko.sftp_client.SFTPClient object at 0xffff85bccdf0>, '_custom_ssh_exception_checks': None}, '/opt/kafka-3.1.2/bin/kafka-storage.sh format --ignore-formatted --config /mnt/kafka/kafka.properties --cluster-id I2eXt9rvSnyhct8BYmW6-w -f group.version=1', 1, b"usage: kafka-storage format [-h] --config CONFIG --cluster-id CLUSTER_ID\n                     [--ignore-formatted]\nkafka-storage: error: unrecognized arguments: '-f'\n")
      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/core/kraft_upgrade_test.py", line 132, in test_isolated_mode_upgrade
          self.run_upgrade(from_kafka_version, group_protocol)
        File "/opt/kafka-dev/tests/kafkatest/tests/core/kraft_upgrade_test.py", line 96, in run_upgrade
          self.kafka.start()
        File "/opt/kafka-dev/tests/kafkatest/services/kafka/kafka.py", line 669, in start
          self.isolated_controller_quorum.start()
        File "/opt/kafka-dev/tests/kafkatest/services/kafka/kafka.py", line 671, in start
          Service.start(self, **kwargs)
        File "/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line 265, in start
          self.start_node(node, **kwargs)
        File "/opt/kafka-dev/tests/kafkatest/services/kafka/kafka.py", line 902, in start_node
          node.account.ssh(cmd)
        File "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/remoteaccount.py", line 35, in wrapper
          return method(self, *args, **kwargs)
        File "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/remoteaccount.py", line 310, in ssh
          raise RemoteCommandError(self, cmd, exit_status, stderr.read())
      ducktape.cluster.remoteaccount.RemoteCommandError: ducker@ducker10: Command '/opt/kafka-3.1.2/bin/kafka-storage.sh format --ignore-formatted --config /mnt/kafka/kafka.properties --cluster-id I2eXt9rvSnyhct8BYmW6-w -f group.version=1' returned non-zero exit status 1. Remote error message: b"usage: kafka-storage format [-h] --config CONFIG --cluster-id CLUSTER_ID\n                     [--ignore-formatted]\nkafka-storage: error: unrecognized arguments: '-f'\n" 

      This may be related to KAFKA-16860

      Attachments

        Issue Links

          Activity

            People

              jolshan Justine Olshan
              gnarula Gaurav Narula
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: