You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2022/02/16 08:23:04 UTC
[flink] branch master updated: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore
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 <fa...@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,