bezdomniy commented on issue #14526:
URL: https://github.com/apache/iceberg/issues/14526#issuecomment-3511095805
It would seem to be that way - but the same source config works when its
FlinkSink writing to the table, but not when it is DynamicIcebergSink. I'm
trying to find what is different.
The other thing is that
StreamingStartingStrategy.TABLE_SCAN_THEN_INCREMENTAL will read all existing
rows, but not any incremental rows.
My source is like this:
```java
var source =
IcebergSource.forOutputType(avroRecordConverter).tableLoader(tableLoader)
.assignerFactory(new SimpleSplitAssignerFactory()).streaming(true)
.streamingStartingStrategy(
StreamingStartingStrategy.INCREMENTAL_FROM_LATEST_SNAPSHOT)
.monitorInterval(Duration.ofSeconds(10)).branch("main");
```
--
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]
