[ https://issues.apache.org/jira/browse/FLINK-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291931#comment-14291931 ]
ASF GitHub Bot commented on FLINK-1437: --------------------------------------- GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/342 [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values. See description in FLINK-1437. PR includes tests cases. You can merge this pull request into a Git repository by running: $ git pull https://github.com/twalthr/flink PojoCopyFix Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/342.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #342 ---- commit f6917765fb599de74ab89580f22feb2096ca946c Author: twalthr <i...@twalthr.com> Date: 2015-01-26T15:09:24Z [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values ---- > Bug in PojoSerializer's copy() method > ------------------------------------- > > Key: FLINK-1437 > URL: https://issues.apache.org/jira/browse/FLINK-1437 > Project: Flink > Issue Type: Bug > Components: Java API > Reporter: Timo Walther > Assignee: Timo Walther > > The PojoSerializer's {{copy()}} method does not work properly with {{null}} > values. An exception could look like: > {code} > Caused by: java.io.IOException: Thread 'SortMerger spilling thread' > terminated due to an exception: null > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:792) > Caused by: java.io.EOFException > at > org.apache.flink.runtime.io.disk.RandomAccessInputView.nextSegment(RandomAccessInputView.java:83) > at > org.apache.flink.runtime.memorymanager.AbstractPagedInputView.advance(AbstractPagedInputView.java:159) > at > org.apache.flink.runtime.memorymanager.AbstractPagedInputView.readByte(AbstractPagedInputView.java:270) > at > org.apache.flink.runtime.memorymanager.AbstractPagedInputView.readUnsignedByte(AbstractPagedInputView.java:277) > at org.apache.flink.types.StringValue.copyString(StringValue.java:839) > at > org.apache.flink.api.common.typeutils.base.StringSerializer.copy(StringSerializer.java:83) > at > org.apache.flink.api.java.typeutils.runtime.PojoSerializer.copy(PojoSerializer.java:261) > at > org.apache.flink.runtime.operators.sort.NormalizedKeySorter.writeToOutput(NormalizedKeySorter.java:449) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$SpillingThread.go(UnilateralSortMerger.java:1303) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:788) > {code} > I'm working on a fix for that... -- This message was sent by Atlassian JIRA (v6.3.4#6332)