[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/246507a7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/246507a7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/246507a7 Branch: refs/heads/master Commit: 246507a7dd1f9fc8644dbdd6ca724b048f2b8c61 Parents: 0479d6f 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:12:16 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/246507a7/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
