[
https://issues.apache.org/jira/browse/FLINK-40188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Taranpreet Kaur updated FLINK-40188:
------------------------------------
Priority: Not a Priority (was: Major)
> Check connection string at the start of job for opensearch distributor
> ----------------------------------------------------------------------
>
> Key: FLINK-40188
> URL: https://issues.apache.org/jira/browse/FLINK-40188
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Opensearch
> Reporter: Taranpreet Kaur
> Priority: Not a Priority
>
> In Kafka Connector distributor, bootstrap URL is validated at the start of
> Flink job while for OpenSearch distributor connection is validated when
> records are sent.
> Fix:
> Add a lightweight connectivity check (e.g., a simple HTTP HEAD or GET to the
> cluster root /) in OpensearchWriter
> constructor, right after creating the RestHighLevelClient. Something like:
> // After: this.client = new RestHighLevelClient(builder);
> // Add early validation:
> try {
> boolean pingSuccess = client.ping(RequestOptions.DEFAULT);
> if (!pingSuccess) {
> throw new FlinkRuntimeException(
> "Failed to connect to OpenSearch cluster at " + hosts + ". Ping
> returned false.");
> }
> } catch (IOException e) {
> throw new FlinkRuntimeException(
> "Failed to connect to OpenSearch cluster at " + hosts + ". Please
> verify the hosts configuration.", e);
> }
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
