[
https://issues.apache.org/jira/browse/FLINK-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064781#comment-14064781
]
Aljoscha Krettek commented on FLINK-1026:
-----------------------------------------
I found the bug. The PojoComparator is not using the user code class loader and
therefore cannot duplicate the serializer it internally uses when it need to be
duplicated. The fix is simple but I will also change the
PackagedProgramEndToEndITCase to use a Pojo so that this will be tested.
> WordCount POJO fails with null pointer exception
> ------------------------------------------------
>
> Key: FLINK-1026
> URL: https://issues.apache.org/jira/browse/FLINK-1026
> Project: Flink
> Issue Type: Bug
> Components: Java API
> Affects Versions: 0.6-incubating
> Reporter: Stephan Ewen
> Assignee: Aljoscha Krettek
> Priority: Critical
> Fix For: 0.6-incubating
>
>
> When run from the command line on larger inputs, the WordCountPOJO fails.
> {code}
> 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)
> {code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
