Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: P2
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.1.0-incubating
    • Component/s: runner-flink
    • Labels:
      None

      Description

      Right now, Flink Batch execution does not use WindowedValue internally, this means that all programs that interact with timestamps/windows will not work. We should just internally wrap everything in WindowedValue as we do in Flink Streaming. This also makes it very straightforward to add support for windows.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                aljoscha Aljoscha Krettek
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: