You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2020/05/27 11:29:00 UTC
[jira] [Commented] (KAFKA-10050) kafka_log4j_appender.py broken on
JDK11
[ 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)