Page History

...

FLINK-2066 Make delay between execution retries configurable, Solution: Pending pull request (PR #1223)

FLINK-2674 Rework windowing logic, open sub-issues:

FLINK-2676 Add abstraction for keyed window state, Solution: WIP
FLINK-2680 Create a dedicated aligned-event time window operator, Solution: no blocker
FLINK-2779 Update documentation to reflect new Stream/Window API, Solution: Pending PR #1208
FLINK-2780 Remove Old Windowing Logic and API, Solution: WIP
FLINK-2819 Add Windowed Join/CoGroup Operator Based on Tagged Union, Solution: WIP
FLINK-2550 Rework DataStream API, Solution: First parts merged

...

FLINK-1610 Java Docs do not build, Solution: PR pending (#1225)

FLINK-2794 Document exactly-once support for sources and sinks, Solution: NONE YET

FLINK-2813 Document off-heap configuration, Solution: NONE YET

FLINK-2737 KeyedDataStream should not be a subclass of DataStream, Solution: NONE YET

FLINK-2611 YARN reports failed final state for successful jobs, Solution: NONE YET

FLINK-2767 Add support Scala 2.11 to Scala shell, Solution: Pending PR #1197

FLINK-2287 Implement JobManager high availability, open sub-issues

FLINK-2354 Recover running jobs on JobManager failure, Solution: Pending PR #1153
FLINK-2790 Add high availability support for Yarn, Solution: Pending PR #1213

asdf

ALL OPEN ISSUES

FLINK-2747 TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

...

FLINK-1778 Improve normalized keys in composite key caseFLINK-2489 Improve the streaming window join

FLINK-2523 Make task canceling interrupt interval configurable

...