fix comment

sd4324530 · sd4324530 · commit e0d17755dd77 · 2026-04-09T19:40:58.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/Elasticsearch8AsyncSink.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSink.java
@@ -79,7 +79,7 @@ protected Elasticsearch8AsyncSink(
     }
 
     /**
-     * Creates a new {@link StatefulSinkWriter} for writing elements to Elasticsearch.
+     * Creates a new {@link SinkWriter} for writing elements to Elasticsearch.
      *
      * @param context the initialization context.
      * @return a new instance of {@link Elasticsearch8AsyncWriter}.
@@ -100,7 +100,7 @@ public SinkWriter<InputT> createWriter(InitContext context) {
     }
 
     /**
-     * Restores a {@link StatefulSinkWriter} from a previously saved state.
+     * Restores a {@link StatefulSinkWriterAdapter} from a previously saved state.
      *
      * @param context the initialization context.
      * @param recoveredState the recovered state.

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ protected Elasticsearch8AsyncSink(`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`/**`
`82`		`- * Creates a new {@link StatefulSinkWriter} for writing elements to Elasticsearch.`
	`82`	`+ * Creates a new {@link SinkWriter} for writing elements to Elasticsearch.`
`83`	`83`	`*`
`84`	`84`	`* @param context the initialization context.`
`85`	`85`	`* @return a new instance of {@link Elasticsearch8AsyncWriter}.`
`@@ -100,7 +100,7 @@ public SinkWriter<InputT> createWriter(InitContext context) {`
`100`	`100`	`}`
`101`	`101`
`102`	`102`	`/**`
`103`		`- * Restores a {@link StatefulSinkWriter} from a previously saved state.`
	`103`	`+ * Restores a {@link StatefulSinkWriterAdapter} from a previously saved state.`
`104`	`104`	`*`
`105`	`105`	`* @param context the initialization context.`
`106`	`106`	`* @param recoveredState the recovered state.`