Can you try with the below code snippet
WITH exploded_json AS (
SELECT explode(from_json(
'[{"key":"abc","value":{"string_value":"abc123"}},{"key":"def","value":{"int_value":123}},{"key":"ghi","value":{"string_value":"ghi456"}}]',
'array<s...
Can you try the below code snippet? And share the stacktrace if the issue persists.
snowflake_table = spark.read \
.format("snowflake") \
.option("host", "******.east-us-2.azure.snowflakecomputing.com") \
.option("user", "******") \
.option(...
To time travel to a previous version, you need data and metadata. Metadata(json files in the delta log directory) by default comes with a retention of 30 days. You will need to increase the retention to be able to time travel to older versions. (del...
Caused by: java.sql.SQLNonTransientConnectionException: Could not connect to md1n4trqmokgnhr.csnrqwqko4ho.ap-southeast-1.rds.amazonaws.com:3306 : Connection reset
at org.mariadb.jdbc.internal.util.exceptions.ExceptionMapper.get(ExceptionMapper.java:...
@Markus Freischlad​ Looks like the spark driver was stuck. It will be good to capture the thread dump of the Spark driver to understand what operation is stuck
