Skip to content

Commit 975ca10

Browse files
authored
changing log level from error to warning on ContextFactory.createSparkSQLExecutionContext (#17)
1 parent 79c0d1f commit 975ca10

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

integration/spark/app/src/main/java/io/openlineage/spark/agent/lifecycle/ContextFactory.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,9 @@ public ExecutionContext createRddExecutionContext(int jobId) {
8585
public Optional<ExecutionContext> createSparkSQLExecutionContext(long executionId) {
8686
QueryExecution queryExecution = SQLExecution.getQueryExecution(executionId);
8787
if (queryExecution == null) {
88-
log.error("Query execution is null: can't emit event for executionId {}", executionId);
88+
// We changed this log level from error to warn so it doesn't mix with other MR and Itapu error logs.
89+
// We should investigate if we can act upon this issue. If not, we should change this to debug
90+
log.warn("Query execution is null: can't emit event for executionId {}", executionId);
8991
return Optional.empty();
9092
}
9193
SparkSession sparkSession = queryExecution.sparkSession();

0 commit comments

Comments
 (0)