Jingsong Lee created FLINK-13253:
------------------------------------
Summary: Deadlock may occur in JDBCUpsertOutputFormat
Key: FLINK-13253
URL: https://issues.apache.org/jira/browse/FLINK-13253
Project: Flink
Issue Type: Bug
Components: Connectors / JDBC
Reporter: Jingsong Lee
Assignee: Jingsong Lee
In close, it await the flush scheduler terminal, but it hold the lock of
JDBCUpsertOutputFormat instance, maybe the async thread is waiting for this
lock in the flush method, so there might be a deadlock here.
First, it should not await scheduler terminal, because it has flushed all data
to jdbc, what we should do is let async thread quit.
Second, we should add lock outside the closed check in the flusher, in this
way, we can ensure async thread secure exiting.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
