...
- 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: NONE YET
Restructuring of Maven modules (getting rid of flink-staging), Blocker?
CRITICAL
FLINK-2674 Rework windowing logic, open sub-issues:
...
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
MINOR
FLINK-2874 Some Avro generated classes are not recognized as POJOs, Solution: Pending PR #1252
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
...
MINOR
FLINK-2810 Warn user if bc not installed, Solution: Pending PR #1228
...
Jira | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
|
MINOR
Jira | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
|