diff --git a/client/java/generator/src/main/java/io/openlineage/client/Generator.java b/client/java/generator/src/main/java/io/openlineage/client/Generator.java
index 9c26cc773ba0e..929dbad0caaa6 100644
--- a/client/java/generator/src/main/java/io/openlineage/client/Generator.java
+++ b/client/java/generator/src/main/java/io/openlineage/client/Generator.java
@@ -53,7 +53,7 @@ public static void main(String[] args) throws JsonParseException, JsonMappingExc
       URL url = new URL(baseURL);
 
       if (url.getProtocol().equals("file")) {
-        File file = new File(url.toURI());
+        File file = new File(url.getFile());
         if (file.isDirectory()) {
           addURLs(urls, file);
         } else {
diff --git a/integration/spark/src/main/common/java/io/openlineage/spark/agent/lifecycle/SparkSQLExecutionContext.java b/integration/spark/src/main/common/java/io/openlineage/spark/agent/lifecycle/SparkSQLExecutionContext.java
index 2f4b7532b419c..4130db8a93bf3 100644
--- a/integration/spark/src/main/common/java/io/openlineage/spark/agent/lifecycle/SparkSQLExecutionContext.java
+++ b/integration/spark/src/main/common/java/io/openlineage/spark/agent/lifecycle/SparkSQLExecutionContext.java
@@ -201,7 +201,7 @@ public void end(SparkListenerJobEnd jobEnd) {
             .job(buildJob(queryExecution))
             .build();
 
-    log.debug("Posting event for start {}: {}", jobEnd, event);
+    log.debug("Posting event for end {}: {}", jobEnd, event);
     sparkContext.emit(event);
   }