fix comment

sd4324530 · sd4324530 · commit 398bb8ad53d6 · 2026-04-09T19:50:34.000+08:00
Signed-off-by: Pei Yu &lt;125331682@qq.com&gt;
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java
@@ -166,7 +166,8 @@ private void handleFailedRequest(
         LOG.debug("The BulkRequest has failed", error);
         numRecordsOutErrorsCounter.inc(requestEntries.size());
 
-        if (isRetryable(error.getCause())) {
+        Throwable retryableError = error.getCause() != null ? error.getCause() : error;
+        if (isRetryable(retryableError)) {
             resultHandler.retryForEntries(requestEntries);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,8 @@ private void handleFailedRequest(`
`166`	`166`	`LOG.debug("The BulkRequest has failed", error);`
`167`	`167`	`numRecordsOutErrorsCounter.inc(requestEntries.size());`
`168`	`168`
`169`		`- if (isRetryable(error.getCause())) {`
	`169`	`+ Throwable retryableError = error.getCause() != null ? error.getCause() : error;`
	`170`	`+ if (isRetryable(retryableError)) {`
`170`	`171`	`resultHandler.retryForEntries(requestEntries);`
`171`	`172`	`}`
`172`	`173`	`}`