Unverified Commit b5fdce41 authored by simon's avatar simon Committed by GitHub
Browse files

fix #2450 (#2493) 



* fix #1441

* support custom datax config

* support datax custom config

* support datax custom config

* support datax custom config

* fix #2450

Co-authored-by: default avatar张世鸣 <zhangshiming@cvte.com>
Co-authored-by: default avatardailidong <dailidong66@gmail.com>
parent 2f5427ca

dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ExecutorService.java

+1 −1
Original line number Diff line number Diff line
@@ -499,7 +499,7 @@ public class ExecutorService extends BaseService{ 
        // determine whether to complement

        if(commandType == CommandType.COMPLEMENT_DATA){

            runMode = (runMode == null) ? RunMode.RUN_MODE_SERIAL : runMode;

            if(null != start && null != end && start.before(end)){

            if(null != start && null != end && !start.after(end)){

                if(runMode == RunMode.RUN_MODE_SERIAL){

                    cmdParam.put(CMDPARAM_COMPLEMENT_DATA_START_DATE, DateUtils.dateToString(start));

                    cmdParam.put(CMDPARAM_COMPLEMENT_DATA_END_DATE, DateUtils.dateToString(end));