FunctionMergedStream non-single partition
Opened this issue · 0 comments
asubb commented
As FunctionMergedStream work with specific elements it should be partitionable, however if you made it so tests which are verifying one partition run vs multiple partitions run are failing.
Need to investigate what causes that.