[incubator-seatunnel] branch dev updated: [Bug][connector-file-base] Fix source split assigning reader to negative number (#2921)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs 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 0b5a2852f [Bug][connector-file-base] Fix source split assigning reader 
to negative number (#2921)
0b5a2852f is described below

commit 0b5a2852fbd1bec8c0c882f93ac5ebbd6af08c11
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Wed Sep 28 08:55:34 2022 +0800

    [Bug][connector-file-base] Fix source split assigning reader to negative 
number (#2921)
---
 .../seatunnel/file/source/split/FileSourceSplitEnumerator.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java
index 49bcb0a04..c888637bd 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java
@@ -102,7 +102,7 @@ public class FileSourceSplitEnumerator implements 
SourceSplitEnumerator<FileSour
     }
 
     private static int getSplitOwner(String tp, int numReaders) {
-        return Math.abs(tp.hashCode()) % numReaders;
+        return (tp.hashCode() & Integer.MAX_VALUE) % numReaders;
     }
 
     @Override