Tboy
0febd9530c
Refactor worker ( #2115 )
...
* refactor worker registry
* refactor master server
5 years ago
Technoboy-
a4c2dfa311
refactor master server
5 years ago
Tboy
c3293887fa
Merge pull request #23 from apache/refactor-worker
...
refactor worker registry (#2107 )
5 years ago
Tboy
d617f9df32
refactor worker registry ( #2107 )
5 years ago
gabry.wu
0e1dd8d7d9
remove incorrect or unnecessary URL tag ( #2099 )
5 years ago
Technoboy-
76fd384a2e
refactor worker registry
5 years ago
Tboy
a51f3ea7c7
Merge pull request #22 from apache/refactor-worker
...
Refactor worker
5 years ago
Tboy
5c621009b5
Merge branch 'refactor-worker' into refactor-worker
5 years ago
qiaozhanwei
043df7e189
WorkerServer refactor ( #2106 )
...
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@analysys.com.cn>
5 years ago
Tboy
4eebde8355
Refactor worker ( #2103 )
...
* refactor kill logic
* refactor ExecutionContext
* refactor worker
5 years ago
Technoboy-
aeb8b852e7
refactor worker
5 years ago
Tboy
b42357a16d
Merge pull request #21 from apache/refactor-worker
...
TaskPriority refactor (#2097 )
5 years ago
qiaozhanwei
eb45ff9e83
TaskPriority refactor ( #2097 )
...
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@analysys.com.cn>
5 years ago
dailidong
4bb97dfb8b
fix actions/checkout@v2 problem ( #2095 )
5 years ago
dailidong
6070738acb
Support worker server to run bat script ( #2023 )
...
* Support worker server to run bat script
1. Reimplement ProcessImpl.java, ProcessEnvironment.java and ProcessBuilder.java for Windows
2. Modify shell task code for windows
3. Add ASF License
* Add Unit Test
5 years ago
dailidong
1f92b4c4db
Optimize ParameterUtils.curingGlobalParams() execution efficiency ( #2090 )
...
* Optimize ParameterUtils.curingGlobalParams() execution efficiency
* Remove excess null check
5 years ago
Tboy
9964cf9057
Merge pull request #20 from apache/refactor-worker
...
task prioriry refator (#2094 )
5 years ago
Tboy
7ed28af4fe
Upgrade curator version ( #2083 )
...
* upgrade curator version
issue: https://github.com/apache/incubator-dolphinscheduler/issues/2020
curator issue: https://github.com/apache/curator/pull/297
* add DefaultEnsembleProvider override
* add some unit test
* add License
5 years ago
qiaozhanwei
8aaee39aa2
task prioriry refator ( #2094 )
...
* 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
5 years ago
dailidong
4230d5a737
add embedded database h2 and update embedded zookeeper ( #2082 )
...
add embedded database h2 and update embedded zookeeper
5 years ago
dailidong
6ec85540bf
fix typo ( #2093 )
5 years ago
Jave-Chen
d33b883420
Merge pull request #2085 from khadgarmage/ci-action-alter
...
action push delete
5 years ago
xiaochun.liu
18d7ff274b
action push delete
5 years ago
qiaozhanwei
d5c795bd45
fix ugly logger usage ( #2063 )
...
* fix ugly logger usage
* remove space
5 years ago
qiaozhanwei
3e5a939913
delete unused import ( #2066 )
5 years ago
qiaozhanwei
b8014d91cf
add workflow id, name for email content ( #2071 )
...
* add tenantService UT
* fix spell
* #464 email content
* modify mysql1.2.2 ddl
5 years ago
Tboy
1d4bf420b0
Merge pull request #19 from apache/refactor-worker
...
Refactor worker (#2081 )
5 years ago
Tboy
15bf740221
Refactor worker ( #2081 )
...
* refactor kill logic
* refactor ExecutionContext
5 years ago
Technoboy-
09173e8d23
refactor ExecutionContext
5 years ago
Tboy
b0f9cd720b
Merge pull request #18 from apache/refactor-worker
...
Refactor worker
5 years ago
zhukai
3186545da1
1. add input cache for datax task ( #2034 )
...
2. add cache for codemirror component, include python, shell and sql task.
5 years ago
qiaozhanwei
72e8f8d195
host add host:port format ( #2070 )
...
* 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
5 years ago
qiaozhanwei
b52542f250
master kill task refactor ( #2069 )
...
* 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
5 years ago
break60
3277b90647
Change DOM label ( #2064 )
...
* Change DOM label
* Change name to lowercase
5 years ago
break60
b70e0aaaab
Change name to lowercase
5 years ago
break60
28f57f87ef
Change DOM label
5 years ago
Tboy
fbf05de39b
delete duplicate startLocalZkServer ( #2062 )
5 years ago
Tboy
b17d0310a5
Merge pull request #16 from apache/refactor-worker
...
refactor kill logic (#2060 )
5 years ago
Tboy
71c11bd594
refactor kill logic ( #2060 )
5 years ago
Technoboy-
b4e4a64e50
refactor kill logic
5 years ago
Tboy
189506c642
Merge pull request #15 from apache/refactor-worker
...
Refactor worker
5 years ago
Tboy
4d64ef091a
Merge branch 'refactor-worker' into refactor-worker
5 years ago
qiaozhanwei
bb3885cfe2
master add kill task logic ( #2058 )
...
* 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
5 years ago
Jave-Chen
46f46ed795
Merge pull request #2055 from Jave-Chen/bcai-dev-fix-bug-20200302-2051
...
remove submodules for checkout v2
5 years ago
bcai
8b894de3d2
remove submodules for checkout v2
5 years ago
samz406
7577fab411
Merge pull request #2053 from Jave-Chen/bcai-dev-fix-bug-20200302-2051
...
Fix github action rerun failed
5 years ago
bcai
3d4acbc012
fix github action rerun failed #2052
5 years ago
samz406
099fc640f9
Merge pull request #2050 from khadgarmage/ci-action-yml
...
modify action build
5 years ago
xiaochun.liu
c9c4402cb6
modify action build
5 years ago
Rubik
1ea48375f4
Fixbug i18n #2008 ( #2035 )
...
* fix:add chinese message
* fix:add chinese message
* fix:'getLocale()' can return not null
* fix:optimize message content
5 years ago