flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [02/11] flink git commit: [hotfix] [runtime] Reduce the gazillion deprecation warnings from the backwards-compatible savepoint path
Date Tue, 28 Feb 2017 18:36:45 GMT
[hotfix] [runtime] Reduce the gazillion deprecation warnings from the backwards-compatible
savepoint path


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/40743aac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/40743aac
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/40743aac

Branch: refs/heads/master
Commit: 40743aac9257677142a510fdd869036d13436edc
Parents: daf0ccd
Author: Stephan Ewen <sewen@apache.org>
Authored: Fri Feb 24 18:22:50 2017 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Tue Feb 28 18:59:09 2017 +0100

----------------------------------------------------------------------
 .../flink/migration/MigrationNamespaceSerializerProxy.java       | 1 +
 .../src/main/java/org/apache/flink/migration/MigrationUtil.java  | 1 +
 .../flink/migration/api/common/state/ListStateDescriptor.java    | 1 +
 .../apache/flink/migration/runtime/checkpoint/KeyGroupState.java | 1 +
 .../apache/flink/migration/runtime/checkpoint/SubtaskState.java  | 1 +
 .../org/apache/flink/migration/runtime/checkpoint/TaskState.java | 1 +
 .../migration/runtime/checkpoint/savepoint/SavepointV0.java      | 1 +
 .../runtime/checkpoint/savepoint/SavepointV0Serializer.java      | 1 +
 .../flink/migration/runtime/state/AbstractCloseableHandle.java   | 1 +
 .../flink/migration/runtime/state/AbstractStateBackend.java      | 1 +
 .../apache/flink/migration/runtime/state/KvStateSnapshot.java    | 1 +
 .../org/apache/flink/migration/runtime/state/StateHandle.java    | 1 +
 .../org/apache/flink/migration/runtime/state/StateObject.java    | 1 +
 .../apache/flink/migration/runtime/state/StreamStateHandle.java  | 1 +
 .../runtime/state/filesystem/AbstractFileStateHandle.java        | 1 +
 .../runtime/state/filesystem/AbstractFsStateSnapshot.java        | 1 +
 .../runtime/state/filesystem/FileSerializableStateHandle.java    | 1 +
 .../runtime/state/filesystem/FileStreamStateHandle.java          | 1 +
 .../flink/migration/runtime/state/filesystem/FsFoldingState.java | 1 +
 .../flink/migration/runtime/state/filesystem/FsListState.java    | 1 +
 .../migration/runtime/state/filesystem/FsReducingState.java      | 1 +
 .../flink/migration/runtime/state/filesystem/FsStateBackend.java | 1 +
 .../flink/migration/runtime/state/filesystem/FsValueState.java   | 1 +
 .../migration/runtime/state/memory/AbstractMemStateSnapshot.java | 1 +
 .../migration/runtime/state/memory/ByteStreamStateHandle.java    | 1 +
 .../flink/migration/runtime/state/memory/MemFoldingState.java    | 1 +
 .../flink/migration/runtime/state/memory/MemListState.java       | 1 +
 .../flink/migration/runtime/state/memory/MemReducingState.java   | 1 +
 .../flink/migration/runtime/state/memory/MemValueState.java      | 1 +
 .../migration/runtime/state/memory/SerializedStateHandle.java    | 1 +
 .../flink/migration/state/MigrationKeyGroupStateHandle.java      | 4 ++--
 .../apache/flink/migration/state/MigrationStreamStateHandle.java | 4 ++--
 .../flink/migration/streaming/runtime/tasks/StreamTaskState.java | 1 +
 .../migration/streaming/runtime/tasks/StreamTaskStateList.java   | 1 +
 34 files changed, 36 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/MigrationNamespaceSerializerProxy.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/MigrationNamespaceSerializerProxy.java
