You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ic...@apache.org on 2022/10/28 09:05:20 UTC
[incubator-seatunnel] branch dev updated: [bug][Connector-V2][Hudi] HashCode may be negative (#3184)
This is an automated email from the ASF dual-hosted git repository.
ic4y pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 8beffbb60 [bug][Connector-V2][Hudi] HashCode may be negative (#3184)
8beffbb60 is described below
commit 8beffbb60380759a9924f867a5edfeea81c342fe
Author: TaoZex <45...@users.noreply.github.com>
AuthorDate: Fri Oct 28 17:05:12 2022 +0800
[bug][Connector-V2][Hudi] HashCode may be negative (#3184)
---
.../connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java
index 42b072af6..0b2f998a1 100644
--- a/seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java
+++ b/seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplitEnumerator.java
@@ -112,7 +112,7 @@ public class HudiSourceSplitEnumerator implements SourceSplitEnumerator<HudiSour
}
private static int getSplitOwner(String tp, int numReaders) {
- return tp.hashCode() % numReaders;
+ return (tp.hashCode() & Integer.MAX_VALUE) % numReaders;
}
@Override