gustavodemorais commented on code in PR #26687:
URL: https://github.com/apache/flink/pull/26687#discussion_r2154527513
##########
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinTestPrograms.java:
##########
@@ -439,10 +438,14 @@ public class MultiJoinTestPrograms {
"location STRING")
.addOption("changelog-mode", "I,UA,UB,D")
.consumedBeforeRestore(
- "+I[1, Gus, order0, payment1,
London]",
- "+I[1, Gus, order1, payment1,
London]",
- "+I[3, Nomad, order3, payment3,
New York]")
+ "+I[1, Gus, order0, payment1,
London]"
+ // "+I[1, Gus, order1, payment1,
London]" // TODO
+ // Gustavo Why is this being
consumed after the restore?
Review Comment:
I've removed it, since you're squashing the PR then it won't land in the
codebase nor in the history
--
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]
