0

ある場所の従業員数を取得するマップ削減ジョブを作成しました。hazelcast 3.6.3 を使用しています。各従業員には名前と住所があります。

次の git リポジトリにコードを追加しました。 https://github.com/adasari/hazelcast-demo

例外 ：

java.util.concurrent.ExecutionException: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.mapreduce.impl.task で com.hazelcast.query.impl.Extractable にキャストできません.TrackableJobFuture.setResult(TrackableJobFuture.java:68) com.hazelcast.mapreduce.impl.task.JobSupervisor.notifyRemoteException(JobSupervisor.java:156) で com.hazelcast.mapreduce.impl.operation.NotifyRemoteExceptionOperation.run(NotifyRemoteExceptionOperation.java) :54) com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:172) で com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:393) でcom.hazelcast.spi.impl.operationexecutor.classic.OperationThread.processPacket (OperationThread.java:184) com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.process(OperationThread.java:137) で com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) で.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) 原因: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は com.hazelcast にキャストできません.query.impl.Extractable at com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) at com.hazelcast.query.impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) での operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) 原因: java.lang.ClassCastException: com.hazelcast. mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) の com.hazelcast.query.impl.Extractable にキャストできません。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) での operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) 原因: java.lang.ClassCastException: com.hazelcast. mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) の com.hazelcast.query.impl.Extractable にキャストできません。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate の com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) で com.hazelcast.query.impl.Extractable にキャストできません。適用 (AbstractPredicate.java:55)DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate の com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) で com.hazelcast.query.impl.Extractable にキャストできません。適用 (AbstractPredicate.java:55)

問題を指摘してもらえますか？

ありがとう。

4

3 に答える 3

0

次のアクションは問題を解決しました - 1. DistinctMapper は DataSerializable を実装します 2. SimpleEntry は QueryableEntry を拡張します

于 2016-08-10T11:21:43.547 に答える
0

何を探しているのか、何をしようとしているのか (コードを見て) 正確にはわかりませんが、問題は次のとおりです。

原因: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry を com.hazelcast.query.impl.Extractable にキャストできません

そのため、SimpleEntry クラスで Extractable インターフェースを実装する必要があります。

于 2016-08-08T20:09:21.480 に答える