Hello, I have postgres as source and mysql as sink. The user authenticating with mysql does _not_ have DELETE privileges.
In some cases, flink throws error because it is trying to _delete_ records and the user does not have privilege. In most cases (of the same job), upsert is working as expected and no exception is thrown. My question is, when does flink execute DELETE statements if it is running in upsert mode? I have found https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java#L98 that might be useful, but I don't understand the logic here (I don't know Java anyway). Can someone help me understand when the delete statements will be executed? Thanks!
