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

Use time indicators in DataStreamLogicalWindowAggregateRule

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0, 1.4.0
    • Component/s: Table API & SQL
    • Labels:
      None

      Description

      The DataStreamLogicalWindowAggregateRule can use time indicators to not generate a dummy timestamp in the DataStreamCalc and make the plan representation nicer.

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user twalthr opened a pull request:

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

          FLINK-6601 [table] Use time indicators in DataStreamLogicalWindowAggregateRule

          See description in FLINK-6601.

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

          $ git pull https://github.com/twalthr/flink FLINK-6601

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

          https://github.com/apache/flink/pull/3924.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 #3924


          commit aa2fcd95fc2f90326f4dd6a382b3fee86c5c1d72
          Author: twalthr <twalthr@apache.org>
          Date: 2017-05-16T14:34:54Z

          FLINK-6601 [table] Use time indicators in DataStreamLogicalWindowAggregateRule


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3924 FLINK-6601 [table] Use time indicators in DataStreamLogicalWindowAggregateRule See description in FLINK-6601 . You can merge this pull request into a Git repository by running: $ git pull https://github.com/twalthr/flink FLINK-6601 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3924.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 #3924 commit aa2fcd95fc2f90326f4dd6a382b3fee86c5c1d72 Author: twalthr <twalthr@apache.org> Date: 2017-05-16T14:34:54Z FLINK-6601 [table] Use time indicators in DataStreamLogicalWindowAggregateRule
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user fhueske commented on the issue:

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

          +1 to merge

          Show
          githubbot ASF GitHub Bot added a comment - Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3924 +1 to merge
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

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

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3924
          Hide
          twalthr Timo Walther added a comment -

          Fixed in 1.4: a2580171dd6e9044c0694deea83a2a2f1f9eb1ee
          Fixed in 1.3: 954a100dd5fe6ecbb2aac40f33e472d85a5822df

          Show
          twalthr Timo Walther added a comment - Fixed in 1.4: a2580171dd6e9044c0694deea83a2a2f1f9eb1ee Fixed in 1.3: 954a100dd5fe6ecbb2aac40f33e472d85a5822df

            People

            • Assignee:
              twalthr Timo Walther
              Reporter:
              twalthr Timo Walther
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development