[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16669516#comment-16669516
]
ASF GitHub Bot commented on FLINK-10600:
----------------------------------------
yanghua commented 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 :
```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
> Provide End-to-end test cases for modern Kafka connectors
> ---------------------------------------------------------
>
> Key: FLINK-10600
> URL: https://issues.apache.org/jira/browse/FLINK-10600
> Project: Flink
> Issue Type: Sub-task
> Components: Kafka Connector
> Reporter: vinoyang
> Assignee: vinoyang
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.7.0
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
