One of the Exception instances finally reported a stacktrace. I'm not sure
why it's so infrequent.
java.lang.NullPointerException: null
at
org.apache.flink.table.data.GenericRowData.getLong(GenericRowData.java:154)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.data.RowData.lambda$createFieldGetter$245ca7d1$7(RowData.java:338)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.formats.avro.AvroRowDataSerializationSchema.lambda$createRowConverter$6827278$1(AvroRowDataSerializationSchema.java:177)
~[blob_p-97afea7f96212938a7f59355af26e877ab52777d-022ef71f40ed0889789b9e942825fbb7:?]
at
org.apache.flink.formats.avro.AvroFileSystemFormatFactory$RowDataAvroWriterFactory$1.addElement(AvroFileSystemFormatFactory.java:251)
~[blob_p-97afea7f96212938a7f59355af26e877ab52777d-022ef71f40ed0889789b9e942825fbb7:?]
at
org.apache.flink.formats.avro.AvroFileSystemFormatFactory$RowDataAvroWriterFactory$1.addElement(AvroFileSystemFormatFactory.java:247)
~[blob_p-97afea7f96212938a7f59355af26e877ab52777d-022ef71f40ed0889789b9e942825fbb7:?]
at
org.apache.flink.table.filesystem.FileSystemTableSink$ProjectionBulkFactory$1.addElement(FileSystemTableSink.java:498)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.filesystem.FileSystemTableSink$ProjectionBulkFactory$1.addElement(FileSystemTableSink.java:494)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.functions.sink.filesystem.BulkPartWriter.write(BulkPartWriter.java:48)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.functions.sink.filesystem.Bucket.write(Bucket.java:202)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.functions.sink.filesystem.Buckets.onElement(Buckets.java:282)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSinkHelper.onElement(StreamingFileSinkHelper.java:104)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.filesystem.stream.StreamingFileWriter.processElement(StreamingFileWriter.java:118)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at StreamExecCalc$793.processElement(Unknown Source) ~[?:?]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:53)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.runtime.operators.join.interval.EmitAwareCollector.collect(EmitAwareCollector.java:48)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.runtime.operators.join.interval.EmitAwareCollector.collect(EmitAwareCollector.java:28)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.runtime.operators.join.interval.TimeIntervalJoin.lambda$removeExpiredRows$2(TimeIntervalJoin.java:411)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at java.util.ArrayList.forEach(ArrayList.java:1259) ~[?:1.8.0_265]
at
org.apache.flink.table.runtime.operators.join.interval.TimeIntervalJoin.removeExpiredRows(TimeIntervalJoin.java:408)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.runtime.operators.join.interval.TimeIntervalJoin.onTimer(TimeIntervalJoin.java:332)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.runtime.operators.join.interval.RowTimeIntervalJoin.onTimer(RowTimeIntervalJoin.java:30)
~[flink-table-blink_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.onEventTime(KeyedCoProcessOperator.java:95)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.advanceWatermark(InternalTimerServiceImpl.java:276)
~[flink-dist_2.12-1.11.1.jar:1.11.1]
On Wed, Dec 9, 2020 at 4:33 PM Dan Hill <quietgol...@gmail.com> wrote:
> In the Flink dashboard, my job is failing with a NullPointerException but
> the Exception is not showing a stack trace. I do not see any
> NullPointerExceptions in any of the flink-jobmanager and flink-taskmanager
> logs.
>
> Is this a normal issue?
>
> [image: Screen Shot 2020-12-09 at 4.29.30 PM.png]
>
