ハイブコンテキストでパーティションテーブルにデータをロードするsqlを実行する際に問題が発生しましたが、私はdynamic partition = true
を設定しましたが、依然として問題が発生しています。spark 1.6ハイブコンテキストsetConf問題
SQL: insert overwrite table target_table PARTITION (column1,column2) select * , deletion_flag ,'2018-12-23' as date_feed from source_table
ハイブsetconf: -
hiveContext.setConf("hive.exec.dynamic.partition","true")
hiveContext.setConf("hive.exec.max.dynamic.partitions","2048")
hiveContext.setConf("hive.exec.dynamic.partition.mode", "nonstrict")
エラー:
org.apache.hadoop.hive.ql.metadata.Hive.loadDynamicPartitions(org.apache.hadoop.fs.Path, java.lang.String, java.util.Map, boolean, int, boolean, boolean, boolean
Mavenの依存関係: -
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.10</artifactId>
<version>1.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-sql_2.10</artifactId>
<version>1.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-hive_2.10</artifactId>
<version>1.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-exec</artifactId>
<version>1.1.0</version>
</dependency>
おかげ
エラーメッセージ、原因、およびスタックトレースの一部を投稿してください。 –
これはhttps://stackoverflow.com/q/46124389/1305344またはhttps://stackoverflow.com/q/40637607/1305344の複製に見えますが、残念なことに受け入れられた回答はありません。 –
スタックトレースエラーについては、このリンクをチェックしてください。http://community.cloudera.com/t5/Advanced-Analytics-Apache-Spark/Hive-loadDynamicPartitions-Issue/mp/63034#M3128 –