removing set of parameters from log related to rdd path

lmassaoy · lmassaoy · commit 3a682309b932 · 2025-02-21T13:08:18.000-03:00
diff --git a/integration/spark/shared/src/main/java/io/openlineage/spark/agent/util/RddPathUtils.java b/integration/spark/shared/src/main/java/io/openlineage/spark/agent/util/RddPathUtils.java
@@ -134,7 +134,7 @@ public Stream<Path> extract(ParallelCollectionRDD rdd) {
                   })
               .filter(Objects::nonNull);
         } else {
-          log.warn("Cannot extract path from ParallelCollectionRDD {}", data);
+          log.warn("Cannot extract path from ParallelCollectionRDD");
         }
       } catch (IllegalAccessException | IllegalArgumentException e) {
         log.warn("Cannot read data field from ParallelCollectionRDD {}", rdd);

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ public Stream<Path> extract(ParallelCollectionRDD rdd) {`
`134`	`134`	`})`
`135`	`135`	`.filter(Objects::nonNull);`
`136`	`136`	`} else {`
`137`		`- log.warn("Cannot extract path from ParallelCollectionRDD {}", data);`
	`137`	`+ log.warn("Cannot extract path from ParallelCollectionRDD");`
`138`	`138`	`}`
`139`	`139`	`} catch (IllegalAccessException \| IllegalArgumentException e) {`
`140`	`140`	`log.warn("Cannot read data field from ParallelCollectionRDD {}", rdd);`