[incubator-streampark] branch dev updated: [Improve] Improve streampark-common module base on [3.9 Java Streams] (#3174)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 63e178707 [Improve] Improve streampark-common module base on [3.9 Java 
Streams] (#3174)
63e178707 is described below

commit 63e1787071868111c379e3bd6b7aea3a1ada1dc6
Author: VampireAchao <achao1441470...@gmail.com>
AuthorDate: Sat Sep 23 22:20:29 2023 +0800

    [Improve] Improve streampark-common module base on [3.9 Java Streams] 
(#3174)
---
 .../java/org/apache/streampark/common/enums/RestoreMode.java     | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
 
b/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
index 63ae3a819..8d4eae9bc 100644
--- 
a/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
+++ 
b/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
@@ -17,7 +17,7 @@
 
 package org.apache.streampark.common.enums;
 
-import java.util.Arrays;
+import java.util.Objects;
 
 public enum RestoreMode {
 
@@ -60,6 +60,11 @@ public enum RestoreMode {
   }
 
   public static RestoreMode of(Integer value) {
-    return Arrays.stream(values()).filter((x) -> x.mode == 
value).findFirst().orElse(null);
+    for (RestoreMode restoreMode : values()) {
+      if (Objects.equals(restoreMode.mode, value)) {
+        return restoreMode;
+      }
+    }
+    return null;
   }
 }