Skip to content

Commit 73b104c

Browse files
committed
changing NuEventEmitter logs level from into to debug
1 parent bd86aab commit 73b104c

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

integration/spark/app/src/main/java/io/openlineage/spark/agent/NuEventEmitter.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,15 +28,15 @@ public class NuEventEmitter {
2828
private static Boolean isPermittedJobType(RunEvent event) {
2929
String jobType = event.getJob().getFacets().getJobType().getJobType();
3030
if (WANTED_JOB_TYPES.stream().noneMatch(jobType::equals)) {
31-
log.info("OpenLineage event with job type {} has no lineage value and should not be emitted", jobType);
31+
log.debug("OpenLineage event with job type {} has no lineage value and should not be emitted", jobType);
3232
return false;
3333
}
3434
return true;
3535
}
3636

3737
private static Boolean isPermitedEventType(RunEvent event) {
3838
if (RUNNING.equals(event.getEventType())) {
39-
log.info("OpenLineage event is {} and should not be emitted", RUNNING);
39+
log.debug("OpenLineage event is {} and should not be emitted", RUNNING);
4040
return false;
4141
}
4242
return true;
@@ -45,11 +45,11 @@ private static Boolean isPermitedEventType(RunEvent event) {
4545
private static Boolean isPermittedJobName(RunEvent event) {
4646
String jobName = event.getJob().getName();
4747
if (isNull(jobName)) {
48-
log.info("OpenLineage event has no job name and should not be emitted");
48+
log.debug("OpenLineage event has no job name and should not be emitted");
4949
return false;
5050
}
5151
if (WANTED_EVENT_NAME_SUBSTRINGS.stream().noneMatch(jobName::contains)) {
52-
log.info("OpenLineage event job name has no permitted substring and should not be emitted");
52+
log.debug("OpenLineage event job name has no permitted substring and should not be emitted");
5353
return false;
5454
}
5555
return true;
@@ -76,11 +76,11 @@ private static void discardColumnLineageFacet(RunEvent event) {
7676
.collect(Collectors.toList())
7777
.forEach(dataset -> {
7878
try {
79-
log.info("Discarding column lineage facet for dataset {} {} {}",
79+
log.debug("Discarding column lineage facet for dataset {} {} {}",
8080
dataset.getClass().getName(), dataset.getNamespace(), dataset.getName());
8181
columnLineageFacetField.set(dataset.getFacets(), null);
8282
} catch (IllegalAccessException e) {
83-
log.warn("Failed to discard column lineage facet", e);
83+
log.error("Failed to discard column lineage facet", e);
8484
}
8585
});
8686
} catch (NoSuchFieldException e) {

0 commit comments

Comments
 (0)