<init>(Path.java:175) at org.apache.spark.sql.hive.client.HiveClientImpl$$anonfun$getDatabase$1$$anonfun$apply$2.apply(HiveClientImpl.scala:343)
at org.apache.spark.sq
我有一个要每天执行的查询,该查询将按执行日期进行分区。此查询的结果应追加到同一个表中。 理想情况下,我的想法是使用类似于CREATE TABLE IF NOT EXISTS命令的方法,在分区不存在的情况下每天通过新分区将数据添加到现有表中,但是我不知道如何将其集成到查询中。 我的问题是: CREATE TABLE IF NOT EXISTS db_name.table_name external_location = 's3://my-query-results-location/', p