(seatunnel) branch dev updated: [Fix][Connector-V2] Fix wrong exception reference in MilvusSourceReader query error handling (#10975)

[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 bf96310c72 [Fix][Connector-V2] Fix wrong exception reference in 
MilvusSourceReader query error handling (#10975)
bf96310c72 is described below

commit bf96310c723c9be4a0bc6a14faf1b0c07df80b3a
Author: cosmosni <nijiahui_y...@cmss.chinamobile.com>
AuthorDate: Sat May 30 13:19:23 2026 +0800

    [Fix][Connector-V2] Fix wrong exception reference in MilvusSourceReader 
query error handling (#10975)
---
 .../connectors/seatunnel/milvus/source/MilvusSourceReader.java         | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java
 
b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java
index fb34245b60..949036d33b 100644
--- 
a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java
@@ -195,8 +195,7 @@ public class MilvusSourceReader implements 
SourceReader<SeaTunnelRow, MilvusSour
 
         if (queryResultsR.getStatus() != R.Status.Success.getCode()) {
             throw new MilvusConnectorException(
-                    MilvusConnectionErrorCode.SERVER_RESPONSE_FAILED,
-                    loadStateResponse.getException());
+                    MilvusConnectionErrorCode.SERVER_RESPONSE_FAILED, 
queryResultsR.getException());
         }
         QueryResultsWrapper wrapper = new 
QueryResultsWrapper(queryResultsR.getData());
         List<QueryResultsWrapper.RowRecord> records = wrapper.getRowRecords();