Custom Dstinct Mapper의 NullPointerException

Question

hazelcast 3.6.1을 사용하고 맞춤형 mapreduce를 사용하여 고유 한 집계 기능을 구현하여 solr 패싯 유형의 결과를 얻습니다.

public class DistinctMapper implements Mapper<String, Employee, String, Long>{ 

    private transient SimpleEntry<String, Employee> entry = new SimpleEntry<String, Employee>(); 

    private static final Long ONE = Long.valueOf(1L); 

    private Supplier<String, Employee, String> supplier; 

    public DistinctMapper(Supplier<String, Employee, String> supplier) { 
     this.supplier = supplier; 
    } 

    @Override 
    public void map(String key, Employee value, Context<String, Long> context) { 
     System.out.println("Object "+ entry + " and key "+key); 
     entry.setKey(key); 
     entry.setValue(value); 
     String fieldValue = (String) supplier.apply(entry); 
     //getValue(value, fieldName); 
     if (null != fieldValue){ 
      context.emit(fieldValue, ONE); 
     } 
    } 
} 

mapper가 NullPointerException으로 실패합니다. 그리고 sysout 명령문은 입력 오브젝트가 널임을 나타냅니다.

SimpleEntry : https://github.com/hazelcast/hazelcast/blob/v3.7-EA/hazelcast/src/main/java/com/hazelcast/mapreduce/aggregation/impl/SimpleEntry.java

당신이 날 위의 코드에서 문제를 지적 할 수 있습니까? 감사.

Answer 1

entry 필드가 일시적입니다. 이것은 serialize되지 않았 음을 의미하므로 DistinctMapper 객체가 hazecalst 노드에서 deserialize 될 때 값은 null입니다. 과도 현상을 제거하면 NullPointerException가 해결됩니다.

쪽지 : 왜이 입력란이 필요합니까? 어떤 용도로 사용하지 않는 것 같습니다.