[hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b2c5c0fd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b2c5c0fd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b2c5c0fd Branch: refs/heads/flip-6 Commit: b2c5c0fd154b3233ef1fb5a65175a94f3111dcd3 Parents: 74570d4 Author: Till Rohrmann <trohrm...@apache.org> Authored: Wed Sep 21 11:47:53 2016 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Fri Oct 14 15:14:40 2016 +0200 ---------------------------------------------------------------------- .../flink/runtime/clusterframework/types/ResourceSlot.java | 4 ---- .../flink/runtime/resourcemanager/SlotRequestRegistered.java | 4 ++-- .../flink/runtime/resourcemanager/SlotRequestRejected.java | 4 ++-- 3 files changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b2c5c0fd/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java index 5fb8aee..4a91a79 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java @@ -20,8 +20,6 @@ package org.apache.flink.runtime.clusterframework.types; import org.apache.flink.runtime.taskexecutor.TaskExecutorGateway; -import java.io.Serializable; - import static org.apache.flink.util.Preconditions.checkNotNull; /** @@ -30,8 +28,6 @@ import static org.apache.flink.util.Preconditions.checkNotNull; */ public class ResourceSlot implements ResourceIDRetrievable { - private static final long serialVersionUID = -5853720153136840674L; - /** The unique identification of this slot */ private final SlotID slotId; http://git-wip-us.apache.org/repos/asf/flink/blob/b2c5c0fd/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRegistered.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRegistered.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRegistered.java index 6b7f6dc..f719dce 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRegistered.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRegistered.java @@ -20,13 +20,13 @@ package org.apache.flink.runtime.resourcemanager; import org.apache.flink.runtime.clusterframework.types.AllocationID; -import java.io.Serializable; - /** * Acknowledgment by the ResourceManager for a SlotRequest from the JobManager */ public class SlotRequestRegistered extends SlotRequestReply { + private static final long serialVersionUID = 4760320859275256855L; + public SlotRequestRegistered(AllocationID allocationID) { super(allocationID); } http://git-wip-us.apache.org/repos/asf/flink/blob/b2c5c0fd/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRejected.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRejected.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRejected.java index cb3ec72..282a7d5 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRejected.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequestRejected.java @@ -20,13 +20,13 @@ package org.apache.flink.runtime.resourcemanager; import org.apache.flink.runtime.clusterframework.types.AllocationID; -import java.io.Serializable; - /** * Rejection message by the ResourceManager for a SlotRequest from the JobManager */ public class SlotRequestRejected extends SlotRequestReply { + private static final long serialVersionUID = 9049346740895325144L; + public SlotRequestRejected(AllocationID allocationID) { super(allocationID); }
