Unverified Commit 4440b35c authored by Rubik-W's avatar Rubik-W Committed by GitHub
Browse files

fix #2334 (#2335) 



Co-authored-by: default avatardailidong <dailidong66@gmail.com>
parent f7e89e45

dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java

+5 −1
Original line number Diff line number Diff line
@@ -299,8 +299,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));