If the operator does not return chunks in the right distribution, store can mistakenly drop them.

Try running this:
store(_sg(your_operator(), 1, -1), target_array).

If that confirms the hypothesis, you can decorate the operator with some function overrides to tell the system you’re not returning data in the right distribution.
See also: PhysicalOperator::getOutputDistribution

If the operator does not return chunks in the right distribution, store can mistakenly drop them.

Try running this:
store(_sg(your_operator(), 1, -1), target_array).

If that confirms the hypothesis, you can decorate the operator with some function overrides to tell the system you’re not returning data in the right distribution.
See also: PhysicalOperator::getOutputDistribution[/quote]