b/flink-runtime/src/main/java/org/apache/flink/migration/MigrationNamespaceSerializerProxy.java
index 808a9ae..91fa633 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/MigrationNamespaceSerializerProxy.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/MigrationNamespaceSerializerProxy.java
@@ -32,6 +32,7 @@ import java.io.Serializable;
  * the first run under Flink 1.2 and provides again the real namespace serializer.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class MigrationNamespaceSerializerProxy extends TypeSerializer<Serializable>
{
 
 	public static final MigrationNamespaceSerializerProxy INSTANCE = new MigrationNamespaceSerializerProxy();

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/MigrationUtil.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/MigrationUtil.java b/flink-runtime/src/main/java/org/apache/flink/migration/MigrationUtil.java
index 76d4eef..9427f72 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/MigrationUtil.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/MigrationUtil.java
@@ -25,6 +25,7 @@ import java.util.Collection;
 
 public class MigrationUtil {
 
+	@SuppressWarnings("deprecation")
 	public static boolean isOldSavepointKeyedState(Collection<KeyGroupsStateHandle> keyGroupsStateHandles)
{
 		return (keyGroupsStateHandles != null)
 				&& (keyGroupsStateHandles.size() == 1)

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/api/common/state/ListStateDescriptor.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/api/common/state/ListStateDescriptor.java
b/flink-runtime/src/main/java/org/apache/flink/migration/api/common/state/ListStateDescriptor.java
index 3b1af54..1847c08 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/api/common/state/ListStateDescriptor.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/api/common/state/ListStateDescriptor.java
@@ -31,6 +31,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
  */
 @Internal
 @Deprecated
+@SuppressWarnings("deprecation")
 public class ListStateDescriptor<T> extends StateDescriptor<ListState<T>,
T> {
 	private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java
index ad94993..483a403 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java
@@ -32,6 +32,7 @@ import java.io.Serializable;
  * which might not be available on the JobManager.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class KeyGroupState implements Serializable {
 	private static final long serialVersionUID = -5926696455438467634L;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java
index df886b3..7e84fdc 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java
@@ -26,6 +26,7 @@ import java.io.Serializable;
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class SubtaskState implements Serializable {
 
 	private static final long serialVersionUID = -2394696997971923995L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java
index 798c112..91d8ba0 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java
@@ -30,6 +30,7 @@ import java.util.Objects;
 import java.util.Set;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class TaskState implements Serializable {
 
 	private static final long serialVersionUID = -4845578005863201810L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java
index 8aa562e..1c51a69 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java
@@ -29,6 +29,7 @@ import java.util.Collection;
  *
  * <p>This format was introduced with Flink 1.1.0.
  */
+@SuppressWarnings("deprecation")
 public class SavepointV0 implements Savepoint {
 
 	/** The savepoint version. */

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java
index 2efe786..4739033 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java
@@ -67,6 +67,7 @@ import java.util.Map;
  * that no default Java serialization is used for serialization. Therefore, we
  * don't rely on any involved Java classes to stay the same.
  */
+@SuppressWarnings("deprecation")
 public class SavepointV0Serializer implements SavepointSerializer<SavepointV1> {
 
 	public static final SavepointV0Serializer INSTANCE = new SavepointV0Serializer();

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractCloseableHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractCloseableHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractCloseableHandle.java
index 873dab8..ad75dae 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractCloseableHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractCloseableHandle.java
@@ -30,6 +30,7 @@ import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
  * the handle is closed or was already closed.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public abstract class AbstractCloseableHandle implements Closeable, Serializable {
 
 	/** Serial Version UID must be constant to maintain format compatibility */

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java
index 1d76c06..ff97e19 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java
@@ -28,6 +28,7 @@ import java.io.Serializable;
  * A state backend defines how state is stored and snapshotted during checkpoints.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public abstract class AbstractStateBackend implements Serializable {
 	
 	private static final long serialVersionUID = 4620413814639220247L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/KvStateSnapshot.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/KvStateSnapshot.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/KvStateSnapshot.java
index 9936ca7..7aecd31 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/KvStateSnapshot.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/KvStateSnapshot.java
@@ -22,6 +22,7 @@ import org.apache.flink.api.common.state.State;
 import org.apache.flink.api.common.state.StateDescriptor;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public interface KvStateSnapshot<K, N, S extends State, SD extends StateDescriptor<S,
?>>
 		extends StateObject {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateHandle.java
index 97d6984..8cdeefa 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateHandle.java
@@ -24,6 +24,7 @@ package org.apache.flink.migration.runtime.state;
  * is lightweight or fetching it lazily from some external storage when the state is too
large.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public interface StateHandle<T> extends StateObject {
 
 	/**

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateObject.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateObject.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateObject.java
index 2f1048f..128a074 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateObject.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StateObject.java
@@ -34,6 +34,7 @@ package org.apache.flink.migration.runtime.state;
  * </ul>
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public interface StateObject extends java.io.Closeable, java.io.Serializable {
 
 	/**

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StreamStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StreamStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StreamStateHandle.java
index 55f9b58..ee6be97 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StreamStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/StreamStateHandle.java
@@ -25,6 +25,7 @@ import java.io.Serializable;
  * A state handle that produces an input stream when resolved.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public interface StreamStateHandle extends StateHandle<InputStream> {
 
 	/**

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFileStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFileStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFileStateHandle.java
index fcdcc78..3d77064 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFileStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFileStateHandle.java
@@ -32,6 +32,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
  * Base class for state that is stored in a file.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public abstract class AbstractFileStateHandle extends AbstractCloseableHandle implements
StateObject {
 
 	private static final long serialVersionUID = 350284443258002355L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFsStateSnapshot.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFsStateSnapshot.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFsStateSnapshot.java
index 59c373b..103c214 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFsStateSnapshot.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/AbstractFsStateSnapshot.java
@@ -34,6 +34,7 @@ import java.io.IOException;
  * @param <SV> The type of the state value.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public abstract class AbstractFsStateSnapshot<K, N, SV, S extends State, SD extends StateDescriptor<S,
?>> 
 		extends AbstractFileStateHandle implements KvStateSnapshot<K, N, S, SD> {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileSerializableStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileSerializableStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileSerializableStateHandle.java
index ef908f5..bee5ded 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileSerializableStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileSerializableStateHandle.java
@@ -33,6 +33,7 @@ import java.io.Serializable;
  * @param <T> The type of state pointed to by the state handle.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FileSerializableStateHandle<T extends Serializable> extends AbstractFileStateHandle
implements StateHandle<T> {
 
 	private static final long serialVersionUID = -657631394290213622L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileStreamStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileStreamStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileStreamStateHandle.java
index 89ff4c4..e44b823 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileStreamStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FileStreamStateHandle.java
@@ -30,6 +30,7 @@ import java.io.Serializable;
  * A state handle that points to state in a file system, accessible as an input stream.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FileStreamStateHandle extends AbstractFileStateHandle implements StreamStateHandle
{
 
 	private static final long serialVersionUID = -6826990484549987311L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsFoldingState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsFoldingState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsFoldingState.java
index e1bac83..6e98a30 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsFoldingState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsFoldingState.java
@@ -24,6 +24,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.core.fs.Path;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FsFoldingState<K, N, T, ACC> {
 	public static class Snapshot<K, N, T, ACC> extends AbstractFsStateSnapshot<K, N,
ACC, FoldingState<T, ACC>, FoldingStateDescriptor<T, ACC>> {
 		private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsListState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsListState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsListState.java
index d4e3d4b..e8f7a9d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsListState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsListState.java
@@ -26,6 +26,7 @@ import org.apache.flink.core.fs.Path;
 import java.util.ArrayList;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FsListState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractFsStateSnapshot<K, N, ArrayList<V>,
ListState<V>, ListStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsReducingState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsReducingState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsReducingState.java
index 5cd9505..8174871 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsReducingState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsReducingState.java
@@ -24,6 +24,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.core.fs.Path;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FsReducingState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractFsStateSnapshot<K, N, V,
ReducingState<V>, ReducingStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsStateBackend.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsStateBackend.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsStateBackend.java
index e964ec9..fbdd393 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsStateBackend.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsStateBackend.java
@@ -24,6 +24,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FsStateBackend extends AbstractStateBackend {
 
 	private static final long serialVersionUID = -8191916350224044011L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsValueState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsValueState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsValueState.java
index 3b432a3..b185f88 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsValueState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/filesystem/FsValueState.java
@@ -24,6 +24,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.core.fs.Path;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class FsValueState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractFsStateSnapshot<K, N, V,
ValueState<V>, ValueStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/AbstractMemStateSnapshot.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/AbstractMemStateSnapshot.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/AbstractMemStateSnapshot.java
index 3336556..6056578 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/AbstractMemStateSnapshot.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/AbstractMemStateSnapshot.java
@@ -29,6 +29,7 @@ import java.util.HashMap;
 import java.util.Map;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public abstract class AbstractMemStateSnapshot<K, N, SV, S extends State, SD extends StateDescriptor<S,
?>> 
 		implements KvStateSnapshot<K, N, S, SD> {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/ByteStreamStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/ByteStreamStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/ByteStreamStateHandle.java
index d9474dc..45785bc 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/ByteStreamStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/ByteStreamStateHandle.java
@@ -28,6 +28,7 @@ import java.io.InputStream;
 import java.io.Serializable;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public final class ByteStreamStateHandle extends AbstractCloseableHandle implements StreamStateHandle
{
 
 	private static final long serialVersionUID = -5280226231200217594L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemFoldingState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemFoldingState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemFoldingState.java
index d6c63c4..0956ddd 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemFoldingState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemFoldingState.java
@@ -23,6 +23,7 @@ import org.apache.flink.api.common.state.FoldingStateDescriptor;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class MemFoldingState<K, N, T, ACC> {
 
 	public static class Snapshot<K, N, T, ACC> extends AbstractMemStateSnapshot<K,
N, ACC, FoldingState<T, ACC>, FoldingStateDescriptor<T, ACC>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemListState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemListState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemListState.java
index 416a898..3ff7c50 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemListState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemListState.java
@@ -25,6 +25,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
 import java.util.ArrayList;
 
 @Deprecated
+@SuppressWarnings("deprecation")
 public class MemListState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractMemStateSnapshot<K, N, ArrayList<V>,
ListState<V>, ListStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemReducingState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemReducingState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemReducingState.java
index 52d60a9..e6154fb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemReducingState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemReducingState.java
@@ -31,6 +31,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
  * @param <V> The type of the values in the list state.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class MemReducingState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractMemStateSnapshot<K, N, V,
ReducingState<V>, ReducingStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemValueState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemValueState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemValueState.java
index ff9bed8..777b0f6 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemValueState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/MemValueState.java
@@ -30,6 +30,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
  * @param <V> The type of the value.
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class MemValueState<K, N, V> {
 
 	public static class Snapshot<K, N, V> extends AbstractMemStateSnapshot<K, N, V,
ValueState<V>, ValueStateDescriptor<V>> {

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java
index d3c9b6c..49d772e 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java
@@ -31,6 +31,7 @@ import java.io.Serializable;
  *
  * @param <T> The type of state represented by this state handle.
  */
+@SuppressWarnings("deprecation")
 public class SerializedStateHandle<T extends Serializable> extends AbstractCloseableHandle
implements StateHandle<T> {
 	
 	private static final long serialVersionUID = 4145685722538475769L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java
index 995d234..ee15b83 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java
@@ -24,12 +24,12 @@ import org.apache.flink.runtime.state.KeyGroupsStateHandle;
 import org.apache.flink.runtime.state.StreamStateHandle;
 import org.apache.flink.util.Migration;
 
-@Internal
-@Deprecated
 /**
  * This class is just a KeyGroupsStateHandle that is tagged as migration, to figure out which
restore logic to apply,
  * e.g. when restoring backend data from a state handle.
  */
+@Internal
+@Deprecated
 public class MigrationKeyGroupStateHandle extends KeyGroupsStateHandle implements Migration
{
 
 	private static final long serialVersionUID = -8554427169776881697L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java
b/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java
index e7831a9..797d5d2 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java
@@ -26,12 +26,12 @@ import org.apache.flink.util.Migration;
 
 import java.io.IOException;
 
-@Internal
-@Deprecated
 /**
  * This class is just a StreamStateHandle that is tagged as migration, to figure out which
restore logic to apply, e.g.
  * when restoring backend data from a state handle.
  */
+@Internal
+@Deprecated
 public class MigrationStreamStateHandle implements StreamStateHandle, Migration {
 
 	private static final long serialVersionUID = -2332113722532150112L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java
b/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java
index f5af185..a6b6e3f 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java
@@ -29,6 +29,7 @@ import java.util.HashMap;
 
 @Deprecated
 @Internal
+@SuppressWarnings("deprecation")
 public class StreamTaskState implements Serializable, Closeable {
 
 	private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/flink/blob/40743aac/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java
b/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java
index 8b0dcd3..07ce44b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java
+++ b/flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java
@@ -27,6 +27,7 @@ import java.util.HashMap;
 
 @Deprecated
 @Internal
+@SuppressWarnings("deprecation")
 public class StreamTaskStateList implements StateHandle<StreamTaskState[]> {
 
 	private static final long serialVersionUID = 1L;


Mime
View raw message