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

benjobs pushed a commit to branch dev-2.1.4
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
     new cab1e5542 [Improve]  Objects.nonNull minor improvement
cab1e5542 is described below

commit cab1e554264a6d7831dab3a3d21121b2b04107e4
Author: benjobs <[email protected]>
AuthorDate: Thu Apr 4 21:38:02 2024 +0800

    [Improve]  Objects.nonNull minor improvement
---
 .../apache/streampark/console/core/metrics/flink/CheckPoints.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
index 1cafc0b7f..8aeadb1fc 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
@@ -29,7 +29,6 @@ import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
-import java.util.Objects;
 
 @Getter
 @Setter
@@ -103,10 +102,10 @@ public class CheckPoints implements Serializable {
     @JsonIgnore
     public List<CheckPoint> getLatestCheckpoint() {
       List<CheckPoint> checkPoints = new ArrayList<>();
-      if (Objects.nonNull(completed)) {
+      if (completed != null) {
         checkPoints.add(completed);
       }
-      if (Objects.nonNull(savepoint)) {
+      if (savepoint != null) {
         checkPoints.add(savepoint);
       }
       return checkPoints;

Reply via email to