Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
DataStream#split() has been deprecated in favour of using Side Outputs because:
- It is less performant, split() creates and checks against Strings for the splitting logic.
- split() was and is buggy : see
FLINK-5031andFLINK-11084, for example - The semantics of consecutive splits are not very clear in general.
- Side outputs are more general and everything that could be done using split() can be achieved with side outputs with strictly better performance.
Attachments
Issue Links
- is related to
-
FLINK-11084 Incorrect ouput after two consecutive split and select
- Closed
-
FLINK-5031 Consecutive DataStream.split() ignored
- Closed
-
FLINK-6113 Implement split/select with Side Outputs
- Closed
- links to