diff --git a/src/client/Context.ts b/src/client/Context.ts index 4f72173..fd81c95 100644 --- a/src/client/Context.ts +++ b/src/client/Context.ts @@ -32,7 +32,7 @@ type ResponseFactory = (rdd: RDD) => Request | Promise>; function hashPartitionFunc(numPartitions: number) { return serialize( (data: V) => { - return xxhash.XXHash32.hash(pack.encode(data)).readIntLE(0,4) % numPartitions; + return xxhash.XXHash32.hash(pack.encode(data)).readUint32LE(0, 4) % numPartitions; }, { numPartitions,