0

ハイブコンテキストを作成し、そこからハイブクエリを実行するScalaプログラムがあります。ハイブ クエリは、複数テーブルの挿入クエリです。クエリは正常に実行されるが、出力が生成されていないという問題に直面しています。興味深いことに、複数テーブルの inert クエリで 1 つのテーブルに挿入すると、クエリは正常に実行されます。つまり、out データを確認できます。例えば:

val hiveContext = = new org.apache.spark.sql.hive.HiveContext(sc)

データを生成していないクエリ:

hiveContext.sql("FROM source_table INSERT INTO destiantion_table_1 PARTITION (...)
INSERT INTO destination_table_2 PARTITION (...)
INSERT INTO destination_table_3 PARTITION (...)")

正常に動作しているクエリ:

hiveContext.sql("FROM source_table INSERT INTO destiantion_table_1 PARTITION (...)

エグゼキューターのログを調べたところ、実行されなかったクエリについてエラーは報告されていませんでした。

YARN で Spark 1.5 を実行しています

上記について追加情報が必要な場合はお知らせください。

4

0 に答える 0