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 ?
---
