commenting returns for lineage events

Author: lmassaoy

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

@@ -87,7 +87,7 @@ public void start(SparkListenerSQLExecutionStart startEvent) {
     } else if (EventFilterUtils.isDisabled(olContext, startEvent)) {
       log.info(
           "OpenLineage received Spark event that is configured to be skipped: SparkListenerSQLExecutionStart");
-      return;
+      // return;
     }
 
     olContext.setActiveJobId(activeJobId);
@@ -133,7 +133,7 @@ public void end(SparkListenerSQLExecutionEnd endEvent) {
     } else if (EventFilterUtils.isDisabled(olContext, endEvent)) {
       log.info(
           "OpenLineage received Spark event that is configured to be skipped: SparkListenerSQLExecutionEnd");
-       return;
+      //  return;
     }
 
     // only one COMPLETE event is expected, verify if jobEnd was not emitted
@@ -270,7 +270,7 @@ public void start(SparkListenerJobStart jobStart) {
     } else if (EventFilterUtils.isDisabled(olContext, jobStart)) {
       log.info(
           "OpenLineage received Spark event that is configured to be skipped: SparkListenerJobStart");
-       return;
+      //  return;
     }
 
     // only one START event is expected, in case it was already sent with sqlExecutionStart, we send
@@ -316,7 +316,7 @@ public void end(SparkListenerJobEnd jobEnd) {
     } else if (EventFilterUtils.isDisabled(olContext, jobEnd)) {
       log.info(
           "OpenLineage received Spark event that is configured to be skipped: SparkListenerJobEnd");
-       return;
+      //  return;
     }
 
     // only one COMPLETE event is expected,

integration/spark/buildDependencies.sh

@@ -6,4 +6,4 @@ set -x -e
 (cd ../../client/java && ./gradlew generateCode publishToMavenLocal -x test --rerun-tasks)
 (cd ../spark-extension-interfaces && ./gradlew clean publishToMavenLocal -x test)
 (cd ../sql/iface-java && ./script/compile.sh && ./script/build.sh)
-(cd ../spark-extension-entrypoint && ./gradlew publishToMavenLocal)
+(cd ../spark-extension-entrypoint && ./gradlew publishToMavenLocal)

integration/spark/gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.9-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists