Versions Compared

Old Version 5

changes.mady.by.user Eron Wright

Saved on

compared with

New Version 6

changes.mady.by.user Eron Wright

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Move to Accepted

Status

Current state: DiscussionAccepted

Discussion thread: https://mail-archives.apache.org/mod_mbox/flink-dev/202105.mbox/%3CCAGkx0%3DR7-vmOqDW-PkHZ75J8Rz1PiNu_f5f1wDeRe30EUXBpGA%40mail.gmail.com%3E

...

  1. Combine a process function and a sink function to achieve similar effects with increased complexity.
  2. Introduce event-time timers to sink functions.  This approach seems too element-centric for the use cases.   Also, event-time timers are generally keyed.

Future Enhancements

  1. Add support for idleness.  A sink operator may become idled due to upstream status changes.  A future enhancement would be to inform the sink function in this situation.