You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/02/20 18:21:42 UTC
[flink] 03/03: [hotfix][DataStream API] Minor JavaDoc / deprecation
cleanup in CheckpointedFunction
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 <se...@apache.org>
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;
-
}