[FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsS…

…ink#restore This closes apache#18795.
nicusX · Feb 16, 2022 · 70ee694 · 70ee694
1 parent d62be2e
commit 70ee694
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java b/...streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
@@ -137,6 +137,7 @@ public StatefulSinkWriter<InputT, BufferedRequestState<PutRecordsRequestEntry>>
         return new KinesisDataStreamsStateSerializer();
     }
 
+    @Internal
     @Override
     public StatefulSinkWriter<InputT, BufferedRequestState<PutRecordsRequestEntry>> restoreWriter(
             InitContext context,