Hi Soheil,
I think the root cause is that in the cancellation, the task was stuck in
*org.postgresql.jdbc.PgStatement.killTimerTask(PgStatement.java:999)*
The taskmanager process exit is expected in this case to enforce a failure
and recovery.
To be specific, when a task on the TM is to be canc
Hi,
I developed a single Flink job that read a huge amount of files and after
some simple preprocessing, sink them into the database. I use the built-in
JDBCOutputFormat for inserting records into the database. The problem is
when I cancel the job using either the WebUI or the command line, the jo
