flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [04/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot
Date Fri, 21 Oct 2016 12:21:44 GMT
[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 <trohrmann@apache.org>
Authored: Wed Sep 21 11:47:53 2016 +0200
Committer: Till Rohrmann <trohrmann@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);
 	}


Mime
View raw message