[hotfix] [test] Make test-streaming-kafka010.sh more flexible for local execution
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59169d0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59169d0e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/59169d0e Branch: refs/heads/release-1.4 Commit: 59169d0eeb2e8ebb1e7f830dd7286914e85f31e7 Parents: cb6a8a6 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Mon Feb 26 16:11:04 2018 +0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Mon Feb 26 23:16:52 2018 +0800 ---------------------------------------------------------------------- test-infra/end-to-end-test/test_streaming_kafka010.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/59169d0e/test-infra/end-to-end-test/test_streaming_kafka010.sh ---------------------------------------------------------------------- diff --git a/test-infra/end-to-end-test/test_streaming_kafka010.sh b/test-infra/end-to-end-test/test_streaming_kafka010.sh index 51a570a..c7564ea 100755 --- a/test-infra/end-to-end-test/test_streaming_kafka010.sh +++ b/test-infra/end-to-end-test/test_streaming_kafka010.sh @@ -64,7 +64,7 @@ $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 \ --input-topic test-input --output-topic test-output \ --prefix=PREFIX \ --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id myconsumer --auto.offset.reset earliest
