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

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 84edea7593 [Improvement-14052][Log] Remove the useless filter in 
getAppIdsFromLogFile (#14053)
84edea7593 is described below

commit 84edea7593216688d839b458d47785d6ade18ad0
Author: Rick Cheng <[email protected]>
AuthorDate: Sat May 6 17:00:53 2023 +0800

    [Improvement-14052][Log] Remove the useless filter in getAppIdsFromLogFile 
(#14053)
---
 .../org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java  | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java
index de2f8d68a1..b2aee43325 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java
@@ -164,10 +164,7 @@ public class LogUtils {
         }
         Set<String> appIds = new HashSet<>();
         try (Stream<String> stream = Files.lines(Paths.get(logPath))) {
-            stream.filter(line -> {
-                Matcher matcher = APPLICATION_REGEX.matcher(line);
-                return matcher.find();
-            }).forEach(line -> {
+            stream.forEach(line -> {
                 Matcher matcher = APPLICATION_REGEX.matcher(line);
                 if (matcher.find()) {
                     String appId = matcher.group();

Reply via email to