-
Notifications
You must be signed in to change notification settings - Fork 246
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
- Take from GitHub CI of fix: [iceberg] Switch to OSS Spark and run Iceberg Spark tests in parallel #1987
TestFilterPushDown > testFilterPushdownWithBucketTransform() > catalogName = testhadoop, implementation = org.apache.iceberg.spark.SparkCatalog, config = {type=hadoop, cache-enabled=false}, planningMode = testhadoop FAILED
java.lang.AssertionError: [Post scan filter should match]
Expecting actual:
"*(1) ColumnarToRow
+- AQEShuffleRead local
+- ShuffleQueryStage 0
+- CometColumnarExchange rangepartitioning(id ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=469743]
+- CometFilter [id, salary, dep], (id = 1)
+- CometBatchScan testhadoop.default.table[id, salary, dep] testhadoop.default.table (branch=null) [filters=dep IS NOT NULL, id IS NOT NULL, dep = 'd1', id = 1, groupedBy=] RuntimeFilters: []
"
to contain:
"Filter (id = 1)"
at org.apache.iceberg.spark.sql.TestFilterPushDown.checkFilters(TestFilterPushDown.java:603)
at org.apache.iceberg.spark.sql.TestFilterPushDown.testFilterPushdownWithBucketTransform(TestFilterPushDown.java:391)
Steps to reproduce
SparkSession configs used:
.config("spark.plugins", "org.apache.spark.CometPlugin")
.config("spark.shuffle.manager", "org.apache.spark.sql.comet.execution.shuffle.CometShuffleManager")
.config("spark.comet.explainFallback.enabled", "true")
.config("spark.sql.iceberg.parquet.reader-type", "COMET")
.config("spark.memory.offHeap.enabled", "true")
.config("spark.memory.offHeap.size", "10g")
.config("spark.comet.use.lazyMaterialization", "false")
.config("spark.comet.schemaEvolution.enabled", "true")
Expected behavior
No response
Additional context
No response
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working