twalthr commented on code in PR #26687:
URL: https://github.com/apache/flink/pull/26687#discussion_r2154509365
##########
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:
This should not end up in the Flink code base. Could you figure it out?
--
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]
