[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r177098211 --- Diff: flink-end-to-end-tests/run-nightly-tests.sh --- @@ -47,5 +47,13 @@ EXIT_CODE=0 # EXIT_CODE=$? # fi +if [ $EXIT_CODE ==

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176999221 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176999224 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997747 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997549 --- Diff: flink-end-to-end-tests/test-scripts/test_batch_wordcount.sh --- @@ -22,4 +22,4 @@ source "$(dirname "$0")"/common.sh start_cluster

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997786 --- Diff: flink-end-to-end-tests/run-nightly-tests.sh --- @@ -47,5 +47,13 @@ EXIT_CODE=0 # EXIT_CODE=$? # fi +if [ $EXIT_CODE ==

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176998055 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996113 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996077 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996131 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995940 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995759 --- Diff: flink-end-to-end-tests/run-nightly-tests.sh --- @@ -47,5 +47,13 @@ EXIT_CODE=0 # EXIT_CODE=$? # fi +if [ $EXIT_CODE == 0

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995662 --- Diff: flink-end-to-end-tests/test-scripts/test_batch_wordcount.sh --- @@ -22,4 +22,4 @@ source "$(dirname "$0")"/common.sh start_cluster

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5761 [FLINK-8989] [e2eTests] Elasticsearch1 end to end test ## What is the purpose of the change This is the first commit for elasticsearch1 end to end test, and fails will have an