public boolean isBucketToLoad(int bucketNumber, String partition) {
        final int partitionIndex = (partition.hashCode() & Integer.MAX_VALUE) % parallelism;
        int globalIndex = partitionIndex + bucketNumber;
        return BucketIdentifier.mod(globalIndex, parallelism) == taskID;
    }
Determine whether the current fileID belongs to the current task.
(partition + curBucket) % numPartitions == this taskID belongs to this task.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/bucket/BucketStreamWriteFunction.java