File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -2542,10 +2542,9 @@ def spark() -> "SparkSession":
25422542 .config ("spark.sql.catalog.spark_catalog" , "org.apache.iceberg.spark.SparkSessionCatalog" )
25432543 .config ("spark.sql.catalog.spark_catalog.type" , "hive" )
25442544 .config ("spark.sql.catalog.spark_catalog.uri" , "http://localhost:9083" )
2545- .config ("spark.sql.catalog.spark_catalog.io-impl" , "org.apache.iceberg.aws.s3.S3FileIO" )
25462545 .config ("spark.sql.catalog.spark_catalog.warehouse" , "s3://warehouse/hive/" )
2547- .config ("spark.sql.catalog.spark_catalog.s3 .endpoint" , "http://localhost:9000" )
2548- .config ("spark.sql.catalog.spark_catalog.s3. path- style- access" , "true" )
2546+ .config ("spark.hadoop.fs.s3a .endpoint" , "http://localhost:9000" )
2547+ .config ("spark.hadoop.fs.s3a. path. style. access" , "true" )
25492548 .config ("spark.sql.catalogImplementation" , "hive" )
25502549 .config ("spark.sql.defaultCatalog" , "integration" )
25512550 .config ("spark.sql.execution.arrow.pyspark.enabled" , "true" )
You can’t perform that action at this time.
0 commit comments