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

Connect tests dont handle concurrent config changes

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.0
    • Fix Version/s: 0.10.0.0
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      [INFO - 2016-04-28 18:42:45,346 - runner - log - lineno:221]: SerialTestRunner: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Summary:

      {"error_code":409,"message":"Cannot complete request momentarily due to stale configuration (typically caused by a concurrent config change)"}

      Traceback (most recent call last):
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.4.0-py2.7.egg/ducktape/tests/runner.py", line 106, in run_all_tests
      data = self.run_single_test()
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.4.0-py2.7.egg/ducktape/tests/runner.py", line 160, in run_single_test
      return self.current_test_context.function(self.current_test)
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkatest/tests/connect/connect_rest_test.py", line 72, in test_rest_api
      timeout_sec=10, err_msg="Connectors that were just created did not appear in connector listing")
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.4.0-py2.7.egg/ducktape/utils/util.py", line 31, in wait_until
      if condition():
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkatest/tests/connect/connect_rest_test.py", line 71, in <lambda>
      wait_until(lambda: set(self.cc.list_connectors()) == set(["local-file-source", "local-file-sink"]),
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkatest/services/connect.py", line 101, in list_connectors
      return self._rest('/connectors', node=node)
      File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkatest/services/connect.py", line 135, in _rest
      raise ConnectRestError(resp.status_code, resp.text, resp.url)
      ConnectRestError

        Attachments

          Activity

            People

            • Assignee:
              liquanpei Liquan Pei
              Reporter:
              liquanpei Liquan Pei
              Reviewer:
              Ewen Cheslack-Postava
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - 24h
                24h
                Remaining:
                Remaining Estimate - 24h
                24h
                Logged:
                Time Spent - Not Specified
                Not Specified