Gustavo de Morais created FLINK-40112:
-----------------------------------------

             Summary: Report a changelog mode mismatch instead of a generic 
planning error
                 Key: FLINK-40112
                 URL: https://issues.apache.org/jira/browse/FLINK-40112
             Project: Flink
          Issue Type: Improvement
            Reporter: Gustavo de Morais
            Assignee: Gustavo de Morais


When changelog mode inference cannot satisfy an operator's required changelog 
and the failure is not at a sink, {{FlinkChangelogModeInferenceProgram}} throws 
a generic "Can't generate a valid execution plan for the given query" with the 
annotated plan. This does not tell the user the failure is a changelog mismatch.

Update and improve the message to state that an operator cannot produce the 
changelog its consumer requires and to point the user at the changelog modes of 
the operators in the plan.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to