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 @@
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;
+
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.
..
-
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
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 @@
+/*
+ *
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 @@
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
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
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;
+