Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5568#discussion_r170577917 --- Diff: test-infra/end-to-end-test/test_streaming_kafka010.sh --- @@ -64,18 +65,18 @@ $KAFKA_DIR/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication $KAFKA_DIR/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-output # run the Flink job (detached mode) -$FLINK_DIR/bin/flink run -d build-target/examples/streaming/Kafka010Example.jar \ +$FLINK_DIR/bin/flink run -d $FLINK_DIR/examples/streaming/Kafka010Example.jar \ --- End diff -- This ```Kafka010Example.jar``` is the use code and load this jar with child first classloading in this test ?
---