0

我将 wso2bam-2.4.0 与外部 apache-cassandra-2.0.2 一起使用。

我使用 java 选项运行 wso2： 

-Ddisable.cassandra.server.startup=true \

当我执行任何“插入覆盖表....”时，会出现以下错误：

TID: [0] [BAM] [2013-11-22 17:21:59,590]  WARN {org.apache.hadoop.mapred.JobClient} -  Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same. {org.apache.hadoop.mapred.JobClient}
TID: [0] [BAM] [2013-11-22 16:58:36,889]  WARN {org.apache.hadoop.mapred.LocalJobRunner} -  job_local_0001 {org.apache.hadoop.mapred.LocalJobRunner}
java.io.IOException: java.io.IOException: java.lang.RuntimeException: unable to load sub/comparator
    at org.apache.hadoop.hive.io.HiveIOExceptionHandlerChain.handleRecordReaderCreationException(HiveIOExceptionHandlerChain.java:97)
    at org.apache.hadoop.hive.io.HiveIOExceptionHandlerUtil.handleRecordReaderCreationException(HiveIOExceptionHandlerUtil.java:57)
    at org.apache.hadoop.hive.ql.io.HiveInputFormat.getRecordReader(HiveInputFormat.java:243)
    at org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.getRecordReader(CombineHiveInputFormat.java:511)
    at org.apache.hadoop.mapred.MapTask$TrackedRecordReader.(MapTask.java:197)
    at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:417)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:371)
    at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:211)
4

1 回答 1

0

似乎您的 cassandra 集群未正确连接到 BAM 服务器。确保在 Hive 脚本中正确提及您的凭据和 IP/端口等。或者您可以在 master-datasource.xml 中正确提及它们。如果一切正常，请使用 Cassandra 1.x 版本重试。

于 2013-11-23T11:11:08.450 回答