yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434539461 @pnowojski I can give you more details : added `set -x` and `set -e`: ``` + stop_kafka_cluster + ${FLINK_DIR}/flink-end-to-end-tests/test-scripts/temp-test-directory-01N/kafka_2.11-2.0.0/bin/kafka-server-stop.sh + ${FLINK_DIR}/flink-end-to-end-tests/test-scripts/temp-test-directory-01N/kafka_2.11-2.0.0/bin/zookeeper-server-stop.sh ++ grep -i 'kafka\.Kafka' ++ jps -vl ++ grep java ++ grep -v grep ++ awk '{print $1}' + PIDS=55405 + '[' '!' -z 55405 ']' + kill -s TERM 55405 ++ jps -vl ++ grep java ++ grep -i QuorumPeerMain ++ grep -v grep ++ awk '{print $1}' + PIDS= [FAIL] 'Modern Kafka end-to-end test' failed after 0 minutes and 57 seconds! Test exited with exit code 1 Stopping taskexecutor daemon (pid: 56949) on host ${MY_HOST}. Stopping standalonesession daemon (pid: 56518) on host ${MY_HOST}. No zookeeper daemon to stop on host ${MY_HOST}. ``` But, just add `set -x` ``` + stop_kafka_cluster + ${FLINK_DIR}/flink-end-to-end-tests/test-scripts/temp-test-directory-21N/kafka_2.11-2.0.0/bin/kafka-server-stop.sh + ${FLINK_DIR}/flink-end-to-end-tests/test-scripts/temp-test-directory-21N/kafka_2.11-2.0.0/bin/zookeeper-server-stop.sh ++ jps -vl ++ grep -i 'kafka\.Kafka' ++ grep java ++ grep -v grep ++ awk '{print $1}' + PIDS=62800 + '[' '!' -z 62800 ']' + kill -s TERM 62800 ++ jps -vl ++ grep java ++ grep -i QuorumPeerMain ++ grep -v grep ++ awk '{print $1}' + PIDS= + '[' '!' -z '' ']' + mv -f ${FLINK_DIR}/flink-dist/target/flink-1.7-SNAPSHOT-bin/flink-1.7-SNAPSHOT/conf/flink-conf.yaml.bak ${FLINK_DIR}/flink-dist/target/flink-1.7-SNAPSHOT-bin/flink-1.7-SNAPSHOT/conf/flink-conf.yaml [PASS] 'Modern Kafka end-to-end test' passed after 1 minutes and 0 seconds! Test exited with exit code 0. Stopping taskexecutor daemon (pid: 64351) on host ${MY_HOST}. Stopping standalonesession daemon (pid: 63917) on host ${MY_HOST}. No zookeeper daemon to stop on host ${MY_HOST}. Deleted all files under ${FLINK_DIR}/flink-dist/target/flink-1.7-SNAPSHOT-bin/flink-1.7-SNAPSHOT/log/ Deleted ${FLINK_DIR}/flink-end-to-end-tests/test-scripts/temp-test-directory-21N [PASS] All tests passed ``` the problem (see comment in this function): ```shell function stop_kafka_cluster { $KAFKA_DIR/bin/kafka-server-stop.sh $KAFKA_DIR/bin/zookeeper-server-stop.sh PIDS=$(jps -vl | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}') if [ ! -z "$PIDS" ]; then kill -s TERM $PIDS fi # here PIDS=$(jps -vl | grep java | grep -i QuorumPeerMain | grep -v grep | awk '{print $1}') if [ ! -z "$PIDS" ]; then kill -s TERM $PIDS fi } ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
