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
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
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