Skip to content

Commit 099b982

Browse files
committed
fix comments
Signed-off-by: Pei Yu <125331682@qq.com>
1 parent 7007534 commit 099b982

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,11 @@ private void handleFailedRequest(
169169
Throwable retryableError = error.getCause() != null ? error.getCause() : error;
170170
if (isRetryable(retryableError)) {
171171
resultHandler.retryForEntries(requestEntries);
172+
} else {
173+
resultHandler.completeExceptionally(
174+
retryableError instanceof Exception
175+
? (Exception) retryableError
176+
: new FlinkRuntimeException(retryableError));
172177
}
173178
}
174179

0 commit comments

Comments
 (0)