[GitHub] [seatunnel] zhilinli123 commented on a diff in pull request #4826: [Bug][flink-runtime][connectors-v2] Flink register table Environment The running mode is set to`job.mode`

["zhilinli123 (via GitHub)" <gi...@apache.org>]

zhilinli123 commented on code in PR #4826:
URL: https://github.com/apache/seatunnel/pull/4826#discussion_r1207702042


##########
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java:
##########
@@ -123,8 +123,10 @@ public int currentUnassignedSplitSize() {
 
     @Override
     public void registerReader(int subtaskId) {
+        Set<Integer> readers = context.registeredReaders();

Review Comment:
   
   > Why change it?
   
   I just reconfirmed that there is no such problem,  I have restored it
   



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org