xuhuang created FLINK-36815:
-------------------------------
Summary: series bugs of DSv2
Key: FLINK-36815
URL: https://issues.apache.org/jira/browse/FLINK-36815
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 2.0.0
Reporter: xuhuang
I found four bugs in DSv2.
1. The DSv2 _org.apache.flink.datastream.api.ExecutionEnvironment#fromSource_
method return a
{_}NonKeyedPartitionStream{_}, which does not allow users to set source
configurations, such as operator name or parallelism.
2. The _org.apache.flink.datastream.api.context.TaskInfo_ lack
{_}sub{_}_taskIndex_ and {_}attemptNumber{_}.
3. The _open_ and _close_ methods of
_org.apache.flink.datastream.api.function.ProcessFunction_ are not being called.
4. The _open_ method of
_org.apache.flink.datastream.api.function.ProcessFunction_ lacks relevant
information, such as the current TaskInfo.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
