drop table if exists/create table if not exists不使用sparksql

i5desfxk  于 2021-06-26  发布在  Hive
关注(0)|答案(0)|浏览(505)

我正在使用spark 2.x连接hive,并运行以下spark查询:

spark.sql("""DROP TABLE IF EXISTS db_name.table_name""")
spark.sql("""Create TABLE IF NOT EXISTS db_name.table_name""")

如果表不存在,那么第一个查询将给出异常“表不存在”。如果表存在并且我在第一个位置运行第二个查询,那么它将抛出table already exists异常。
这意味着如果存在和如果不存在的条件是不工作的。
我在某个地方读到,可能存在数据依赖性问题。下面是我用于data nucleus的依赖项:

<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>

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题