[flink] branch master updated: [FLINK-26779][rest] OperationKey implements Serializable

[chesnay]

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

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 07150c4  [FLINK-26779][rest] OperationKey implements Serializable
07150c4 is described below

commit 07150c47ffb4b9bcfc65ab5fa6ee894d401fdfb9
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Mon Mar 21 14:19:15 2022 +0100

    [FLINK-26779][rest] OperationKey implements Serializable
---
 .../org/apache/flink/runtime/rest/handler/async/OperationKey.java    | 5 ++++-
 .../flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java  | 2 ++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java
index 85df2ac..d908eef 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java
@@ -21,13 +21,16 @@ package org.apache.flink.runtime.rest.handler.async;
 import org.apache.flink.runtime.rest.messages.TriggerId;
 import org.apache.flink.util.Preconditions;
 
+import java.io.Serializable;
 import java.util.Objects;
 
 /**
  * Any operation key for the {@link AbstractAsynchronousOperationHandlers} 
must extend this class.
  * It is used to store the trigger id.
  */
-public class OperationKey {
+public class OperationKey implements Serializable {
+
+    private static final long serialVersionUID = 6138473450686379255L;
 
     private final TriggerId triggerId;
 
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java
index 2512a94..7bee295 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java
@@ -37,6 +37,8 @@ import static java.util.Objects.requireNonNull;
 @Immutable
 public class AsynchronousJobOperationKey extends OperationKey {
 
+    private static final long serialVersionUID = -4907777251835275859L;
+
     private final JobID jobId;
 
     private AsynchronousJobOperationKey(final TriggerId triggerId, final JobID 
jobId) {