Skip to content

Commit ae916f4

Browse files
committed
Disable CometBroadcastExchange
1 parent b6b1a4b commit ae916f4

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

dev/diffs/iceberg/1.8.1.diff

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1241,10 +1241,10 @@ index 2665d7b..95647d7 100644
12411241
}
12421242

12431243
diff --git a/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBase.java b/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBase.java
1244-
index de68351..0e39a32 100644
1244+
index de68351..248f927 100644
12451245
--- a/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBase.java
12461246
+++ b/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/TestBase.java
1247-
@@ -77,6 +77,14 @@ public abstract class TestBase extends SparkTestHelperBase {
1247+
@@ -77,6 +77,15 @@ public abstract class TestBase extends SparkTestHelperBase {
12481248
.config(SQLConf.PARTITION_OVERWRITE_MODE().key(), "dynamic")
12491249
.config("spark.hadoop." + METASTOREURIS.varname, hiveConf.get(METASTOREURIS.varname))
12501250
.config("spark.sql.legacy.respectNullabilityInTextDatasetConversion", "true")
@@ -1256,6 +1256,7 @@ index de68351..0e39a32 100644
12561256
+ .config("spark.memory.offHeap.size", "10g")
12571257
+ .config("spark.comet.use.lazyMaterialization", "false")
12581258
+ .config("spark.comet.schemaEvolution.enabled", "true")
1259+
+ .config("spark.comet.exec.broadcastExchange.enabled", "false")
12591260
.enableHiveSupport()
12601261
.getOrCreate();
12611262

0 commit comments

Comments
 (0)