- 29 6月, 2020 40 次提交
-
-
由 zhangchunyang 提交于
* In the dev branch, in order to the RPM package which is printed under the dist module contain configuration files: master.properties, worker.properties * Restore files deleted by mistake Co-authored-by: Nzhangchunyang <zhangchunyang@analysys.com.cn> Co-authored-by: Nqiaozhanwei <qiaozhanwei@outlook.com>
-
由 break60 提交于
-
由 Rubik-W 提交于
-
由 songgg 提交于
* sqlTask failed to run * prevent repeated database updates * prevent repeated database updates * prevent repeated database updates Co-authored-by: Nsongqh <songquanhe@foxmail.com> Co-authored-by: Ndailidong <dailidong66@gmail.com>
-
由 break60 提交于
-
由 xingchun-chen 提交于
* add LoginTest license * Delete useless packages * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * e2e add project and workflow case * Update worker_group_id to worker_group in init.sql * Update worker_group_id to worker_group in init.sql * Update worker_group_id to worker_group Co-authored-by:chenxingchun <438044805@qq.com>
-
由 break60 提交于
-
由 break60 提交于
-
由 break60 提交于
Change the name of the shell node and modify the parameter transmission method of spark, mr, python, and flink nodes
-
由 break60 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 liwenhe1993 提交于
* Remove .helmignore file * Exclude .mvn/jvm.config and .mvn/wrapper/maven-wrapper.properties When running rat, exclude .mvn/jvm.config and .mvn/wrapper/maven-wrapper.properties
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 qiaozhanwei 提交于
-
由 liwenhe1993 提交于
* Remove .helmignore file * Refactor dockerfile
-
由 Zonglei Dong 提交于
* add maven-wrapper support. * fixes maven build command to maven-wrapper. Co-authored-by: Ndailidong <dailidong66@gmail.com> -
由 BoYiZhang 提交于
* Remove invalid code * fix document errors Co-authored-by: Nzhanglong <zhanglong@ysstech.com> Co-authored-by: Ndailidong <dailidong66@gmail.com>
-
由 qiaozhanwei 提交于
-
由 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 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>
-
由 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> -
由 Tboy 提交于
* let quartz use the same datasource * move master/worker config from dao.properties to each config add master/worker registry test * move mybatis config from application.properties to SpringConnectionFactory * move mybatis-plus config from application.properties to SpringConnectionFactory * refactor TaskCallbackService * add ZookeeperNodeManagerTest
-
由 Tboy 提交于
* let quartz use the same datasource * move master/worker config from dao.properties to each config add master/worker registry test
-
由 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
-
由 qiaozhanwei 提交于
-
由 songgg 提交于
* sqlTask failed to run * remove duplicate code * remove duplicate code * remove duplicate code * remove duplicate code * remove duplicate code Co-authored-by: Nsongqh <songquanhe@foxmail.com> -
由 itbasketplayer 提交于
.gitignore remove taskInstance/index.vue(#2300) and no need to findProcessDefineById 2 times(#2373) (#2374) * some optimization * revert * ProcessDefinitionService#updateProcessDefinition findProcessDefineById 1 time
-
由 _和 提交于
* fix workflow dependent bug * fix workflow dependent bug 2 * fix workflow dependent bug 2 Co-authored-by: Nsunchaohe <sunzhaohe@linklogis.com> Co-authored-by: Ndailidong <dailidong66@gmail.com>
-
由 break60 提交于
-
由 break60 提交于
-
由 break60 提交于
-
由 break60 提交于
-
由 break60 提交于
-
由 lgcareer 提交于
Co-authored-by: Ndailidong <dailidong66@gmail.com> -
由 Rubik-W 提交于
Co-authored-by: Ndailidong <dailidong66@gmail.com>
-