You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Description:
I'm encountering an issue when running UPDATE or DELETE queries after upgrading to Iceberg 1.6.0. These queries were working fine before Iceberg 1.6.0, but now I get the following error in PySpark:
pyspark.errors.exceptions.captured.IllegalArgumentException: Cannot add fieldId 1 as an identifier field: field does not exist
This error occurs whenever I try to execute any update or delete query in my Iceberg table.
The table was originally created using FlinkSQL. Here is the script I used to create the table (use flink for the purpose of real-time upserting):
CREATE CATALOG glue_catalog WITH (
'type'='iceberg',
'catalog-impl'='org.apache.iceberg.aws.glue.GlueCatalog',
'warehouse'='s3://my-bucket'
);
CREATE DATABASE IF NOT EXISTS glue_catalog.my_db;
CREATE TABLE IF NOT EXISTS glue_catalog.my_db.my_table(
id_b BIGINT,
...,
id_a STRING,
id_c DATE,
PRIMARY KEY (id_b,id_a,id_c) NOT ENFORCED
) PARTITIONED BY (
id_c
) WITH (
'format-version'='2',
'write.metadata.delete-after-commit.enabled'='true',
'write.upsert.enabled'='true',
'write.delete.mode'='merge-on-read',
'write.merge.mode'='merge-on-read',
'write.update.mode'='merge-on-read'
);
Query Execution: The issue occurs when running an UPDATE or DELETE query in PySpark after the upgrade to Iceberg 1.6.0.
Expected Behavior:
The queries should execute successfully as they did before Iceberg 1.6.0.
Apache Iceberg version
1.6.0
Query engine
Spark
Please describe the bug 🐞
Description:
I'm encountering an issue when running UPDATE or DELETE queries after upgrading to Iceberg 1.6.0. These queries were working fine before Iceberg 1.6.0, but now I get the following error in PySpark:
This error occurs whenever I try to execute any update or delete query in my Iceberg table.
The table was originally created using FlinkSQL. Here is the script I used to create the table (use flink for the purpose of real-time upserting):
Query Execution: The issue occurs when running an UPDATE or DELETE query in PySpark after the upgrade to Iceberg 1.6.0.
Expected Behavior:
The queries should execute successfully as they did before Iceberg 1.6.0.
Environment Details:
previous iceberg-spark-runtime package VERSION: iceberg-spark-runtime-3.4_2.12:1.5.2 (Works fine)
current iceberg-spark-runtime package VERSION: iceberg-spark-runtime-3.4_2.12:1.6.0 (Issue)
iceberg-flink-runtime package VERSION: iceberg-flink-runtime-1.16-1.4.1.jar
Willingness to contribute
The text was updated successfully, but these errors were encountered: