You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by jo...@apache.org on 2020/03/31 09:27:32 UTC

[incubator-dolphinscheduler] branch refactor-worker updated: remove zookeeper as task queue config (#2344)

This is an automated email from the ASF dual-hosted git repository.

journey pushed a commit to branch refactor-worker
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/refactor-worker by this push:
     new c9620ab  remove zookeeper as task queue config (#2344)
c9620ab is described below

commit c9620ab557ec4c8d0bef1c87c93348b238a7bd8e
Author: dailidong <da...@gmail.com>
AuthorDate: Tue Mar 31 17:27:22 2020 +0800

    remove zookeeper as task queue config (#2344)
    
    * 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: qiaozhanwei <qi...@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: Tboy <gu...@immomo.com>
    Co-authored-by: break60 <79...@qq.com>
    Co-authored-by: qiaozhanwei <qi...@outlook.com>
    Co-authored-by: qiaozhanwei <qi...@analysys.com.cn>
---
 dolphinscheduler-common/src/main/resources/common.properties | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-common/src/main/resources/common.properties b/dolphinscheduler-common/src/main/resources/common.properties
index 08e67ae..baead1b 100644
--- a/dolphinscheduler-common/src/main/resources/common.properties
+++ b/dolphinscheduler-common/src/main/resources/common.properties
@@ -16,7 +16,7 @@
 #
 
 # resource storage type : HDFS,S3,NONE
-resource.storage.type=HDFS
+resource.storage.type=NONE
 
 # resource store on HDFS/S3 path, resource file will store to this hadoop hdfs path, self configuration, please make sure the directory exists on hdfs and have read write permissions。"/dolphinscheduler" is recommended
 #resource.upload.path=/dolphinscheduler