Skip to content

Commit 19d3f64

Browse files
authored
[FIX-#6007]Wrong complement date (#6068)
1 parent 10a3097 commit 19d3f64

File tree

1 file changed

+3
-7
lines changed
  • dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql

1 file changed

+3
-7
lines changed

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

+3-7
Original file line numberDiff line numberDiff line change
@@ -182,18 +182,14 @@ private SqlBinds getSqlAndSqlParamsMap(String sql) {
182182
sqlParameters.getLocalParametersMap(),
183183
CommandType.of(taskExecutionContext.getCmdTypeIfComplement()),
184184
taskExecutionContext.getScheduleTime());
185-
if(MapUtils.isEmpty(paramsMap)){
186-
paramsMap=new HashMap<>();
185+
if (paramsMap == null) {
186+
sqlBuilder.append(sql);
187+
return new SqlBinds(sqlBuilder.toString(), sqlParamsMap);
187188
}
188189
if (MapUtils.isNotEmpty(taskExecutionContext.getParamsMap())){
189190
paramsMap.putAll(taskExecutionContext.getParamsMap());
190191
}
191192
// spell SQL according to the final user-defined variable
192-
if(paramsMap.isEmpty()){
193-
sqlBuilder.append(sql);
194-
return new SqlBinds(sqlBuilder.toString(), sqlParamsMap);
195-
}
196-
197193
if (StringUtils.isNotEmpty(sqlParameters.getTitle())){
198194
String title = ParameterUtils.convertParameterPlaceholders(sqlParameters.getTitle(),
199195
ParamUtils.convert(paramsMap));

0 commit comments

Comments
 (0)