[flink-kubernetes-operator] branch main updated: [hotfix] Fix observer sort logic for job status merge

[thw]

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

thw pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git


The following commit(s) were added to refs/heads/main by this push:
     new 3e6a00f  [hotfix] Fix observer sort logic for job status merge
3e6a00f is described below

commit 3e6a00f0eb528ad85b91a99424258925ea9304d5
Author: zeus1ammon <45544051+zeus1am...@users.noreply.github.com>
AuthorDate: Wed Feb 23 11:16:55 2022 -0500

    [hotfix] Fix observer sort logic for job status merge
---
 .../apache/flink/kubernetes/operator/observer/JobStatusObserver.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
index c0dabcb..0740dea 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
@@ -89,7 +89,7 @@ public class JobStatusObserver {
         JobStatus newStatus = oldStatus;
         Collections.sort(
                 clusterJobStatuses,
-                (j1, j2) -> -1 * Long.compare(j1.getStartTime(), 
j1.getStartTime()));
+                (j1, j2) -> -1 * Long.compare(j1.getStartTime(), 
j2.getStartTime()));
         JobStatusMessage newJob = clusterJobStatuses.get(0);
 
         if (newStatus == null) {