fix #2334 (#2335)

Co-authored-by: dailidong <dailidong66@gmail.com>
5 years ago · 9b6ab81e60
1 changed files with 5 additions and 1 deletions
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
@ -309,8 +309,12 @@ public class SqlTask extends AbstractTask {
                    while (resultSet.next()) {
                        JSONObject mapOfColValues = new JSONObject(true);
                        for (int i = 1; i <= num; i++) {
+                            if (StringUtils.isNotEmpty(md.getColumnLabel(i))) {
+                                mapOfColValues.put(md.getColumnLabel(i), resultSet.getObject(i));
+                            } else {
                                mapOfColValues.put(md.getColumnName(i), resultSet.getObject(i));
                            }
+                        }
                        resultJSONArray.add(mapOfColValues);
                    }
                    logger.debug("execute sql : {}", JSON.toJSONString(resultJSONArray, SerializerFeature.WriteMapNullValue));