0

我在 3 个 ec2 节点上安装了 cassandra spark-hadoop 集群。昨天可以在node0上启动spark thrift server，并在beeline中实际执行了一个简单的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

我尝试从其他两个 cassandra 节点运行相同的序列，对于那些，sql 语句被卡住并且永远不会返回。

这是什么错误？有谁知道？

4

2 回答 2

0

好的，我发现了问题。

host参数的默认值指向ec2的内部ip DNS，导致异常。需要显式声明

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

于 2016-05-05T01:34:26.193 回答
0

这不是 ip 。您必须输入私有 ip 或公共 dns。

于 2016-04-27T06:01:35.953 回答