Я использую Spark JDBC для подключения к таблице MySQL. Когда он читает таблицу, схема содержит все столбцы как обнуляемые. В то время как первичные ключи должны иметь значение NULL. Я использую драйвер версии MySQL 5.1.8.
Я использую
session.read.jdbc(s"${destOptions.getProperty("connection_string")}?useCompression=true&useSSL=false&autoReconnect=true", config.srcTable,andLogicPredicate, destOptions).selectExpr(primaryKeyArray: _*)