fink+iceberg ， как обновить данные в айсберге
2021-07-13T11: 28: 31.187430109+ 08: 00 java.lang.UnsupportedOperationException: обнаружена операция перезаписи, не может поддерживать добавочные данные в моментальных снимках (6836035541320694960, 2925937061867801870)
2021-07-13T11: 28: 31.187439398+ 08:00 в org.apache.iceberg.IncrementalDataTableScan.snapshotsWithin(IncrementalDataTableScan.java:123) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187445899+ 08:00 в org.apache.iceberg.IncrementalDataTableScan.planFiles(IncrementalDataTableScan.java:73) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187454652+ 08:00 в org.apache.iceberg.BaseTableScan.planTasks(BaseTableScan.java:241) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187460151+ 08:00 в org.apache.iceberg.DataTableScan.planTasks(DataTableScan.java:28) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187481059+ 08:00 в org.apache.iceberg.flink.source.FlinkSplitGenerator.tasks(FlinkSplitGenerator.java:86) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187486890+ 08:00 в org.apache.iceberg.flink.source.FlinkSplitGenerator.createInputSplits(FlinkSplitGenerator.java:38) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187493214+ 08:00 в org.apache.iceberg.flink.source.StreamingMonitorFunction.monitorAndForwardSplits(StreamingMonitorFunction.java:143) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187497911+ 08:00 в org.apache.iceberg.flink.source.StreamingMonitorFunction.run(StreamingMonitorFunction.java:121) ~[iceberg-flink-runtime-a6a88e6.jar:?]
2021-07-13T11: 28: 31.187502585+ 08:00 в org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) ~[flink-dist_2.11-1.12.4.jar:1.12.4]
2021-07-13T11: 28: 31.187507397+ 08:00 в org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66) ~[flink-dist_2.11-1.12.4.jar:1.12.4]
2021-07-13T11: 28: 31.187512294+ 08:00 в org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:263) ~[flink-dist_2.11-1.12.4.jar:1.12.4]
2021-07-13T11: 28: 31.187545900+ 08: 00 2021-07-13 03: 28: 31,187 INFO org.apache.flink.runtime.taskmanager.Task [] - Освобождение ресурсов задачи для Source: Iceberg table