[
https://issues.apache.org/jira/browse/FLINK-41390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Theusner reassigned FLINK-41390:
-------------------------------------
Assignee: Timo Theusner
> 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
> Assignee: Timo Theusner
> Priority: Major
>
> 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)
