github-actions[bot] commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-2365374227
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
pvary commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-1757039591
@Ge: Sorry, but I do not understand your question.
In upsert mode something like this should be the answer:
```
Flink SQL> SELECT * FROM word_count LIMIT 10;
++--
Ge commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-1755752149
`SELECT word, COUNT(*) FROM word_table GROUP BY word;` is the retract stream:
```
Flink SQL> SELECT word, COUNT(*) FROM word_table GROUP BY word;
++
pvary commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-1752968284
Upsert (append only) stream - by definition -, only contains Inserts in case
of an update. So I would say that the example above is expected.
If you need the `-U` records, you ne
Ge commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-1751842819
Turning off the upsert mode also leads to incorrect results:
```
Flink SQL> SELECT * FROM word_count LIMIT 10;
+++--
pvary commented on issue #8719:
URL: https://github.com/apache/iceberg/issues/8719#issuecomment-1748445456
Have you tried turning off the upsert mode?
https://iceberg.apache.org/docs/latest/flink-configuration/#write-options
```
upsert-enabled | Table write.upsert.enabled | Overrides
Ge opened a new issue, #8719:
URL: https://github.com/apache/iceberg/issues/8719
### Feature Request / Improvement
Consider the following continuous insertion into a keyless table:
```
SET 'execution.checkpointing.interval' = '10 s';
SET 'sql-client.execution.result-mo
