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

Fix consecutive() for times() pattern.

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.3.0
    • Component/s: CEP
    • Labels:
      None

      Description

      When using next() with times() and times() is not consecutive(), the library ignores that relaxed continuity within the pattern.

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user kl0u opened a pull request:

          https://github.com/apache/flink/pull/3674

          FLINK-6265 [cep] Fix consecutive() for times()

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/kl0u/flink cep-times-fix

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flink/pull/3674.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #3674


          commit 423093371b91ebb14286c5f232da35e440cc3633
          Author: kl0u <kkloudas@gmail.com>
          Date: 2017-04-04T16:23:50Z

          FLINK-6265 [cep] Fix consecutive() for times()


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3674 FLINK-6265 [cep] Fix consecutive() for times() You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink cep-times-fix Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3674.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3674 commit 423093371b91ebb14286c5f232da35e440cc3633 Author: kl0u <kkloudas@gmail.com> Date: 2017-04-04T16:23:50Z FLINK-6265 [cep] Fix consecutive() for times()
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flink/pull/3674

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3674
          Hide
          kkl0u Kostas Kloudas added a comment -

          Merged at ffca0e76eaaefe6251a7664b93c4ec007e4305e9

          Show
          kkl0u Kostas Kloudas added a comment - Merged at ffca0e76eaaefe6251a7664b93c4ec007e4305e9

            People

            • Assignee:
              kkl0u Kostas Kloudas
              Reporter:
              kkl0u Kostas Kloudas
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development