changed url.getFile instead of url.toURI to fix build on windows (apa…

…che#429) * changed url.getFile instead of url.toURI to fix build on windows Signed-off-by: Arnaud Nauwynck <[email protected]> * fix debug log end != start Signed-off-by: Arnaud Nauwynck <[email protected]> Co-authored-by: Arnaud Nauwynck <[email protected]>
mobuchowski · Dec 8, 2021 · 7aa920f · 7aa920f
1 parent 41dfc82
commit 7aa920f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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
@@ -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/...k/src/main/common/java/io/openlineage/spark/agent/lifecycle/SparkSQLExecutionContext.java b/...k/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);
   }