Skip to content

Commit ad51d1b

Browse files
committed
Add comment about spark.addArtifact()
1 parent 0ccac81 commit ad51d1b

2 files changed

Lines changed: 7 additions & 5 deletions

File tree

tests/templates/kuttl/spark-connect-kerberos/10_spark-connect.yaml.j2

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ spec:
151151
# protocol (not the rename-based FileOutputCommitter), so writes to S3
152152
# work without the staging/_temporary issues of plain parquet tables.
153153
# The catalog inherits the kerberos metastore config from spark.hadoop.*
154-
# above. See https://github.com/stackabletech/spark-k8s-operator/issues/702
154+
# above. See https://issues.apache.org/jira/browse/SPARK-46032
155155
spark.sql.extensions: org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions
156156
spark.sql.catalog.iceberg: org.apache.iceberg.spark.SparkCatalog
157157
spark.sql.catalog.iceberg.type: hive

tests/templates/kuttl/spark-connect-kerberos/20-run-connect-client.yaml.j2

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -63,10 +63,12 @@ data:
6363
# metastore query (driver-side). We deliberately avoid result.collect() /
6464
# count() over the Iceberg table: a *distributed* scan ships the Iceberg
6565
# RDD closure to the executors, where it currently fails to deserialize on
66-
# Spark Connect ("cannot assign SerializedLambda ... Function3"). That is a
67-
# Spark Connect classloader limitation independent of where the Iceberg jar
68-
# is placed, and is separate from the metastore/Kerberos integration this
69-
# test validates. See https://github.com/stackabletech/spark-k8s-operator/issues/702
66+
# Spark Connect ("cannot assign SerializedLambda ... Function3"). This is an
67+
# upstream Spark Connect classloader limitation (see SPARK-46032 /
68+
# SPARK-51537) independent of how the Iceberg jar is provisioned - it
69+
# reproduces with --packages, with the jar on the system classpath, with
70+
# spark.addArtifact(), and with --packages + addArtifact together - and is
71+
# separate from the metastore/Kerberos integration this test validates.
7072
ice_tables = [row.tableName for row in spark.sql("SHOW TABLES IN iceberg.lakehouse").collect()]
7173
print("Tables in 'iceberg.lakehouse':", ice_tables)
7274
assert "greetings" in ice_tables, f"Iceberg table not registered in the HMS: {ice_tables}"

0 commit comments

Comments
 (0)