You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/07/17 16:39:04 UTC
[jira] [Resolved] (FLINK-1026) WordCount POJO fails with null
pointer exception
[ https://issues.apache.org/jira/browse/FLINK-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek resolved FLINK-1026.
-------------------------------------
Resolution: Fixed
Fixed together with other bugs in https://github.com/apache/incubator-flink/commit/152dcde0bb0d8a56bf878dde6f4aae2d2db6c8ba
> 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)