rdblue commented on PR #5061: URL: https://github.com/apache/iceberg/pull/5061#issuecomment-1163836498
> In Flink SQL, data is transferred from one operator to another as a Chanlog Stream. The stream of changes from the debugger screenshot appears incorrect to me. Even if join outputs are modeled this way, there should not be a delete and an insert for ID 2. Why would an unmatched row produce anything from the join? -- 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]
