[incubator-seatunnel] branch dev updated: [bug][Connector-V2][Hudi] HashCode may be negative (#3184)

[ic4y]

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 <45089228+tao...@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