[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r806624471 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/enumerator/Elasticsearch7SourceEnumera

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r806624471 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/enumerator/Elasticsearch7SourceEnumera

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r803656678 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/common/ElasticsearchUtil.java ##

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r803632122 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/reader/Elasticsearch7SplitReader.java

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r803586116 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/reader/Elasticsearch7Record.java #

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802774901 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSource.java ##

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802772088 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table/RowDataElasticsearch7SearchHitDeseriali

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802765395 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/enumerator/Elasticsearch7SourceEnumSta

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802762536 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/Elasticsearch7SourceBuilder.java #

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802754265 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/Elasticsearch7SourceBuilder.java #

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802739776 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/common/ElasticsearchUtil.java ##

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802732166 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/split/Elasticsearch7SplitState.java ##

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802730687 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/split/Elasticsearch7SplitSerializer.ja

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802727244 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/reader/Elasticsearch7SearchHitReader.j

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802713900 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/enumerator/Elasticsearch7SourceEnumSta

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802667734 ## File path: flink-connectors/flink-connector-elasticsearch7/pom.xml ## @@ -91,6 +91,14 @@ under the License.