hililiwei commented on PR #5061: URL: https://github.com/apache/iceberg/pull/5061#issuecomment-1161214941
 In Flink SQL, data is transferred from one operator to another as a Chanlog Stream. Changelog Stream can be translated as either a table or a Stream. Iceberg should be more like a Dynamic Table. In our case above, I think it should materialize changes rather than store changes in the table as they were. > Do you mean that the new sink doesn't pass the RowKind and you only get in inserted rows? Sink will not just receive Inserted Rows. With Flink CDC, it can receive change log normally. -- 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]
