[
https://issues.apache.org/jira/browse/FLINK-36991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909255#comment-17909255
]
Adam Domański commented on FLINK-36991:
---------------------------------------
Attaching generated code for TableCalcMapFunction$6
> NPE in BinarySegmentUtils
> -------------------------
>
> Key: FLINK-36991
> URL: https://issues.apache.org/jira/browse/FLINK-36991
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.19.1
> Reporter: Adam Domański
> Priority: Major
> Attachments: TableCalcMapFunction$6.java, exception.txt
>
>
> Job fails three times a day due to NPE exception in BinarySegmentUtils.
> {code:java}
> Caused by: java.lang.NullPointerException
> at
> org.apache.flink.table.data.binary.BinarySegmentUtils.inFirstSegment(BinarySegmentUtils.java:411)
> ~[flink-table-api-java-uber-1.19.1.jar:1.19.1]
> at
> org.apache.flink.table.data.binary.BinarySegmentUtils.copyToBytes(BinarySegmentUtils.java:132)
> ~[flink-table-api-java-uber-1.19.1.jar:1.19.1]
> at
> org.apache.flink.table.data.binary.BinarySegmentUtils.copyToBytes(BinarySegmentUtils.java:118)
> ~[flink-table-api-java-uber-1.19.1.jar:1.19.1]
> at
> org.apache.flink.table.data.binary.BinaryStringData.copy(BinaryStringData.java:360)
> ~[flink-table-api-java-uber-1.19.1.jar:1.19.1]
> at
> org.apache.flink.table.runtime.typeutils.StringDataSerializer.copy(StringDataSerializer.java:56)
> ~[flink-table-runtime-1.19.1.jar:1.19.1]
> at TableCalcMapFunction$8.flatMap(Unknown Source) ~[?:?]
> at
> org.apache.flink.table.runtime.operators.join.lookup.LookupJoinWithCalcRunner$CalcCollector.collect(LookupJoinWithCalcRunner.java:87)
> ~[flink-table-runtime-1.19.1.jar:1.19.1]
> ... 46 more
> {code}
> Job is restored then.
> org.apache.flink.runtime.jobmaster.JobMaster [] - 3550 tasks will be
> restarted to recover the failed task
> 9459e605a9875c40ca2910b1a71fe1d8_660e66c589c31053e951972446c69fc1_1_44.
> Execution graph is
> {{*anonymous_datastream_source$1*[1] -> Calc[2] -> WatermarkAssigner[3] ->
> MiniBatchAssigner[4] -> Calc[5] -> LookupJoin[6] -> Calc[7] ->
> WindowTableFunction[8] -> Calc[9] (2/20)}}
> Attached full stacktrace.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
