Error occurred while processing GET request while using pyspark #3325
Unanswered
lalitbyteiq
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Hi im getting the bellow error while trying to connect amoro using pyspark jupyter
here are my details
docker compose :
AMS_HOST = "amoro"
AMS_PORT = "1260"
AMS_CATALOG_NAME = "demo_catalog"
spark = SparkSession.builder
.appName("MySparkApp")
.config("spark.jars.packages", "org.apache.amoro:amoro-mixed-spark-3.3-runtime:0.7.0")
.config("spark.sql.extensions", "org.apache.amoro.spark.MixedFormatSparkExtensions")
.config("spark.sql.catalog.local_catalog", "org.apache.amoro.spark.MixedFormatSparkCatalog")
.config("spark.sql.catalog.local_catalog.url", f"thrift://{AMS_HOST}:{AMS_PORT}/{AMS_CATALOG_NAME}")
.getOrCreate()
Set the catalog
spark.sql("use local_catalog")
error
Py4JJavaError: An error occurred while calling o36.sql.
: org.apache.iceberg.exceptions.RESTException: Error occurred while processing GET request
at org.apache.iceberg.rest.HTTPClient.execute(HTTPClient.java:304)
at org.apache.iceberg.rest.HTTPClient.execute(HTTPClient.java:219)
at org.apache.iceberg.rest.HTTPClient.get(HTTPClient.java:320)
at org.apache.iceberg.rest.RESTSessionCatalog.fetchConfig(RESTSessionCatalog.java:823)
at org.apache.iceberg.rest.RESTSessionCatalog.initialize(RESTSessionCatalog.java:167)
at org.apache.iceberg.rest.RESTCatalog.initialize(RESTCatalog.java:68)
at org.apache.iceberg.CatalogUtil.loadCatalog(CatalogUtil.java:239)
at org.apache.iceberg.CatalogUtil.buildIcebergCatalog(CatalogUtil.java:284)
at org.apache.iceberg.spark.SparkCatalog.buildIcebergCatalog(SparkCatalog.java:144)
at org.apache.iceberg.spark.SparkCatalog.initialize(SparkCatalog.java:552)
at org.apache.spark.sql.connector.catalog.Catalogs$.load(Catalogs.scala:60)
at org.apache.spark.sql.connector.catalog.CatalogManager.$anonfun$catalog$1(CatalogManager.scala:53)
Beta Was this translation helpful? Give feedback.
All reactions