Skip to content

Commit d535332

Browse files
committed
returning log level to debug in NuEventEmitter methods
1 parent 569e5bb commit d535332

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,15 @@ public class NuEventEmitter {
3636
private static Boolean isPermittedJobType(RunEvent event) {
3737
String jobType = event.getJob().getFacets().getJobType().getJobType();
3838
if (WANTED_JOB_TYPES.stream().noneMatch(jobType::equals)) {
39-
log.info("OpenLineage event with job type {} has no lineage value and should not be emitted", jobType);
39+
log.debug("OpenLineage event with job type {} has no lineage value and should not be emitted", jobType);
4040
return false;
4141
}
4242
return true;
4343
}
4444

4545
private static Boolean isPermitedEventType(RunEvent event) {
4646
if (RUNNING.equals(event.getEventType())) {
47-
log.info("OpenLineage event is {} and should not be emitted", RUNNING);
47+
log.debug("OpenLineage event is {} and should not be emitted", RUNNING);
4848
return false;
4949
}
5050
return true;
@@ -53,11 +53,11 @@ private static Boolean isPermitedEventType(RunEvent event) {
5353
private static Boolean isPermittedJobName(RunEvent event) {
5454
String jobName = event.getJob().getName();
5555
if (isNull(jobName)) {
56-
log.info("OpenLineage event has no job name and should not be emitted");
56+
log.debug("OpenLineage event has no job name and should not be emitted");
5757
return false;
5858
}
5959
if (WANTED_EVENT_NAME_SUBSTRINGS.stream().noneMatch(jobName::contains)) {
60-
log.info("OpenLineage event job name {} has no permitted substring and should not be emitted", jobName);
60+
log.debug("OpenLineage event job name {} has no permitted substring and should not be emitted", jobName);
6161
return false;
6262
}
6363
return true;
@@ -84,7 +84,7 @@ private static void discardColumnLineageFacet(RunEvent event) {
8484
.collect(Collectors.toList())
8585
.forEach(dataset -> {
8686
try {
87-
log.info("Discarding column lineage facet for dataset {} {} {}",
87+
log.debug("Discarding column lineage facet for dataset {} {} {}",
8888
dataset.getClass().getSimpleName(), dataset.getNamespace(), dataset.getName());
8989
columnLineageFacetField.set(dataset.getFacets(), null);
9090
} catch (IllegalAccessException e) {

0 commit comments

Comments
 (0)