Affects Version/s: None
Fix Version/s: Future
Currently when an operator invokes kill(), only the upstream operators within that fragment get terminated. This causes problems if the upstream operator in a different fragment is still continuously producing batches, and it then becomes the responsibility of the operator to drain all the batches even though a kill was issued.
While dealing with plans with multiple fragments we would need to inform the sender that a kill has been invoked. It would then be the responsibility of the sender to not push any more batches to the corresponding receiver.
|Field||Original Value||New Value|
|Workflow||no-reopen-closed, patch-avail [ 12859872 ]||no-reopen-closed, patch-avail, testing [ 12860203 ]|
|Fix Version/s||Future [ 12326743 ]|
|Workflow||no-reopen-closed, patch-avail, testing [ 12860203 ]||Drill workflow [ 12933868 ]|