Skip to content

Commit b66d099

Browse files
authored
[Fix-17103][DataxTask] DataxTask getColumnName Cause failure (#17104)
1 parent 008e6e5 commit b66d099

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

  • dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src

dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -534,7 +534,7 @@ public String[] tryExecuteSqlResolveColumnNames(DbType sourceType, BaseConnectio
534534
int num = md.getColumnCount();
535535
columnNames = new String[num];
536536
for (int i = 1; i <= num; i++) {
537-
columnNames[i - 1] = md.getColumnName(i).replace("t.", "");
537+
columnNames[i - 1] = md.getColumnLabel(i).replace("t.", "");
538538
}
539539
} catch (SQLException | ExecutionException e) {
540540
log.error(e.getMessage(), e);

dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/test/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ public void testTryExecuteSqlResolveColumnNames() throws Exception {
213213

214214
ResultSetMetaData md = mock(ResultSetMetaData.class);
215215
when(md.getColumnCount()).thenReturn(1);
216-
when(md.getColumnName(eq(1))).thenReturn("something");
216+
when(md.getColumnLabel(eq(1))).thenReturn("something");
217217

218218
ResultSet resultSet = mock(ResultSet.class);
219219
when(resultSet.getMetaData()).thenReturn(md);

0 commit comments

Comments
 (0)