Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31007

The code generated by the IF function throws NullPointerException

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • 1.15.2, 1.15.3
    • None
    • None

    Description

      Caused by: java.lang.NullPointerException
          at StreamExecCalc$19.processElement_split1(Unknown Source)
          at StreamExecCalc$19.processElement(Unknown Source)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
          at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
          at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
          at org.apache.flink.table.runtime.operators.source.InputConversionOperator.processElement(InputConversionOperator.java:128)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
          at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
          at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
          at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
          at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
          at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
          at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
          at org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:231)
          at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
          at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
          at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)

      Attachments

        1. StreamExecCalc$19.java
          7 kB
          tivanli
        2. image-2023-02-10-17-20-51-619.png
          408 kB
          xuzhiwen
        3. image-2023-02-13-18-24-08-380.png
          107 kB
          xuzhiwen
        4. image-2023-02-13-18-25-32-357.png
          170 kB
          xuzhiwen
        5. image-2023-02-13-18-27-27-856.png
          112 kB
          xuzhiwen

        Issue Links

          Activity

            People

              xzw0223 xuzhiwen
              tivan tivanli
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: