THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- ResultSubPartition is kept when the consumer exits (task fails), the consumer only releases the view.
- ResultSubPartition is released through ResultPartitionManager on
- consumption finished;
- producer failure/cancellation;
- Job exits
- Multiple views can be created on the same subpartition, but only one view exists at a time (No two views exist at the same time).
The proposed changes are either:
...
We plan to introduce a new `ResultPartitionType.PIPELINED_APPROXIMATE` and its corresponding ResultSubPartition to minimize the impact on existing system behavior.
There are four more points worth to highlight here:
...