[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-28 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r860639392 ## flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java: ## @@ -0,0 +1,45 @@

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-27 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r859457944 ## flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/pom.xml: ## @@ -0,0 +1,82 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-22 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r856141131 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/pom.xml: ## @@ -30,10 +30,14 @@ under the License. .. -

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-20 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r854259322 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch-common/src/main/java/org/apache/flink/streaming/tests/KeyValue.java: ## @@ -0,0 +1,74 @@ +package

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-20 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r854078618 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/main/java/org/apache/flink/streaming/tests/Elasticsearch6Client.java: ## @@ -0,0 +1,123 @@ +/* + *

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-20 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r854077355 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchDataReader.java: ## @@ -0,0 +1,67 @@

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-20 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r854069305 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch-common/src/main/java/org/apache/flink/streaming/tests/KeyValue.java: ## @@ -0,0 +1,74 @@ +package

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-20 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r853895298 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch-common/src/main/java/org/apache/flink/streaming/tests/KeyValue.java: ## @@ -0,0 +1,74 @@ +package

[GitHub] [flink] fapaul commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

2022-04-08 Thread GitBox
fapaul commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r846017025 ## flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/pom.xml: ## @@ -0,0 +1,158 @@ + + +http://maven.apache.org/POM/4.0.0; +