Sure. Currently, it looks like any element assigned to a too late window
will be dropped silently😓 ?
Having a late window stream imply somehow Flink needs to add one more state
to window and split window state cleanup from window retirement.
I would suggest as simple as adding a function in trigge
Ignacio N. Lucero Ascencio created FLINK-4188:
-
Summary: Support for outer joins on DataStream
Key: FLINK-4188
URL: https://issues.apache.org/jira/browse/FLINK-4188
Project: Flink
Ignacio N. Lucero Ascencio created FLINK-4187:
-
Summary: Support for outer joins on DataStream
Key: FLINK-4187
URL: https://issues.apache.org/jira/browse/FLINK-4187
Project: Flink
Robert Metzger created FLINK-4186:
-
Summary: Expose Kafka metrics through Flink metrics
Key: FLINK-4186
URL: https://issues.apache.org/jira/browse/FLINK-4186
Project: Flink
Issue Type: Improv
