Closed charles-typ closed 4 years ago
Change dequeue to mutator operation and modify the way to check the number of blocks existing in the queue. The previous implementation is wrong because it is checking self.block_info.data_blocks which is not updated as the queue scales.
Tested here: https://github.com/ucbrise/jiffy/blob/4ec82a117825f2764bb791732b13d53276b49d7e/pyjiffy/test/test_client.py#L441 .
Does this issue also exist in C++ client?
No, this is only for python client. In C++ client we directly check the number of partitions with blocks_.size().
What changes were proposed in this pull request?
Change dequeue to mutator operation and modify the way to check the number of blocks existing in the queue. The previous implementation is wrong because it is checking self.block_info.data_blocks which is not updated as the queue scales.
How was this patch tested?
Tested here: https://github.com/ucbrise/jiffy/blob/4ec82a117825f2764bb791732b13d53276b49d7e/pyjiffy/test/test_client.py#L441 .