[FLINK-36815] series bugs of DSv2

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.0.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: xuhuang
• Reporter: xuhuang
• Created: 28/Nov/24 07:32
• Updated: 03/Dec/24 02:19
• Resolved: 03/Dec/24 02:19

Description

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 subtaskIndex 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.

 

Issue Links

• links to: GitHub Pull Request #25706