We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c6358ac commit af9982aCopy full SHA for af9982a
gluten-kafka/src/main/scala/org/apache/gluten/execution/OffloadKafkaScan.scala
@@ -23,7 +23,7 @@ import org.apache.gluten.extension.columnar.validator.Validators
23
import org.apache.gluten.extension.injector.Injector
24
25
import org.apache.spark.sql.execution.SparkPlan
26
-import org.apache.spark.sql.execution.datasources.v2.{BatchScanExec, MicroBatchScanExec}
+import org.apache.spark.sql.execution.datasources.v2.MicroBatchScanExec
27
28
case class OffloadKafkaScan() extends OffloadSingleNode {
29
override def offload(plan: SparkPlan): SparkPlan = plan match {
0 commit comments