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;