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