У меня есть мои таблицы, хранящиеся в MySQL с идентификатором в качестве первичного ключа. Я хочу написать, используя Spark для Mysql, где он игнорирует строки в фрейме данных, который уже существует в Mysql (на основе первичного ключа) и только ...

Я использую Spark JDBC DataFramReader для запроса к Postgres DB, запрос выполняется через PGBouncer, работающий в Transaction Pooling. Со второго выполненного запроса я получаю следующую ошибку: org ....