Я соединяюсь с Hive с помощью Spark 2.x и выполняю следующий запрос Spark:
spark.sql("""DROP TABLE IF EXISTS db_name.table_name""")
spark.sql("""Create TABLE IF NOT EXISTS db_name.table_name""")
, если таблица не существует, то первый запрос дает исключение из таблицы «Не существует».Если таблица существует, и я вначале выполняю второй запрос, то он выдает исключение «Таблица уже существует».
Что означает условие, что ЕСЛИ СУЩЕСТВУЕТ, а ЕСЛИ НЕ СУЩЕСТВУЕТ, не работает.
Я прочиталэто где-то, что может быть проблема зависимости ядра данных.Ниже приведены зависимости, которые я использую для ядра данных:
<dependency>
<groupId>org.datanucleus</groupId>
<artifactId>datanucleus-rdbms</artifactId>
<version>3.2.9</version>
</dependency>
<dependency>
<groupId>org.datanucleus</groupId>
<artifactId>datanucleus-core</artifactId>
<version>3.2.10</version>
</dependency>
<dependency>
<groupId>org.datanucleus</groupId>
<artifactId>datanucleus-api-jdo</artifactId>
<version>3.2.6</version>
</dependency>