WenDing-Y commented on code in PR #9161:
URL: https://github.com/apache/seatunnel/pull/9161#discussion_r2041398795
##########
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceSplitEnumerator.java:
##########
@@ -80,9 +87,7 @@ public ElasticsearchSourceSplitEnumerator(
}
@Override
- public void open() {
- esRestClient = EsRestClient.createInstance(connConfig);
- }
Review Comment:
In other projects, it's difficult to reproduce this issue—so far, it has
only been reproduced in Flink.
If we wait for an official fix, it may take a long time or even yield no
results.
Given these two points, I think we can proceed with this workaround for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
