pvary commented on issue #10453: URL: https://github.com/apache/iceberg/issues/10453#issuecomment-2151626475
@dll02: I don't understand yet your issue. Could you please elaborate? I see, that your log contains one record, which could be correct, or wrong depending on your use-case: ``` +I[dao, 1717576320, 2024-06-05T08:32, 0.730100000000000, 2024-06-05] ``` Also, please remember that Flink Iceberg Source currently only able to stream appends to the table. See: https://iceberg.apache.org/docs/nightly/flink-queries/#streaming-read_1 > This example will start the streaming read from the latest table snapshot (inclusive). Every 60s, it polls Iceberg table to discover new append-only snapshots. CDC read is not supported yet. I hope this helps. Thanks, Peter -- 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: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
