We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f44890f commit fc34890Copy full SHA for fc34890
python/ray/data/_internal/batcher.py
@@ -211,10 +211,6 @@ def __init__(
211
# Round it up internally to `batch_size` since our algorithm requires it.
212
# This is harmless since it only offers extra randomization.
213
shuffle_buffer_min_size = batch_size
214
- self._buffer_capacity = max(
215
- 2 * shuffle_buffer_min_size,
216
- shuffle_buffer_min_size + batch_size,
217
- )
218
self._buffer_min_size = shuffle_buffer_min_size
219
self._builder = DelegatingBlockBuilder()
220
self._shuffle_buffer: Block = None
0 commit comments