[GitHub] [dolphinscheduler] wordhardqi opened a new issue #5692: [Bug][Spark] When completing data, the time template replacement is not correct.

Thu, 24 Jun 2021 20:59:19 -0700 


wordhardqi opened a new issue #5692:
URL: https://github.com/apache/dolphinscheduler/issues/5692


   
   
![image](https://user-images.githubusercontent.com/13628428/123367328-56a9ec80-d5ac-11eb-9e42-b0135f3c8a13.png)
   
   When building the command for spark task, we use  
`ParameterUtils.convertParameterPlaceholders` which is 
   ```
           if (parameterMap != null && null != 
parameterMap.get(Constants.PARAMETER_DATETIME)) {
               //Get current time, schedule execute time
               String cronTimeStr = 
parameterMap.get(Constants.PARAMETER_DATETIME);
               cronTime = DateUtils.parse(cronTimeStr, 
Constants.PARAMETER_FORMAT_TIME);
           } else {
               cronTime = new Date();
           }
   ```
   This function didn't replace $[yyyy-MM-dd] use schedule time as what we did 
in shell task. 
   I notice this is a function  `ParameterUtils.convertParameterPlaceholders2` 
which take `        String cronTimeStr = 
parameterMap.get(Constants.PARAMETER_SHECDULE_TIME);` into consideration, shall 
we change to that? 
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to