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

StreamExecTemporalSort should require a distribution trait in StreamExecTemporalSortRule

    XMLWordPrintableJSON

    Details

      Description

      flink reads kafka data and sorts by time field. In the case of multiple concurrency, it throws the following null pointer exception. One concurrent processing is normal.

       

       

       

       

        Attachments

        1. image-2020-03-27-21-22-21-122.png
          80 kB
          wuchangjun
        2. image-2020-03-27-21-22-44-191.png
          123 kB
          wuchangjun
        3. image-2020-03-27-21-23-13-648.png
          33 kB
          wuchangjun

          Issue Links

            Activity

              People

              • Assignee:
                libenchao Benchao Li
                Reporter:
                robinjun wuchangjun
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m