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

AbstractCEPPatternOperator fails to restore state

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.1.2, 1.2.0
    • None
    • Library / CEP
    • None

    Description

      The restoreState() of the AbstractCEPPatternOperator restores the a Java PriorityQueue. For that it first reads the number of elements to insert and then creates a PriorityQueue object. However, Java's PriorityQueue cannot be instantiated with an initial capacity of 0, which is not checked.
      In case of an empty queue, the PriorityQueue should be instantiated with an initial size of 1.

      See http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Problem-with-CEPPatternOperator-when-taskmanager-is-killed-tp9024.html

      Attachments

        Activity

          People

            jaxbihani Jagadish Bihani
            fhueske Fabian Hueske
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: