Page History

...

• 3c236b2c89ed84cded0d056ac40fc728089c6f67 changes the signature of the Scala DataSet API's ExecutionEnvironment.fromCollection() method and breaks binary compatibility.
• 06b37bf550315bd1d5be7dc3ed6638fd21768e1a removes JDBC Input/OutputFormats for the deprecated Record API
  
• bac21bf5d77c8e15c608ecbf006d29e7af1dd68a:
  • Return value of addSink in DataStream API is no longer a DataStream but a DataStreamSink
  • Forward shipping is not legal when the parallelism of the operations differ
• e727355e42bd0ad7d403aee703aaf33a68a839d2  (FLINK-2723) CopyableValue interface has a new method "T copy()".
• DataStream API: Windows

...

OPEN ISSUES

BLOCKER

FLINK-2747 TypeExtractor does not correctly analyze Scala Immutables, Solution: NONE YET

FLINK-2888 Copy default state for AbstractHeapKvState, Solution: Pending PR #1289

CRITICAL

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

• FLINK-2676 Add abstraction for keyed window state, Solution: WIP (this is internal cleanup only, not related to the release)
• FLINK-2680 Create a dedicated aligned-event time window operator, Solution: no blocker (this is internal improvements only, not related to the release)

MAJOR

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

FLINK-2763 Bug in HybridHashJoin: Request to spill partition with less than two buffers, Solution: NONE YET

FLINK-2800 Kryo Serialization Problem, Solution: NONE YET

Restructuring of Maven modules (getting rid of flink-staging), (nice to have, not a blocker)

• FLINK-2581 Move Python API, Solution: Pending PR #1257

FLINK-1681 Remove Record API (nice to have, not a blocker)

• FLINK-1982 Remove dependencies in flink-runtime, Solution: Pending PR #1294
  
• FLINK-2900 Remove dependencies in hadoop-compat, Solution: Pending PR #1293
• FLINK-2901 Remove dependencies in flink-test, Solution: NONE YET
• FLINK-2906 Remove Record API, Solution: NONE YET

MINOR

FLINK-2902 Web interface sort newest jobs first, Solution: Pending PR #1296

FLINK-2904 Web interface truncates task counts, Solution: NONE YET

FIXED ISSUES

BLOCKER

FLINK-2236 RowSerializer and CaseClassComparator are not in sync regarding Null-Values, Solution: revert f8e12b20d925c3f6f24769327d1da5d98affa679 (FLINK-2203) and b59c81bc41f0fc4ade5359dfdf42549a76d412fa (FLINK-2210) on master

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

Unstage Streaming + Module refactoring, Solution: NONE YET

FLINK-2833 Unstage Gelly + Module refactoring, Solution: Pending PR #1241

FLINK-2844 Remove the old web interface, Solution: WIP (Max)

CRITICAL

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

...

Pending PR #1246

Unstage Streaming + Module refactoring, Solution: NONE YET

FLINK-2206 Web Dashboard shows at most 5 finished jobs, Solution: Pending PR #1287

CRITICAL

FLINK-2842 S3FileSystem is broken, Solution: Pending PR #1245

...

FLINK-2779 Update documentation to reflect new Stream/Window API, Solution: Pending PR #1208

FLINK-2780 Remove Old Windowing Logic and API, Solution: Pending PR #1242

FLINK-2819 Add Windowed Join/CoGroup Operator Based on Tagged Union, Solution: PR pending #1232

FLINK-2550 Rework DataStream API, Solution: Done

...

FLINK-2842 S3FileSystem is broken, Solution: Pending PR #1245

MAJOR

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

...

FLINK-2813 Document off-heap configuration, Solution: PR pending #1226

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

FLINK-2611 YARN reports failed final state for successful jobs, Solution: Pending PR #1240 (not a blocker)

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

...

FLINK-2785 Implement Graph's fromCsvReader in Gelly-Scala, Solution: Pending PR #1205

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

FLINK-2782 Remove deprecated features for 0.10, open sub-issues

• FLINK-2784 Remove deprecated config keys, Solution: Pending PR #1244
• FLINK-2786 Remove Spargel from source code and update documentation in favor of Gelly, Solution: NONE YET

MINOR

FLINK-2810 Warn user if bc not installed, Solution: Pending PR #1228

FLINK-2107 Hash-based OuterJoin strategy, Solution: Pending PR #1262

FLINK-2874 Some Avro generated classes are not recognized as POJOs, Solution: Pending PR #1252

FLINK-2668 Make each project() call a separate operator, Solution: Pending PR #1279

FLINK-2895 Duplicate immutable object creation, Solution: Pending PR #1288

ALL OPEN ISSUES

BLOCKER