(dolphinscheduler) branch dev updated: [Fix-17103][DataxTask] DataxTask getColumnName Cause failure (#17104)

[wenjun]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new b66d099f60 [Fix-17103][DataxTask] DataxTask getColumnName Cause 
failure (#17104)
b66d099f60 is described below

commit b66d099f60b9e944b3ef14c077f2dcc9bd61cd22
Author: deng-jeffer <jeffer_d...@foxmail.com>
AuthorDate: Tue Apr 15 09:36:29 2025 +0800

    [Fix-17103][DataxTask] DataxTask getColumnName Cause failure (#17104)
---
 .../java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java   | 2 +-
 .../org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java
index 4b989a5503..d8aadffe96 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java
@@ -534,7 +534,7 @@ public class DataxTask extends AbstractTask {
             int num = md.getColumnCount();
             columnNames = new String[num];
             for (int i = 1; i <= num; i++) {
-                columnNames[i - 1] = md.getColumnName(i).replace("t.", "");
+                columnNames[i - 1] = md.getColumnLabel(i).replace("t.", "");
             }
         } catch (SQLException | ExecutionException e) {
             log.error(e.getMessage(), e);
diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/test/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/test/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java
index fbd5c59aa7..3b1dd82c92 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/test/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/test/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java
@@ -213,7 +213,7 @@ public class DataxTaskTest {
 
             ResultSetMetaData md = mock(ResultSetMetaData.class);
             when(md.getColumnCount()).thenReturn(1);
-            when(md.getColumnName(eq(1))).thenReturn("something");
+            when(md.getColumnLabel(eq(1))).thenReturn("something");
 
             ResultSet resultSet = mock(ResultSet.class);
             when(resultSet.getMetaData()).thenReturn(md);