Skip to content
This repository was archived by the owner on Feb 2, 2024. It is now read-only.

Commit 27a48a6

Browse files
author
Ehsan Totoni
committed
fix parallel sort key size
1 parent 8cab48a commit 27a48a6

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

hpat/hiframes/sort.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -421,7 +421,7 @@ def local_sort(key_arrs, data, ascending=True):
421421

422422
@numba.njit(no_cpython_wrapper=True, cache=True)
423423
def parallel_sort(key_arrs, data, ascending=True):
424-
n_local = len(key_arrs)
424+
n_local = len(key_arrs[0])
425425
n_total = hpat.distributed_api.dist_reduce(n_local, np.int32(Reduce_Type.Sum.value))
426426

427427
n_pes = hpat.distributed_api.get_size()

0 commit comments

Comments
 (0)