1. 06 5月, 2020 1 次提交
    • D
      add development state config (#2609) · 6a92bef5
      dailidong 提交于
      * update README about DolphinScheduler
      
      * Update issue templates
      
      * update
      
      * regularize api pom xml
      update rpc maven compile to 1.8
      
      * regularize api pom xml
      
      * change commons.lang3.StringUtils to common.utils.StringUtils
      
      * update pom.xml
      
      * update
      
      * correct equals method
      
      * jasper-runtime is needed when api server start
      
      * jasper-runtime jar is needed when api server start
      
      * combine logback config of master/worker/alert/api server to one logback.xml
      
      * remove tomcat runtime jar
      
      * add UT
      
      * add license
      
      * remove jasper-runtime jar, not need anymore
      
      * sovle jar conflict, remove servlet-api 2.5 jar
      
      * remove servlet 2.5
      
      * add embedded database h2 and update embedded zookeeper
      
      * delete logs
      
      * add license
      
      * change log level to INFO
      
      * simplify and optimize config
      
      * add development state
      Co-authored-by: Nlidongdai <escheduler@outlook.com>
      Co-authored-by: Ndailidong <dolphinschedule@gmail.com>
      6a92bef5
  2. 30 4月, 2020 3 次提交
  3. 28 4月, 2020 1 次提交
  4. 21 4月, 2020 1 次提交
    • D
      simplify and optimize config (#2469) · eec92ed1
      dailidong 提交于
      * [Refactor worker] simplify and optimize config (#2386)
      
      * simplify config
      
      * simplify config
      
      * simplify and optimize config
      
      * Update HadoopUtils.java
      
      optimize HadoopUtils
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HttpUtils.java
      
      * Update pom.xml
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      
      * Update HadoopUtilsTest.java
      eec92ed1
  5. 20 4月, 2020 2 次提交
    • D
      Update HttpUtils.java · 437605e6
      dailidong 提交于
      437605e6
    • B
      move dependent and conditions to master server (#2423) · 4946e888
      bao liang 提交于
      * move condition and dependent to master
      
      * move conditions to master
      
      * move conditions and dependent task to master
      
      * move conditions to master
      
      * update test
      
      * add log
      
      * add test for dependent task
      
      * add test for dependent task
      
      * update
      
      * update
      
      * refactor complexity code
      
      * refactor complexity code
      
      * add conditions task test
      
      * add conditions task test
      
      * update
      
      * update host to host:port
      
      * update logback.xml
      Co-authored-by: Nbaoliang <baoliang@analysys.com.cn>
      4946e888
  6. 16 4月, 2020 2 次提交
    • D
      Update HadoopUtils.java · b85b5937
      dailidong 提交于
      optimize HadoopUtils
      b85b5937
    • Q
      1,task status statistics and process status statistics bug fix (#2357) ... · d6798c6d
      qiaozhanwei 提交于
      1,task status statistics and process status statistics bug fix (#2357)  2,worker group bug fix (#2430)
      
      * dispatch task fail will set task status failed
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,no worker condition , master will while ture wait for worker startup
      2,worker response task status sync wait for result
      
      * 1,task status statistics and process status statistics bug fix (#2357)
      2,worker group bug fix
      
      * 1,task status statistics and process status statistics bug fix (#2357)
      2,worker group bug fix
      
      * 1,task status statistics and process status statistics bug fix (#2357)
      2,worker group bug fix
      
      * 1,task status statistics and process status statistics bug fix (#2357)
      2,worker group bug fix
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      d6798c6d
  7. 11 4月, 2020 1 次提交
    • L
      It is necessary to check whether the resource is valid (#2399) · 733acdfd
      lgcareer 提交于
      * init full_name in dml of version 1.2.2
      
      * redefine request parameter resourceIds
      
      * redefine request parameter resourceIds
      
      * Actually grant resource file if choose the directory
      
      * To cancel authorized resource need check whether it is used by the process definition which is online
      
      * If release the process definition online,It is necessary to check whether resource is valid
      
      * update ResourceServiceTest and ResourceMapperTest
      
      * add batchUpdateResourceTest
      
      * add getHdfsFileNameTest and getHdfsResourceFileNameTest
      
      * update ResourceServiceTest and ResourceMapperTest
      
      * extract getResourceProcessMap to ResourceProcessDefinitonUtils
      Co-authored-by: Ndailidong <dailidong66@gmail.com>
      733acdfd
  8. 10 4月, 2020 1 次提交
  9. 07 4月, 2020 3 次提交
  10. 31 3月, 2020 4 次提交
    • Q
      startup conflict reslove · 70d63601
      qiaozhanwei 提交于
      70d63601
    • D
      remove zookeeper as task queue config (#2344) · c9620ab5
      dailidong 提交于
      * update logback
      
      * update log
      
      * refactor worker registry (#2107)
      
      * Refactor worker (#2115)
      
      * refactor worker registry
      
      * refactor master server
      
      * Modify workgroupid parameter name (#2105)
      
      * Delete worker group management page
      
      * Modify workgroupid parameter name
      
      * Refactor worker (#2121)
      
      * refactor worker registry
      
      * refactor master server
      
      * refactor MasterSchedulerService
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath (#2126)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      
      * not exist in openjdk,just delete
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * fix cpu 100% bug
      
      * simplify master、 worker、alert、dao properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * Optimize code , reduce cost time from 60ms to 0.5ms
      
      * merge code form remote
      
      * remove zookeeper as task queue relevant config
      
      * correct config error and remove unuse properties that may affect performance
      
      * correct config error and remove unuse properties that may affect performance
      
      * remove zookeeper as task queue config
      
      * remove zookeeper as task queue config
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      c9620ab5
    • D
      [Refactor worker] correct config error and remove unuse properties that may... · fce6af0c
      dailidong 提交于
      [Refactor worker] correct config error and remove unuse properties that may affect performance  (#2343)
      
      * update logback
      
      * update log
      
      * refactor worker registry (#2107)
      
      * Refactor worker (#2115)
      
      * refactor worker registry
      
      * refactor master server
      
      * Modify workgroupid parameter name (#2105)
      
      * Delete worker group management page
      
      * Modify workgroupid parameter name
      
      * Refactor worker (#2121)
      
      * refactor worker registry
      
      * refactor master server
      
      * refactor MasterSchedulerService
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath (#2126)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      
      * not exist in openjdk,just delete
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * fix cpu 100% bug
      
      * simplify master、 worker、alert、dao properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * Optimize code , reduce cost time from 60ms to 0.5ms
      
      * merge code form remote
      
      * remove zookeeper as task queue relevant config
      
      * correct config error and remove unuse properties that may affect performance
      
      * correct config error and remove unuse properties that may affect performance
      
      * remove zookeeper as task queue config
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      fce6af0c
    • G
      Adapting partial code(file name start with O) to the sonar cloud rule (#2259) · 718e4b15
      gabry.wu 提交于
      * Adapting partial code(file name start with O) to the sonar cloud rule
      
      * resolve conflict with dev branch
      Co-authored-by: Ndailidong <dailidong66@gmail.com>
      718e4b15
  11. 30 3月, 2020 3 次提交
    • D
      [Refactor worker] correct config error and remove unuse properties that may... · 07cc10c3
      dailidong 提交于
      [Refactor worker] correct config error and remove unuse properties that may affect performance (#2337)
      
      * update logback
      
      * update log
      
      * refactor worker registry (#2107)
      
      * Refactor worker (#2115)
      
      * refactor worker registry
      
      * refactor master server
      
      * Modify workgroupid parameter name (#2105)
      
      * Delete worker group management page
      
      * Modify workgroupid parameter name
      
      * Refactor worker (#2121)
      
      * refactor worker registry
      
      * refactor master server
      
      * refactor MasterSchedulerService
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath (#2126)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      
      * not exist in openjdk,just delete
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * fix cpu 100% bug
      
      * simplify master、 worker、alert、dao properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * Optimize code , reduce cost time from 60ms to 0.5ms
      
      * merge code form remote
      
      * remove zookeeper as task queue relevant config
      
      * correct config error and remove unuse properties that may affect performance
      
      * correct config error and remove unuse properties that may affect performance
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      07cc10c3
    • S
      some annotation optimizations (#2333) · f7e89e45
      songgg 提交于
      Co-authored-by: Nsongqh <songquanhe@foxmail.com>
      f7e89e45
    • D
      remove zookeeper as task queue relevant config (#2330) · 195dfb50
      dailidong 提交于
      * update logback
      
      * update log
      
      * refactor worker registry (#2107)
      
      * Refactor worker (#2115)
      
      * refactor worker registry
      
      * refactor master server
      
      * Modify workgroupid parameter name (#2105)
      
      * Delete worker group management page
      
      * Modify workgroupid parameter name
      
      * Refactor worker (#2121)
      
      * refactor worker registry
      
      * refactor master server
      
      * refactor MasterSchedulerService
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath (#2126)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      
      * not exist in openjdk,just delete
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * fix cpu 100% bug
      
      * simplify master、 worker、alert、dao properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * Optimize code , reduce cost time from 60ms to 0.5ms
      
      * merge code form remote
      
      * remove zookeeper as task queue relevant config
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      195dfb50
  12. 28 3月, 2020 3 次提交
    • L
      Connection mode of adding Sid to Oracle (#2254) · 526e5c91
      liwenhe1993 提交于
      * Connection mode of adding Sid to Oracle
      
      * Remove code
      
      * Add asf
      
      * Add unit test
      
      * Add unit test
      
      * Add unit test
      
      * solve the conflict
      526e5c91
    • L
      new feature for #404 add resource tree function (#2323) · 38c965dd
      lgcareer 提交于
      * add create resource directory
      
      * add create resource directory
      
      * update the resource test
      
      * add upgrade sql in version 1.2.2
      
      * Adding request parameter id to update queryResourceListPaging
      
      * set isDirectory value is false default
      
      * add full name to update updateResource
      
      * remove request parameter isDirectory to update createResource method
      
      * update queryResourceListPaging with change get to post
      
      * update updateResource method with remove fullName
      
      * File management list modification (#1976)
      
      * add resource component
      
      * add resource tree visitor
      
      * return json string
      
      * update queryResourceList
      
      * upload file need fullName
      
      * add method rootNode
      
      * Shell task resources and authorization resources (#1989)
      
      * File management list modification
      
      * Shell task resources and authorization resources
      
      * download resource when execute task
      
      * download resource when execute task
      
      * update authorization type
      
      * download resource when execute task
      
      * Spark task resource changes (#1990)
      
      * File management list modification
      
      * Shell task resources and authorization resources
      
      * Spark task resource changes
      
      * download resource when execute task
      
      * update udf function service
      
      * add resource type in ResourceComponent
      
      * UDF resource tree and change DAG style (#2019)
      
      * File management list modification
      
      * Shell task resources and authorization resources
      
      * Spark task resource changes
      
      * UDF resource tree and change DAG style
      
      * add deleteIds method in ResourceMapper and ResourceMapperTest
      
      * Add comments on class and method
      
      * add queryResourceByName method in controller
      
      * update verify-name with change name to full name
      
      * update queryResource with add parameter pid
      
      * update queryResource with add parameter pid
      
      * add resource ids in process definition and delete resource need judge whether it is used by any process definition
      
      * Breadcrumb development (#2033)
      
      * File management list modification
      
      * Shell task resources and authorization resources
      
      * Spark task resource changes
      
      * UDF resource tree and change DAG style
      
      * Breadcrumb development
      
      * Breadcrumb development
      
      * Resource tree bug fix (#2040)
      
      * File management list modification
      
      * Shell task resources and authorization resources
      
      * Spark task resource changes
      
      * UDF resource tree and change DAG style
      
      * Breadcrumb development
      
      * Breadcrumb development
      
      * Resource tree bug fix
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * Fix github action rerun failed (#2067)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * Change crumb position
      
      * Change crumb position (#2068)
      
      * build resource process definition map
      
      * UDF changed to multiple choice
      
      * UDF changed to multiple choice (#2077)
      
      * Change crumb position
      
      * UDF changed to multiple choice
      
      * build resource process definition map (#2076)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * build resource process definition map
      
      * update resource name also need update all the children full name
      
      * need add queryResource
      
      * update resource name also need update all the children full name (#2096)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * build resource process definition map
      
      * update resource name also need update all the children full name
      
      * need add queryResource
      
      * Limit customization file content to no more than 3000 lines
      
      * Limit customization file content to no more than 3000 lines(#2128)
      
      * Limit customization file content to no more than 3000 lines(#2128) (#2140)
      
      * Change crumb position
      
      * UDF changed to multiple choice
      
      * Limit customization file content to no more than 3000 lines
      
      * Limit customization file content to no more than 3000 lines(#2128)
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add queryResourceJarList (#2192)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * build resource process definition map
      
      * update resource name also need update all the children full name
      
      * need add queryResource
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * Modify the main jar package
      
      * Modify the main jar package (#2200)
      
      * Change crumb position
      
      * UDF changed to multiple choice
      
      * Limit customization file content to no more than 3000 lines
      
      * Limit customization file content to no more than 3000 lines(#2128)
      
      * Modify the main jar package
      
      * add resource filter in order to get filtered resource
      
      * add comments of resource filter
      
      * update list children by resource
      
      * choose main jar with resource tree (#2220)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * build resource process definition map
      
      * update resource name also need update all the children full name
      
      * need add queryResource
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add resource filter in order to get filtered resource
      
      * add comments of resource filter
      
      * update list children by resource
      
      * Return null if query resource list is empty
      
      * update queryResource method change parameter pid to id
      
      * getResouDelete checksum and modify parameter namerceId
      
      * revert .env
      
      * remove parameter pid
      
      * Delete request interface
      
      * go back to the last page
      
      * jar interface call
      
      * Fix issue #2234 and #2228
      
      * change resource name with full name
      
      * Fix issue #2234 and #2228 (#2246)
      
      * update resource service test
      
      * Fix github action rerun failed
      
      * add status of PARENT_RESOURCE_NOT_EXIST
      
      * build resource process definition map
      
      * update resource name also need update all the children full name
      
      * need add queryResource
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add queryResourceJarList
      
      * add resource filter in order to get filtered resource
      
      * add comments of resource filter
      
      * update list children by resource
      
      * Return null if query resource list is empty
      
      * update queryResource method change parameter pid to id
      
      * revert .env
      
      * remove parameter pid
      
      * Fix issue #2234 and #2228
      
      * change resource name with full name
      
      * Fix list query value error
      
      * remove unauth-file with authorize-resource-tree
      
      * Repair data cannot be echoed
      
      * Repair data cannot be echoed
      
      * execute mr and spark task need query resource name before
      
      * Authorized resource interface replacement
      
      * Authorized resource interface replacement
      
      * Filter UDF resources
      
      * Change parameters
      
      * need query all authorized directory children when create task
      
      * Change normalize.scss import method and animation.scss license modification
      
      * Delete file list update processing
      
      * It's fixed that resource not deleted in hdfs when delete it.
      
      * add tooltips
      
      * add tooltips (#2310)
      
      * Echo workflow name and modify udf management name
      
      * [new feature]add resource tree function
      
      * revert front code in order to be same as dev branch
      
      * revert front code in order to be same as dev branch
      
      * revert common.properties and application.properties
      
      * add super method
      
      * update flink parameter test
      
      * update flink parameter and unit test
      
      * update resource service test
      
      * If resource list is empty,need init it
      
      * update flink parameter test
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nxingchun-chen <55787491+xingchun-chen@users.noreply.github.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      38c965dd
    • G
  13. 26 3月, 2020 3 次提交
  14. 25 3月, 2020 2 次提交
    • Q
      1,ZookeeperRegister use common.properties zookeeperRoot path 2,api start... · 03e29b93
      qiaozhanwei 提交于
      1,ZookeeperRegister use common.properties zookeeperRoot path 2,api start exclude org.apache.dolphinscheduler.server.* (#2307)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * Encapsulate the parameters required by sqltask
      
      * 1,Encapsulate the parameters required by sqltask
      2,SQLTask optimization
      
      * AbstractTask modify
      
      * ProcedureTask optimization
      
      * MasterSchedulerService modify
      
      * TaskUpdateQueueConsumer modify
      
      * test
      
      * DataxTask process run debug
      
      * DataxTask process run debug
      
      * add protobuf dependency,MR、Spark task etc need this
      
      * TaskUpdateQueueConsumer modify
      
      * TaskExecutionContextBuilder set TaskInstance workgroup
      
      * WorkerGroupService queryAllGroup modify
      query available work group
      
      * 1,get workergroup from zk modify
      2,SpringConnectionFactory repeat load modify
      
      * master and worker register ip  use OSUtils.getHost()
      
      * ProcessInstance host set ip:port format
      
      * worker fault tolerance modify
      
      * Constants and .env modify
      
      * master fault tolerant bug modify
      
      * UT add pom.xml
      
      * timing online  modify
      
      * when taskResponse is faster than taskAck to db,task state will error
      add async queue and new a thread reslove this problem
      
      * TaskExecutionContext set host
      
      * 1,TaskManager refactor
      2, api start load server dolphinschedule-daemon.sh modify
      
      * 1,TaskManager refactor
      2, api start load server dolphinschedule-daemon.sh modify
      
      * add UT in pom.xml
      
      * revert dolphinscheduler-daemon.sh
      
      * ZookeeperRegister use common.properties zookeeperRoot path
      
      * api start exclude org.apache.dolphinscheduler.server.*
      
      * ZookeeperRegister use common.properties zookeeperRoot path
      
      * 1,api start load server filter
      2,SHELL task exitStatusCode modify
      
      * java doc error modify
      
      * java doc error modify
      
      * remove todo
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      03e29b93
    • D
      [refactor-worker] simplify master、 worker、alert、dao properties (#2304) · ace907e7
      dailidong 提交于
      * update logback
      
      * update log
      
      * refactor worker registry (#2107)
      
      * Refactor worker (#2115)
      
      * refactor worker registry
      
      * refactor master server
      
      * Modify workgroupid parameter name (#2105)
      
      * Delete worker group management page
      
      * Modify workgroupid parameter name
      
      * Refactor worker (#2121)
      
      * refactor worker registry
      
      * refactor master server
      
      * refactor MasterSchedulerService
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath (#2126)
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      
      * not exist in openjdk,just delete
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * fix cpu 100% bug
      
      * simplify master、 worker、alert、dao properties
      
      * add master and worker properties
      
      * add master and worker properties
      
      * add master and worker properties
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      ace907e7
  15. 24 3月, 2020 1 次提交
    • Q
      timing online modify (#2296) · 11e3bff6
      qiaozhanwei 提交于
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * Encapsulate the parameters required by sqltask
      
      * 1,Encapsulate the parameters required by sqltask
      2,SQLTask optimization
      
      * AbstractTask modify
      
      * ProcedureTask optimization
      
      * MasterSchedulerService modify
      
      * TaskUpdateQueueConsumer modify
      
      * test
      
      * DataxTask process run debug
      
      * DataxTask process run debug
      
      * add protobuf dependency,MR、Spark task etc need this
      
      * TaskUpdateQueueConsumer modify
      
      * TaskExecutionContextBuilder set TaskInstance workgroup
      
      * WorkerGroupService queryAllGroup modify
      query available work group
      
      * 1,get workergroup from zk modify
      2,SpringConnectionFactory repeat load modify
      
      * master and worker register ip  use OSUtils.getHost()
      
      * ProcessInstance host set ip:port format
      
      * worker fault tolerance modify
      
      * Constants and .env modify
      
      * master fault tolerant bug modify
      
      * UT add pom.xml
      
      * timing online  modify
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      11e3bff6
  16. 23 3月, 2020 1 次提交
    • Q
      UT Coverage rate test (#2276) · 052f9d10
      qiaozhanwei 提交于
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * Encapsulate the parameters required by sqltask
      
      * 1,Encapsulate the parameters required by sqltask
      2,SQLTask optimization
      
      * AbstractTask modify
      
      * ProcedureTask optimization
      
      * MasterSchedulerService modify
      
      * TaskUpdateQueueConsumer modify
      
      * test
      
      * DataxTask process run debug
      
      * DataxTask process run debug
      
      * add protobuf dependency,MR、Spark task etc need this
      
      * TaskUpdateQueueConsumer modify
      
      * TaskExecutionContextBuilder set TaskInstance workgroup
      
      * WorkerGroupService queryAllGroup modify
      query available work group
      
      * 1,get workergroup from zk modify
      2,SpringConnectionFactory repeat load modify
      
      * master and worker register ip  use OSUtils.getHost()
      
      * ProcessInstance host set ip:port format
      
      * worker fault tolerance modify
      
      * Constants and .env modify
      
      * master fault tolerant bug modify
      
      * UT add pom.xml
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      052f9d10
  17. 22 3月, 2020 2 次提交
  18. 20 3月, 2020 1 次提交
  19. 19 3月, 2020 1 次提交
  20. 18 3月, 2020 1 次提交
    • R
      add repace time when run history job and batch complement job ,not current time (#2196) · 880e9956
      ruson 提交于
      * add release notes in 1.2.1 (#1654)
      
      * fix Monitor bug (#1656)
      
      * fix Monitor bug
      
      * fix zk monitor bug
      
      * fix api url (#1673)
      
      * get root path from zookeeper config
      
      * Fixed DAG zoom in and zoom out nodes separated from arrows #1679 (#1685)
      
      * fix api url
      
      * Fixed DAG zoom in and zoom out nodes separated from arrows #1679
      
      * check license and update (#1725)
      
      * Fixed tasks_queue and tasks_kill did not exist in zookeeper #1696 (#1734)
      Co-authored-by: Nelonlo <gamelifedong@gmail.com>
      
      * upgrade jackson from 2.9.8 to 2.10.1 (#1767)
      
      * add out put log when master/worker server start (#1769)
      
      * merge hadoop.properties into common.properties
      
      * merge hadoop,zookeeper.properties into common.properties
      remove combined.properties/master.properties/worker.properties
      
      * change db user/pwd to test/test
      
      * rename .dolphinscheduler_en.sh to dolphinscheduler_env.sh
      remove some unused in install.sh
      
      * add out put log when master/worker server start...
      
      * add start log when servers start
      
      * add check download resource permission in order to fix issues 1770 (#1788)
      
      * merge dev branch front-end code (#1786)
      
      * fix #1775 bug,delete process definition when process instance is running (#1790)
      
      * fix #1775 bug,delete process definition when process instance is running
      
      * revert CONTRIBUTING.md
      
      * fix udfs assignment and task instance page jump #1789 (#1791)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * update method checkDownloadPermission in order to fix issues 1770 (#1794)
      
      * add check download resource permission in order to fix issues 1770
      
      * update method checkDownloadPermission in order to fix issues 1770
      
      * update method listUnauthorizedResource in order to fix issues 1770
      
      * update method listUnauthorizedResource in order to fix issues 1770 (#1797)
      
      * if login user is admin,it will has permission to query all udf function (#1799)
      
      * Fixed space and icon display issues before and after the input box (#1798)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * Fixed space and icon display issues before and after the input box
      
      * add license
      
      * add license
      
      * donot submit task to queue if sub process (#1793)
      
      * dockerfile modify (#1800)
      
      * fix #1775 bug,delete process definition when process instance is running
      
      * revert CONTRIBUTING.md
      
      * dockerfile modify
      
      * dockerfile modify
      
      * dockerfile modify
      
      * Fix data echo, style and popup cannot be closed (#1801)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * Fixed space and icon display issues before and after the input box
      
      * add license
      
      * add license
      
      * Fix data echo, style and popup cannot be closed
      
      * Fix page number loading issue and dag not getting value(#1810) (#1815)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * Fixed space and icon display issues before and after the input box
      
      * add license
      
      * add license
      
      * Fix data echo, style and popup cannot be closed
      
      * Fix page number loading issue and dag not getting value
      
      * [Fix issue #1770]check udf and data source in order to fix issue 1770 (#1817)
      
      * if login user is admin,it will has permission to query all udf function
      
      * check udf and data source in order to fix issue 1770
      
      * check udf and data source in order to fix issue 1770
      
      * check udf and data source in order to fix issue 1770
      
      * check udf and data source in order to fix issue 1770
      
      * check udf and data source in order to fix issue 1770
      
      * revert common.properties
      
      * update the test method name
      
      * remove useless code and import in unit test
      
      * refactor has permission and check permission
      
      * #1813 remove "_001" after the master/server register path in zookeepe (#1824)
      
      * donot submit task to queue if sub process
      
      * [feature] #1813 remove "_001" after the master/server register path in zookeeper (#1820)
      
      * change master/worker register path.
      
      * remove "_" from register path.
      
      * remove install.sh server.servlet.context-path replace (#1823)
      
      * fix #1775 bug,delete process definition when process instance is running
      
      * revert CONTRIBUTING.md
      
      * dockerfile modify
      
      * dockerfile modify
      
      * dockerfile modify
      
      * remove install.sh server.servlet.context-path replace
      
      * Fix DAG add dependent project value exception # 1816 and keep requesting task interface (#1827)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * Fixed space and icon display issues before and after the input box
      
      * add license
      
      * add license
      
      * Fix data echo, style and popup cannot be closed
      
      * Fix page number loading issue and dag not getting value
      
      * Fix DAG add dependent project value exception # 1816 and keep requesting task interface
      
      * rpm package add UI (#1846)
      
      * [fix #1828] when the executor of process instance is not the owner of udf resouce, the path of the read resource file is incorrect (#1847)
      
      * fix issue 1828:get the udf resource path error when create udf function
      
      * update grantResources
      
      * first verify whether udf resource is bound by udf function
      
      * update grantResources
      
      * update testListAuthorizedUdfFunc
      
      * update getUserInfo in order to run success
      
      * add LoggerServer RPC PORT modified. #1848 (#1849)
      
      * fix #1775 bug,delete process definition when process instance is running
      
      * revert CONTRIBUTING.md
      
      * dockerfile modify
      
      * dockerfile modify
      
      * dockerfile modify
      
      * remove install.sh server.servlet.context-path replace
      
      * add LoggerServer RPC PORT modified. #1848
      
      * LoggerService Logger RPC PORT get Error modify . #1848 (#1857)
      
      * fix #1775 bug,delete process definition when process instance is running
      
      * revert CONTRIBUTING.md
      
      * dockerfile modify
      
      * dockerfile modify
      
      * dockerfile modify
      
      * remove install.sh server.servlet.context-path replace
      
      * add LoggerServer RPC PORT modified. #1848
      
      * LoggerService Logger RPC PORT get Error modify . #1848
      
      * Fix UDF function list delete data without refresh and page data display widened #1851 (#1852)
      
      * merge dev branch front-end code
      
      * fix udfs assignment
      
      * Fix task instance page jump
      
      * fix udfs assignment and task instance page jump #1789
      
      * Fixed space and icon display issues before and after the input box
      
      * add license
      
      * add license
      
      * Fix data echo, style and popup cannot be closed
      
      * Fix page number loading issue and dag not getting value
      
      * Fix DAG add dependent project value exception # 1816 and keep requesting task interface
      
      * Fix UDF function list delete data without refresh and page data display widened
      
      * [Fix #1828]check whether has permission to download udf file or delete udf function (#1858)
      
      * fix issue 1828:get the udf resource path error when create udf function
      
      * update grantResources
      
      * first verify whether udf resource is bound by udf function
      
      * update grantResources
      
      * update testListAuthorizedUdfFunc
      
      * update getUserInfo in order to run success
      
      * check whether has permission to download udf file or delete udf file
      
      * update listAuthorizedResourceById in ResourceMapper.xml
      
      * add log, don't swallow exception info (#1877)
      
      * Added hints in Resource Center (#1891)
      
      * update jackson version from 2.9.8 to 2.10.1 (#1892)
      
      * update release notes and modify the plugin of rat (#1899)
      
      * modify how to build (#1902)
      
      * update release notes and modify the plugin of rat
      
      * modify how to build
      
      * [maven-release-plugin] prepare release 1.2.1
      
      * [maven-release-plugin] prepare for next development iteration
      
      * get authorized udf resources need exclude all created by self (#1905)
      
      * get authorized udf resources need exclude all created by self
      
      * reset pom version to 1.2.1-SNAPSHOT
      
      * Update ReleaseNotes.md
      
      add detail info
      
      * Update ReleaseNotes.md
      
      * update notice year form 2019 to 2019-2020 (#1907)
      
      * [maven-release-plugin] prepare release 1.2.1
      
      * [maven-release-plugin] prepare for next development iteration
      
      * 当手动重跑历史活着补数的时候对shell和sql脚本中的[YYYYmmddd...]变量赋值与传递的日期,而不是当前日期
      Co-authored-by: Nlgcareer <18610854716@163.com>
      Co-authored-by: Nbao liang <29528966+lenboo@users.noreply.github.com>
      Co-authored-by: Nbreak60 <790061044@qq.com>
      Co-authored-by: NTboy <guo.jiwei@immomo.com>
      Co-authored-by: Nelonlo <gamelifedong@gmail.com>
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
      Co-authored-by: Nzhangchunyang <18910529250@163.com>
      Co-authored-by: Ndailidong <dailidong66@gmail.com>
      Co-authored-by: N谷雨 <lixun@guyudeMacBook-Pro.local>
      880e9956
  21. 17 3月, 2020 2 次提交
    • Q
      worker fault tolerance modify (#2212) · 055bb28d
      qiaozhanwei 提交于
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * 1, master persistent task
      2. extract  master and worker communication model
      
      * add license
      
      * modify javadoc error
      
      * TaskExecutionContext create modify
      
      * buildAckCommand taskInstanceId not set modify
      
      * java doc error modify
      
      * add comment
      
      * ExecutorManager interface add generic type
      
      * add TaskInstanceCacheManager receive Worker report result
      
      * TaskInstance setExecutePath
      
      * add TaskInstanceCacheManager to receive Worker Task result report
      
      * TaskInstanceCacheManager add remove method
      
      * add license
      
      * add dispatcht task method
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * AbstractCommandExecutor remove db access
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * taskInstanceCache is null ,need load from db
      
      * 1,worker TaskPros use TaskExecutionContext replase
      2,Master kill Task , KillTaskProcessor modify
      
      * worker remove db
      
      * ShellTask modify
      
      * master persistence processId and appIds
      
      * master persistence processId and appIds
      
      * master add kill task logic
      
      * master add kill task logic
      
      * master add kill task logic
      
      * javadoc error modify
      
      * remove chinese log
      
      * executeDirectly method add Override
      
      * remote module modify
      
      * TaskKillResponseProcessor command type modify
      
      * create buildKillCommand
      
      * host add host:port format
      
      * host add host:port format
      
      * TaskAckProcessor modify
      
      * TaskAckProcessor modify
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * task prioriry refator
      
      * remove ITaskQueue
      
      * TaskPriority refactor
      
      * remove logs
      
      * WorkerServer refactor
      
      * MasterSchedulerService modify
      
      * WorkerConfig listen port modify
      
      * modify master and worker listen port
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * cancelTaskInstance set TaskExecutionContext host,logPath,executePath
      
      * Encapsulate the parameters required by sqltask
      
      * 1,Encapsulate the parameters required by sqltask
      2,SQLTask optimization
      
      * AbstractTask modify
      
      * ProcedureTask optimization
      
      * MasterSchedulerService modify
      
      * TaskUpdateQueueConsumer modify
      
      * test
      
      * DataxTask process run debug
      
      * DataxTask process run debug
      
      * add protobuf dependency,MR、Spark task etc need this
      
      * TaskUpdateQueueConsumer modify
      
      * TaskExecutionContextBuilder set TaskInstance workgroup
      
      * WorkerGroupService queryAllGroup modify
      query available work group
      
      * 1,get workergroup from zk modify
      2,SpringConnectionFactory repeat load modify
      
      * master and worker register ip  use OSUtils.getHost()
      
      * ProcessInstance host set ip:port format
      
      * worker fault tolerance modify
      
      * Constants and .env modify
      Co-authored-by: Nqiaozhanwei <qiaozhanwei@analysys.com.cn>
      055bb28d
    • T
      Optimize PropertyUtils instantiation. (#2199) · 7dd126da
      t1mon 提交于
      * Optimize PropertyUtils instantiation.
      
      * Fix info error.
      7dd126da
  22. 16 3月, 2020 1 次提交