@@ -5,7 +5,7 @@ spark_profile:
55 type : spark
66 method : thrift
77 host : localhost
8- port : 10000 # Default Spark Thrift port, adjust if needed
8+ port : 10001 # Default Spark Thrift port, adjust if needed
99 user : # leave blank if not using auth
1010 password : # leave blank if not using auth
1111 database : default # or your specific database
@@ -19,11 +19,11 @@ spark_profile:
1919
2020 # Additional Spark configurations for Iceberg
2121 connect_args :
22- spark.jars.packages : org.apache.iceberg:iceberg-spark-runtime-3.5_2.12:1.8.1,org.projectnessie.nessie-integrations:nessie-spark-extensions-3.5_2.12:0.102.5
22+ spark.jars.packages : org.apache.iceberg:iceberg-spark-runtime-3.5_2.12:1.8.1,org.projectnessie.nessie-integrations:nessie-spark-extensions-3.5_2.12:0.102.5,org.apache.hadoop:hadoop-aws:3.3.4
2323 spark.sql.extensions : org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions,org.projectnessie.spark.extensions.NessieSparkSessionExtensions
2424 spark.sql.catalog.iceberg : org.apache.iceberg.spark.SparkCatalog
2525 spark.sql.catalog.iceberg.type : nessie
26- spark.sql.catalog.iceberg.warehouse : s3a://warehouse
26+ spark.sql.catalog.iceberg.warehouse : s3a://warehouse
2727 spark.sql.catalog.iceberg.uri : http://nessie:19120/api/v1
2828 spark.sql.catalog.iceberg.ref : main
2929 spark.sql.catalog.iceberg.io-impl : org.apache.iceberg.aws.s3.S3FileIO
@@ -32,3 +32,12 @@ spark_profile:
3232 spark.sql.catalog.iceberg.s3.impl : org.apache.hadoop.fs.s3a.S3AFileSystem
3333 spark.sql.catalog.iceberg.s3.access.key : minioadmin
3434 spark.sql.catalog.iceberg.s3.secret.key : minioadmin
35+ # Add these new configurations
36+ spark.sql.defaultCatalog : iceberg
37+ spark.sql.catalog.spark_catalog : org.apache.iceberg.spark.SparkSessionCatalog
38+ spark.sql.catalog.spark_catalog.type : nessie
39+ spark.hadoop.fs.s3a.access.key : minioadmin
40+ spark.hadoop.fs.s3a.secret.key : minioadmin
41+ spark.hadoop.fs.s3a.endpoint : http://minio:9000
42+ spark.hadoop.fs.s3a.path.style.access : true
43+ spark.hadoop.fs.s3a.impl : org.apache.hadoop.fs.s3a.S3AFileSystem
0 commit comments