Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Fixed
-
0.6-incubating
-
None
-
None
Description
When run from the command line on larger inputs, the WordCountPOJO fails.
java.lang.NullPointerException at org.apache.flink.api.java.typeutils.runtime.PojoComparator.compare(PojoComparator.java:271) at org.apache.flink.runtime.operators.sort.NormalizedKeySorter.compareRecords(NormalizedKeySorter.java:319) at org.apache.flink.runtime.operators.sort.NormalizedKeySorter.compare(NormalizedKeySorter.java:357) at org.apache.flink.runtime.operators.sort.QuickSort.sortInternal(QuickSort.java:96) at org.apache.flink.runtime.operators.sort.QuickSort.sort(QuickSort.java:52) at org.apache.flink.runtime.operators.sort.QuickSort.sort(QuickSort.java:56) at org.apache.flink.runtime.operators.ReduceCombineDriver.sortAndCombine(ReduceCombineDriver.java:166) at org.apache.flink.runtime.operators.ReduceCombineDriver.run(ReduceCombineDriver.java:149) at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:509) at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:374) at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265) at java.lang.Thread.run(Thread.java:745)