0

3 つの ec2 ノードに cassandra spark-hadoop クラスターをインストールしました。昨日、node0 で spark thrift サーバーを起動することができ、実際にビーラインで単純な sql ステートメントを実行しました。今日、スキーマの変更後、thrift サーバーを再起動したところ、org.apache.hadoop.hive.cassandra.cql3.input.HiveCqlInputFormat で SparkException java.lang.IllegalArgumentException: ip-172-30-4-140 が発生しました。 getRecordReader(HiveCqlInputFormat.java:212)

ip-172-30-4-140 は単にそのノードのプライベート IP です

他の 2 つの cassandra ノードから同じシーケンスを実行しようとしましたが、SQL ステートメントがスタックして戻りません。

このエラーは何ですか? 誰でも知っていますか?

4

2 に答える 2

0

わかりました、私は問題を見つけました。

host パラメータのデフォルト値は、ec2 の内部 IP DNS を指しているため、例外が発生します。明示的に宣言する必要があります

sudo dse spark-sql-thriftserver start hive.server2.thrift.bind.host=your-ec2-private-ip

于 2016-05-05T01:34:26.193 に答える