File tree Expand file tree Collapse file tree 2 files changed +14
-2
lines changed
backends-velox/src/test/scala/org/apache/gluten/execution
gluten-paimon/src-paimon/main/scala/org/apache/gluten/execution Expand file tree Collapse file tree 2 files changed +14
-2
lines changed Original file line number Diff line number Diff line change @@ -197,6 +197,20 @@ class VeloxScanSuite extends VeloxWholeStageTransformerSuite {
197197 }
198198 }
199199
200+ test(" remove pushed down filter in filter node" ) {
201+ createTPCHNotNullTables()
202+ val query = " select l_partkey from lineitem where l_partkey = 1"
203+ runQueryAndCompare(query) {
204+ df =>
205+ {
206+ val executedPlan = getExecutedPlan(df)
207+ val filter = executedPlan.collect { case f : FilterExecTransformerBase => f }
208+ assert(filter.size == 1 )
209+ assert(filter.head.cond == null )
210+ }
211+ }
212+ }
213+
200214 test(" test binary as string" ) {
201215 withTempDir {
202216 dir =>
Original file line number Diff line number Diff line change @@ -74,8 +74,6 @@ case class PaimonScanTransformer(
7474 throw new GlutenNotSupportException (" Only support PaimonScan." )
7575 }
7676
77- override def filterExprs (): Seq [Expression ] = pushdownFilters
78-
7977 override def getPartitionSchema : StructType = scan match {
8078 case paimonScan : PaimonScan =>
8179 val partitionKeys = paimonScan.table.partitionKeys()
You can’t perform that action at this time.
0 commit comments