Timo Theusner created FLINK-41390:
-------------------------------------

             Summary: Clean up after materialized table refresh-job failures in 
CREATE and SUSPEND
                 Key: FLINK-41390
                 URL: https://issues.apache.org/jira/browse/FLINK-41390
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Planner
            Reporter: Timo Theusner


When {{CREATE MATERIALIZED TABLE}} submits a continuous refresh job but the 
catalog can't record it, the table is dropped while the job keeps running 
unrecorded. If that compensation drop fails, the original error is lost, and a 
{{SUSPEND}} whose catalog write fails after the stop loses the savepoint path. 
Cancel the unrecorded job, keep the original error and name the savepoint, for 
the SQL Gateway and every {{TableEnvironment.}}



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to