You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2016/10/21 12:21:44 UTC
[04/50] [abbrv] flink git commit: [hotfix] Remove unused imports from
SlotRequestRegistered/Rejected and ResourceSlot
[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/ee20d721
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ee20d721
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ee20d721
Branch: refs/heads/flip-6
Commit: ee20d721f4cbe68a8931986ba4a42bb295ec4bee
Parents: fdd9a7a
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Sep 21 11:47:53 2016 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu Oct 20 19:46:20 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/ee20d721/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/ee20d721/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/ee20d721/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);
}