We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 49cc5fc commit 68d01c4Copy full SHA for 68d01c4
python/ray/data/_internal/planner/plan_udf_map_op.py
@@ -197,18 +197,15 @@ def plan_streaming_repartition_op(
197
198
if op._strict:
199
ref_bundler = StreamingRepartitionRefBundler(op.target_num_rows_per_block)
200
- min_rows_per_bundle = None
201
else:
202
ref_bundler = None
203
- min_rows_per_bundle = op.target_num_rows_per_block
204
205
operator = MapOperator.create(
206
map_transformer,
207
input_physical_dag,
208
data_context,
209
name=op.name,
210
compute_strategy=compute,
211
- min_rows_per_bundle=min_rows_per_bundle,
212
ref_bundler=ref_bundler,
213
ray_remote_args=op._ray_remote_args,
214
ray_remote_args_fn=op._ray_remote_args_fn,
0 commit comments