Both, job and task manager do not present any stack trace: JOBMANAGER 07:13:15,231 INFO org.apache.flink.runtime.jobmanager.EventCollector - 11/25/2014 07:13:15: CHAIN Reduce (org.apache.flink.api.java.operators.DistinctOperator$DistinctFunction) -> Filter (org.okkam.flink.maintenance.deduplication.match.SingleMatchFilterFunctionWithFlagMatch) -> Map (org.okkam.flink.maintenance.deduplication.match.MapToTuple3MapFunction) -> Combine(org.apache.flink.api.java.operators.DistinctOperator$DistinctFunction) (18/24) switched to FAILED java.lang.NullPointerException
TASKMANAGER (on the machine that failed) 07:13:15,124 ERROR org.apache.flink.runtime.operators.RegularPactTask - Error in task code: CHAIN Reduce (org.apache.flink.api.java.operators.DistinctOperator$DistinctFunction) -> Filter (org.okkam.flink.maintenance.deduplication.match.SingleMatchFilterFunctionWithFlagMatch) -> Map (org.okkam.flink.maintenance.deduplication.match.MapToTuple3MapFunction) -> Combine(org.apache.flink.api.java.operators.DistinctOperator$DistinctFunction) (18/24) java.lang.NullPointerException do you want me to attach the whole log files? saluti, Stefano
