-
Notifications
You must be signed in to change notification settings - Fork 3k
Closed
Description
I am not able to resolve this issue as of now.
Spark Version: 3.2.1
Iceberg Version: 0.13.1
I am using "org.apache.iceberg" %% "iceberg-spark3-runtime" % "0.13.1" dependency
Exact Code:
object Test {
val spark: SparkSession = SparkSession.builder()
.config("spark.driver.bindAddress", "127.0.0.1")
.config("spark.sql.extensions", "org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions")
.master("local").getOrCreate()
def main(args: Array[String]): Unit = {
testUnit()
}
def testUnit(): Unit = {
spark.read.format("iceberg").load("abc").createTempView("abc")
spark.read.format("iceberg").load("xyz").createTempView("xyz")
val query = "" +
"MERGE INTO abc AS target " +
"USING xyz AS source ON target.id = source.id " +
"WHEN " +
"MATCHED THEN UPDATE SET target.Data = source.Data " +
"WHEN " +
"NOT MATCHED THEN INSERT (target.Data) VALUES (\'New Value\')"
spark.sql(query).show(false)
}
}
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels