(seatunnel) branch dev updated: [Fix][Connector-V2][Socket] Fix premature socket close in SocketSourceReader.pollNext() (#10529)

[lidongdai]

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

davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new e83661302a [Fix][Connector-V2][Socket] Fix premature socket close in 
SocketSourceReader.pollNext() (#10529)
e83661302a is described below

commit e83661302a275fea031786a4b96b2bcf9cae6140
Author: ZIHAN DAI <99155080+pd...@users.noreply.github.com>
AuthorDate: Sun Jul 19 11:47:33 2026 +1000

    [Fix][Connector-V2][Socket] Fix premature socket close in 
SocketSourceReader.pollNext() (#10529)
    
    Co-authored-by: DanielLeens <danielle...@users.noreply.github.com>
---
 .../seatunnel/socket/source/SocketSourceReader.java          | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceReader.java
 
b/seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceReader.java
index 4ecaaf4baa..975e3fca70 100644
--- 
a/seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceReader.java
@@ -60,10 +60,14 @@ public class SocketSourceReader extends 
AbstractSingleSplitReader<SeaTunnelRow>
 
     @Override
     public void close() throws IOException {
-        if (reader != null) {
-            reader.close();
-        } else if (socket != null) {
-            socket.close();
+        try {
+            if (reader != null) {
+                reader.close();
+            }
+        } finally {
+            if (socket != null) {
+                socket.close();
+            }
         }
     }