Jiangjie Qin created FLINK-31654:
------------------------------------
Summary: DataStreamUtils.reinterpretAsKeyedStream() should not
override the user specified chaining strategy.
Key: FLINK-31654
URL: https://issues.apache.org/jira/browse/FLINK-31654
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.15.4, 1.16.1, 1.14.6, 1.17.0
Reporter: Jiangjie Qin
Currently {{DataStreamUtils.reinterpretAsKeyedStream()}} does not work well
with batch jobs. There are two issues:
# The input to the downstream operator will not be sorted. So users need to
sort the records by themselves.
# The result {{KeyedStream}} will still override the chaining strategy of the
downstream operator to {{HEAD.}} This breaks the operator chain and defeats the
purpose of reinterpreting the stream instead of calling {{keyBy.}}
This ticket tends to address the second issue.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
