akshayjain-tmdc opened a new issue, #4671:
URL: https://github.com/apache/iceberg/issues/4671
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"
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)
}
}`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
