This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 55272b3a5652c16560a9f7391d1b50cb94410d7e Author: Stephan Ewen <[email protected]> AuthorDate: Thu Feb 20 18:23:05 2020 +0100 [hotfix][DataStream API] Minor JavaDoc / deprecation cleanup in CheckpointedFunction --- .../apache/flink/streaming/api/checkpoint/CheckpointedFunction.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java index 91bf241..604e7f4 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java @@ -141,7 +141,6 @@ import org.apache.flink.runtime.state.FunctionSnapshotContext; * @see RuntimeContext */ @PublicEvolving -@SuppressWarnings("deprecation") public interface CheckpointedFunction { /** @@ -150,7 +149,7 @@ public interface CheckpointedFunction { * the Function was initialized, or offered now by {@link FunctionSnapshotContext} itself. * * @param context the context for drawing a snapshot of the operator - * @throws Exception + * @throws Exception Thrown, if state could not be created ot restored. */ void snapshotState(FunctionSnapshotContext context) throws Exception; @@ -159,8 +158,7 @@ public interface CheckpointedFunction { * execution. Functions typically set up their state storing data structures in this method. * * @param context the context for initializing the operator - * @throws Exception + * @throws Exception Thrown, if state could not be created ot restored. */ void initializeState(FunctionInitializationContext context) throws Exception; - }
