This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 9f90d4b  [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable
9f90d4b is described below

commit 9f90d4b31f1e2316b0e01a10cb0d727ab647677e
Author: Yangze Guo <[email protected]>
AuthorDate: Fri Jun 18 10:13:14 2021 +0800

    [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable
    
    This closes #16188.
---
 .../flink/runtime/resourcemanager/TaskManagerInfoWithSlots.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskManagerInfoWithSlots.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskManagerInfoWithSlots.java
index ccde008..933f513 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskManagerInfoWithSlots.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskManagerInfoWithSlots.java
@@ -23,11 +23,14 @@ import 
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerInfo;
 import org.apache.flink.runtime.taskexecutor.TaskExecutor;
 import org.apache.flink.util.Preconditions;
 
+import java.io.Serializable;
 import java.util.Collection;
 import java.util.Collections;
 
 /** Contains the base information about a {@link TaskExecutor} and its 
allocated slots. */
-public class TaskManagerInfoWithSlots {
+public class TaskManagerInfoWithSlots implements Serializable {
+
+    private static final long serialVersionUID = 1L;
 
     private final TaskManagerInfo taskManagerInfo;
     private final Collection<SlotInfo> allocatedSlots;

Reply via email to