This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 70ee694 [FLINK-26174][kinesis] Add Internal annotation to
KinesisDataStreamsSink#restore
70ee694 is described below
commit 70ee694c62d6762de4a909988c6399bfede28c62
Author: Fabian Paul <fabianp...@ververica.com>
AuthorDate: Wed Feb 16 09:06:03 2022 +0100
[FLINK-26174][kinesis] Add Internal annotation to
KinesisDataStreamsSink#restore
This closes #18795.
---
.../org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
b/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
index 6252bfe..d8288f7 100644
---
a/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
+++
b/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
@@ -137,6 +137,7 @@ public class KinesisDataStreamsSink<InputT> extends
AsyncSinkBase<InputT, PutRec
return new KinesisDataStreamsStateSerializer();
}
+ @Internal
@Override
public StatefulSinkWriter<InputT,
BufferedRequestState<PutRecordsRequestEntry>> restoreWriter(
InitContext context,
