[ https://issues.apache.org/jira/browse/KAFKA-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117673#comment-17117673 ]
Nikolay Izhikov commented on KAFKA-10050: ----------------------------------------- Results with the patch: {noformat} nizhikov@kafka:~/kafka$ TC_PATHS="tests/kafkatest/tests/tools/log4j_appender_test.py" bash tests/docker/run_tests.sh > Configure project : Building project 'core' with Scala version 2.13.2 Building project 'streams-scala' with Scala version 2.13.2 Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.4.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD SUCCESSFUL in 1s 111 actionable tasks: 2 executed, 109 up-to-date docker exec ducker01 bash -c "cd /opt/kafka-dev && ducktape --cluster-file /opt/kafka-dev/tests/docker/build/cluster.json ./tests/kafkatest/tests/tools/log4j_appender_test.py" [INFO:2020-05-27 04:25:23,949]: starting test run with session id 2020-05-27--006... [INFO:2020-05-27 04:25:23,949]: running 4 tests... [INFO:2020-05-27 04:25:23,949]: Triggering test 1 of 4... [INFO:2020-05-27 04:25:23,961]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/tools', 'file_name': 'log4j_appender_test.py', 'method_name': 'test_log4j_appender', 'cls_name': 'Log4jAppenderTest', 'injected_args': {'security_protocol': 'SASL_PLAINTEXT'}} [INFO:2020-05-27 04:25:23,966]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: Setting up... /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:39: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. m.add_string(self.Q_C.public_numbers().encode_point()) /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:94: CryptographyDeprecationWarning: Support for unsafe construction of public numbers from encoded data will be removed in a future version. Please use EllipticCurvePublicKey.from_encoded_point self.curve, Q_S_bytes /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:109: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. hm.add_string(self.Q_C.public_numbers().encode_point()) [INFO:2020-05-27 04:25:27,733]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: Running... [INFO:2020-05-27 04:25:50,830]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: PASS [INFO:2020-05-27 04:25:50,831]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: Tearing down... [INFO:2020-05-27 04:25:58,992]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: Summary: [INFO:2020-05-27 04:25:58,993]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT: Data: None [INFO:2020-05-27 04:25:59,009]: ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ [INFO:2020-05-27 04:25:59,010]: Triggering test 2 of 4... [INFO:2020-05-27 04:25:59,020]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/tools', 'file_name': 'log4j_appender_test.py', 'method_name': 'test_log4j_appender', 'cls_name': 'Log4jAppenderTest', 'injected_args': {'security_protocol': 'SASL_SSL'}} [INFO:2020-05-27 04:25:59,024]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: Setting up... /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:39: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. m.add_string(self.Q_C.public_numbers().encode_point()) /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:94: CryptographyDeprecationWarning: Support for unsafe construction of public numbers from encoded data will be removed in a future version. Please use EllipticCurvePublicKey.from_encoded_point self.curve, Q_S_bytes /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:109: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. hm.add_string(self.Q_C.public_numbers().encode_point()) [INFO:2020-05-27 04:26:02,760]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: Running... [INFO:2020-05-27 04:26:32,156]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: PASS [INFO:2020-05-27 04:26:32,156]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: Tearing down... [INFO:2020-05-27 04:26:39,792]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: Summary: [INFO:2020-05-27 04:26:39,792]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL: Data: None [INFO:2020-05-27 04:26:39,801]: ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ [INFO:2020-05-27 04:26:39,802]: Triggering test 3 of 4... [INFO:2020-05-27 04:26:39,812]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/tools', 'file_name': 'log4j_appender_test.py', 'method_name': 'test_log4j_appender', 'cls_name': 'Log4jAppenderTest', 'injected_args': {'security_protocol': 'PLAINTEXT'}} [INFO:2020-05-27 04:26:39,816]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: Setting up... /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:39: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. m.add_string(self.Q_C.public_numbers().encode_point()) /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:94: CryptographyDeprecationWarning: Support for unsafe construction of public numbers from encoded data will be removed in a future version. Please use EllipticCurvePublicKey.from_encoded_point self.curve, Q_S_bytes /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:109: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. hm.add_string(self.Q_C.public_numbers().encode_point()) [INFO:2020-05-27 04:26:43,644]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: Running... [INFO:2020-05-27 04:26:56,333]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: PASS [INFO:2020-05-27 04:26:56,334]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: Tearing down... [INFO:2020-05-27 04:27:03,583]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: Summary: [INFO:2020-05-27 04:27:03,584]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT: Data: None [INFO:2020-05-27 04:27:03,593]: ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ [INFO:2020-05-27 04:27:03,593]: Triggering test 4 of 4... [INFO:2020-05-27 04:27:03,604]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/tools', 'file_name': 'log4j_appender_test.py', 'method_name': 'test_log4j_appender', 'cls_name': 'Log4jAppenderTest', 'injected_args': {'security_protocol': 'SSL'}} [INFO:2020-05-27 04:27:03,609]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: Setting up... /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:39: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. m.add_string(self.Q_C.public_numbers().encode_point()) /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:94: CryptographyDeprecationWarning: Support for unsafe construction of public numbers from encoded data will be removed in a future version. Please use EllipticCurvePublicKey.from_encoded_point self.curve, Q_S_bytes /usr/local/lib/python2.7/dist-packages/paramiko/kex_ecdh_nist.py:109: CryptographyDeprecationWarning: encode_point has been deprecated on EllipticCurvePublicNumbers and will be removed in a future version. Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding. hm.add_string(self.Q_C.public_numbers().encode_point()) [INFO:2020-05-27 04:27:07,645]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: Running... [INFO:2020-05-27 04:27:28,674]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: PASS [INFO:2020-05-27 04:27:28,674]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: Tearing down... [INFO:2020-05-27 04:27:35,937]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: Summary: [INFO:2020-05-27 04:27:35,937]: RunnerClient: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: Data: None ================================================================================ SESSION REPORT (ALL TESTS) ducktape version: 0.7.7 session_id: 2020-05-27--006 run time: 2 minutes 11.997 seconds tests run: 4 passed: 4 failed: 0 ignored: 0 ================================================================================ test_id: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT status: PASS run time: 35.025 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL status: PASS run time: 40.767 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT status: PASS run time: 23.767 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL status: PASS run time: 32.328 seconds -------------------------------------------------------------------------------- nizhikov@kafka:~/kafka$ git status On branch KAFKA-10050 Changes not staged for commit: (use "git add <file>..." to update what will be committed) (use "git restore <file>..." to discard changes in working directory) modified: tests/docker/run_tests.sh no changes added to commit (use "git add" and/or "git commit -a") nizhikov@kafka:~/kafka$ git diff diff --git a/tests/docker/run_tests.sh b/tests/docker/run_tests.sh index 063e24d17..6278f9ac6 100755 --- a/tests/docker/run_tests.sh +++ b/tests/docker/run_tests.sh @@ -30,6 +30,6 @@ if [ "$REBUILD" == "t" ]; then fi if ${SCRIPT_DIR}/ducker-ak ssh | grep -q '(none)'; then - ${SCRIPT_DIR}/ducker-ak up -n "${KAFKA_NUM_CONTAINERS}" || die "ducker-ak up failed" + ${SCRIPT_DIR}/ducker-ak up -j 'openjdk:11' -n "${KAFKA_NUM_CONTAINERS}" || die "ducker-ak up failed" fi ${SCRIPT_DIR}/ducker-ak test ${TC_PATHS} ${_DUCKTAPE_OPTIONS} || die "ducker-ak test failed" nizhikov@kafka:~/kafka$ {noformat} > kafka_log4j_appender.py broken on JDK11 > --------------------------------------- > > Key: KAFKA-10050 > URL: https://issues.apache.org/jira/browse/KAFKA-10050 > Project: Kafka > Issue Type: Bug > Reporter: Nikolay Izhikov > Assignee: Nikolay Izhikov > Priority: Major > > kafka_log4j_appender.py brokern on jdk11 > {noformat} > [INFO:2020-05-27 02:31:27,662]: RunnerClient: > kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL: > Data: None > ================================================================================ > SESSION REPORT (ALL TESTS) > ducktape version: 0.7.7 > session_id: 2020-05-27--002 > run time: 1 minute 41.177 seconds > tests run: 4 > passed: 0 > failed: 4 > ignored: 0 > ================================================================================ > test_id: > kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_PLAINTEXT > status: FAIL > run time: 27.509 seconds > KafkaLog4jAppender-0-140270269628496-worker-1: Traceback (most recent > call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > Traceback (most recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 132, in run > data = self.run_test() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 189, in run_test > return self.test_context.function(self.test) > File "/usr/local/lib/python2.7/dist-packages/ducktape/mark/_mark.py", line > 428, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File "/opt/kafka-dev/tests/kafkatest/tests/tools/log4j_appender_test.py", > line 84, in test_log4j_appender > self.appender.wait() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 72, in wait > self._propagate_exceptions() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 98, in _propagate_exceptions > raise Exception(self.errors) > Exception: KafkaLog4jAppender-0-140270269628496-worker-1: Traceback (most > recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > -------------------------------------------------------------------------------- > test_id: > kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SASL_SSL > status: FAIL > run time: 28.121 seconds > KafkaLog4jAppender-0-140270269498000-worker-1: Traceback (most recent > call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > Traceback (most recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 132, in run > data = self.run_test() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 189, in run_test > return self.test_context.function(self.test) > File "/usr/local/lib/python2.7/dist-packages/ducktape/mark/_mark.py", line > 428, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File "/opt/kafka-dev/tests/kafkatest/tests/tools/log4j_appender_test.py", > line 84, in test_log4j_appender > self.appender.wait() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 72, in wait > self._propagate_exceptions() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 98, in _propagate_exceptions > raise Exception(self.errors) > Exception: KafkaLog4jAppender-0-140270269498000-worker-1: Traceback (most > recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > -------------------------------------------------------------------------------- > test_id: > kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=PLAINTEXT > status: FAIL > run time: 22.451 seconds > KafkaLog4jAppender-0-140270597865104-worker-1: Traceback (most recent > call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > Traceback (most recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 132, in run > data = self.run_test() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 189, in run_test > return self.test_context.function(self.test) > File "/usr/local/lib/python2.7/dist-packages/ducktape/mark/_mark.py", line > 428, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File "/opt/kafka-dev/tests/kafkatest/tests/tools/log4j_appender_test.py", > line 84, in test_log4j_appender > self.appender.wait() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 72, in wait > self._propagate_exceptions() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 98, in _propagate_exceptions > raise Exception(self.errors) > Exception: KafkaLog4jAppender-0-140270597865104-worker-1: Traceback (most > recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > -------------------------------------------------------------------------------- > test_id: > kafkatest.tests.tools.log4j_appender_test.Log4jAppenderTest.test_log4j_appender.security_protocol=SSL > status: FAIL > run time: 22.986 seconds > KafkaLog4jAppender-0-140270597865104-worker-1: Traceback (most recent > call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > Traceback (most recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 132, in run > data = self.run_test() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", > line 189, in run_test > return self.test_context.function(self.test) > File "/usr/local/lib/python2.7/dist-packages/ducktape/mark/_mark.py", line > 428, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File "/opt/kafka-dev/tests/kafkatest/tests/tools/log4j_appender_test.py", > line 84, in test_log4j_appender > self.appender.wait() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 72, in wait > self._propagate_exceptions() > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 98, in _propagate_exceptions > raise Exception(self.errors) > Exception: KafkaLog4jAppender-0-140270597865104-worker-1: Traceback (most > recent call last): > File > "/usr/local/lib/python2.7/dist-packages/ducktape/services/background_thread.py", > line 36, in _protected_worker > self._worker(idx, node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 42, in _worker > cmd = self.start_cmd(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka_log4j_appender.py", > line 48, in start_cmd > cmd = fix_opts_for_new_jvm(node) > File "/opt/kafka-dev/tests/kafkatest/services/kafka/util.py", line 36, in > fix_opts_for_new_jvm > if node.version == LATEST_0_8_2 or node.version == LATEST_0_9 or > node.version == LATEST_0_10_0 or node.version == LATEST_0_10_1 or > node.version == LATEST_0_10_2 or node.version == LATEST_0_11_0 or > node.version == LATEST_1_0: > AttributeError: 'ClusterNode' object has no attribute 'version' > -------------------------------------------------------------------------------- > ducker-ak test failed > {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)