Version
Describe the version you used.
After 2022-10-3
Describe the bug
A clear and concise description of what the bug is.
Build the following graph :
- Python Source(1)
- Java Map (2)
- Java Filter (3)
- Python Sink (4)
Jobgraph build a full graph like
1->2->3->4, but generated a new graph by optimization in chained operation, finally like
1->2(3 Chained)->4. Actually current version passing a wrong edge<2,4> to the second operator actor, so the last actor would not get the final output record.
To Reproduce
Steps to reproduce the behavior:
1.
2.
3.
4.
Expected behavior
A clear and concise description of what you expected to happen.
Screenshots
If applicable, add screenshots to help explain your problem.
Additional context
Add any other context about the problem here.