(flink-agents) branch release-0.1 updated: [bugfix][test]parsing log path error on windows (#308)

[xtsong]

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

xtsong pushed a commit to branch release-0.1
in repository https://gitbox.apache.org/repos/asf/flink-agents.git


The following commit(s) were added to refs/heads/release-0.1 by this push:
     new fcaabe7  [bugfix][test]parsing log path error on windows (#308)
fcaabe7 is described below

commit fcaabe7dbe6b04f00da9c5a3563e9599710088ce
Author: tsaiggo <ttsai...@gmail.com>
AuthorDate: Wed Nov 5 23:22:12 2025 +0800

    [bugfix][test]parsing log path error on windows (#308)
---
 .../apache/flink/agents/runtime/eventlog/FileEventLogger.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/runtime/src/main/java/org/apache/flink/agents/runtime/eventlog/FileEventLogger.java
 
b/runtime/src/main/java/org/apache/flink/agents/runtime/eventlog/FileEventLogger.java
index ad21a95..07be819 100644
--- 
a/runtime/src/main/java/org/apache/flink/agents/runtime/eventlog/FileEventLogger.java
+++ 
b/runtime/src/main/java/org/apache/flink/agents/runtime/eventlog/FileEventLogger.java
@@ -110,9 +110,14 @@ public class FileEventLogger implements EventLogger {
                         config.getProperties()
                                 .getOrDefault(BASE_LOG_DIR_PROPERTY_KEY, 
DEFAULT_BASE_LOG_DIR);
         String jobId = 
params.getRuntimeContext().getJobInfo().getJobId().toString();
-        String taskName = 
params.getRuntimeContext().getTaskInfo().getTaskName();
+        String taskName =
+                params.getRuntimeContext()
+                        .getTaskInfo()
+                        .getTaskName()
+                        .replaceAll("[\\\\/:*?\"<>|]", "_");
         int subTaskId = 
params.getRuntimeContext().getTaskInfo().getIndexOfThisSubtask();
-        return String.format("%s/events-%s-%s-%d.log", baseLogDir, jobId, 
taskName, subTaskId);
+        String fileName = String.format("events-%s-%s-%d.log", jobId, 
taskName, subTaskId);
+        return Paths.get(baseLogDir, fileName).toString();
     }
 
     @Override