zhushanwei

这是偶发性异常

I used the upsert mode

> The reason is Iceberg find some delete files associated with the data file that you want to rewrite. Can you show me your case? //writer data Configuration conf =...

> Is this problem solved? i met the same error create table: 'write.distribution-mode'='hash', 'commit.manifest.min-count-to-merge'='2', 'format-version'='2', 'write.upsert.enable'='true', 'write.metadata.metrics.default'='full', 'write.metadata.delete-after-commit.enabled'='true', 'write.metadata.previous-versions-max'='1' writer data: FlinkSink.forRowData(input) .writeParallelism(parallelism) .tableLoader(tableLoader) .overwrite(false) .append(); I used these configurations,The...