Adam Domański created FLINK-36991:
-------------------------------------
Summary: 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
Attachments: 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)
