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();