Skip to content

Commit c4030e2

Browse files
committed
update relocated streaming imports and override slf4j 1.7.6 pinning
Signed-off-by: Sotaro Hikita <bering1814@gmail.com>
1 parent 3ba084a commit c4030e2

5 files changed

Lines changed: 13 additions & 4 deletions

File tree

spark/sql-40/build.gradle

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,15 @@ sparkVariants {
2626
}
2727
}
2828

29+
// Override BuildPlugin's slf4j 1.7.6 pinning: Spark 4.1+ requires slf4j 2.x
30+
project.configurations.all { Configuration conf ->
31+
conf.resolutionStrategy.eachDependency { details ->
32+
if (details.requested.group == 'org.slf4j' && details.requested.name == 'slf4j-api') {
33+
details.useVersion '2.0.16'
34+
}
35+
}
36+
}
37+
2938
// Configure main compile task
3039
project.getTasks().getByName(scalaCompileTaskName) { ScalaCompile compileScala ->
3140
configure(compileScala.scalaCompileOptions.forkOptions) {

spark/sql-40/src/main/scala/org/opensearch/spark/sql/streaming/NullMetadataLog.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
package org.opensearch.spark.sql.streaming
3131

32-
import org.apache.spark.sql.execution.streaming.MetadataLog
32+
import org.apache.spark.sql.execution.streaming.checkpointing.MetadataLog
3333

3434
/**
3535
* A null object style metadata log that discards incoming data, and otherwise

spark/sql-40/src/main/scala/org/opensearch/spark/sql/streaming/OpenSearchCommitProtocol.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ package org.opensearch.spark.sql.streaming
3131

3232
import org.apache.commons.logging.Log
3333
import org.apache.commons.logging.LogFactory
34-
import org.apache.spark.sql.execution.streaming.MetadataLog
34+
import org.apache.spark.sql.execution.streaming.checkpointing.MetadataLog
3535
import org.opensearch.hadoop.util.Assert
3636

3737
/**

spark/sql-40/src/main/scala/org/opensearch/spark/sql/streaming/OpenSearchSinkMetadataLog.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
package org.opensearch.spark.sql.streaming
3131

3232
import org.apache.spark.sql.SparkSession
33-
import org.apache.spark.sql.execution.streaming.CompactibleFileStreamLog
33+
import org.apache.spark.sql.execution.streaming.runtime.CompactibleFileStreamLog
3434
import org.opensearch.hadoop.cfg.Settings
3535

3636
/**

spark/sql-40/src/main/scala/org/opensearch/spark/sql/streaming/OpenSearchSparkSqlStreamingSink.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ import org.apache.spark.sql.DataFrame
3838
import org.apache.spark.sql.SparkSession
3939
import org.apache.spark.sql.catalyst.InternalRow
4040
import org.apache.spark.sql.execution.SQLExecution
41-
import org.apache.spark.sql.execution.streaming.MetadataLog
41+
import org.apache.spark.sql.execution.streaming.checkpointing.MetadataLog
4242
import org.apache.spark.sql.execution.streaming.Sink
4343
import org.opensearch.hadoop.cfg.Settings
4444

0 commit comments

Comments
 (0)