changing nu event emitter log

nubank · Oct 22, 2024 · 975f831 · 975f831
1 parent 73b104c
commit 975f831
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/integration/spark/app/src/main/java/io/openlineage/spark/agent/NuEventEmitter.java b/integration/spark/app/src/main/java/io/openlineage/spark/agent/NuEventEmitter.java
@@ -77,7 +77,7 @@ private static void discardColumnLineageFacet(RunEvent event) {
                     .forEach(dataset -> {
                         try {
                             log.debug("Discarding column lineage facet for dataset {} {} {}",
-                                    dataset.getClass().getName(), dataset.getNamespace(), dataset.getName());
+                                    dataset.getClass().getSimpleName(), dataset.getNamespace(), dataset.getName());
                             columnLineageFacetField.set(dataset.getFacets(), null);
                         } catch (IllegalAccessException e) {
                             log.error("Failed to discard column lineage facet", e);