68e4e5c4e0
add input cache for sqoop and conditions tasks ( #2118 )
...
Co-authored-by: zhukai <zhukai@ygsoft.com>
5 years ago
9fda4da70e
fix: The toolbar buttons of Dag disable bug ( #2124 )
5 years ago
712a1bc126
Limit customization file content to no more than 3000 lines( #2128 ) ( #2141 )
...
* Change DOM label
* Change name to lowercase
* Limit customization file content to no more than 3000 lines
5 years ago
84bcdc7896
Limit customization file content to no more than 3000 lines
5 years ago
290772dfaa
Modify workgroupid parameter name ( #2105 )
...
* Delete worker group management page
* Modify workgroupid parameter name
5 years ago
3186545da1
1. add input cache for datax task ( #2034 )
...
2. add cache for codemirror component, include python, shell and sql task.
5 years ago
3277b90647
Change DOM label ( #2064 )
...
* Change DOM label
* Change name to lowercase
5 years ago
b70e0aaaab
Change name to lowercase
5 years ago
28f57f87ef
Change DOM label
5 years ago
0df7c6719d
[New Feature] add conditions task #205 ( #2003 )
...
* add funtion conditions task
* update conditions tasks
* update conditions for ui
* update conditions
* update
* revert
* update
5 years ago
726706835d
Refactor worker ( #10 )
...
* Refactor worker (#2000 )
* Refactor worker (#2 )
* Refactor worker (#1993 )
* Refactor worker (#1 )
* add TaskResponseProcessor (#1983 )
* 1, master persistent task 2. extract master and worker communication model (#1992 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* TaskExecutionContext create modify (#1994 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
* add- register processor
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* buildAckCommand taskInstanceId not set modify (#2002 )
* 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 (#2004 )
* 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 (#2006 )
* 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 (#2012 )
* 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
* Refactor worker (#2018 )
* Refactor worker (#7 )
* Refactor worker (#2000 )
* Refactor worker (#2 )
* Refactor worker (#1993 )
* Refactor worker (#1 )
* add TaskResponseProcessor (#1983 )
* 1, master persistent task 2. extract master and worker communication model (#1992 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* TaskExecutionContext create modify (#1994 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
* add- register processor
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* buildAckCommand taskInstanceId not set modify (#2002 )
* 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 (#2004 )
* 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 (#2006 )
* 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 (#2012 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* Refactor worker (#8 )
* Refactor worker (#2000 )
* Refactor worker (#2 )
* Refactor worker (#1993 )
* Refactor worker (#1 )
* add TaskResponseProcessor (#1983 )
* 1, master persistent task 2. extract master and worker communication model (#1992 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* TaskExecutionContext create modify (#1994 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* updates
* add- register processor
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* buildAckCommand taskInstanceId not set modify (#2002 )
* 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 (#2004 )
* 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 (#2006 )
* 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 (#2012 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* add kill command
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
* add TaskInstanceCacheManager receive Worker report result，modify master polling db transfrom to cache (#2021 )
* 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
Co-authored-by: qiaozhanwei <qiaozhanwei@outlook.com>
5 years ago
2bb5ebaf3a
add TaskInstanceCacheManager receive Worker report result，modify master polling db transfrom to cache ( #2021 )
...
* 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
5 years ago
5f3d88e4c2
Fix bug #1986 . ( #1987 )
...
When in the projects define page, click the toolbar's button(task type) will cause the task details window switch to new one.
For now, the task details window will not switch.
5 years ago
3d6eee5d80
#203 add sqoop task ( #1974 )
...
* add sqoop task
* add sqoop task
* add sqoop task test
* add sqoop task test
* add sqoop task test
* modify add sqoop task test
* modify sqoop task test
* modify sqoop task test
* modify sqoop task test
* modify sqoop task test 2
* modify sqoop task test 3
* modify sqoop task test 3
* modify sqoop task test 3
* modify sqoop task test 4
5 years ago
34e0a663ed
Refactor dockerfile ( #1978 )
...
* Support DS to create user and group in windows environment
* Add unit test
* delete combined-server config in dolphinscheduler-daemon.sh file
* refactor dockerfile
* modify dockerfile
* modify dockerfile
5 years ago
619fb30c50
#1310 add executor user to the process instance & task instance pages ( #1973 )
...
* add executor name in processDefinitionInstance & taskInstance
* modify processInstanceTest
* modify processInstanceTest
* #1310 add executor user to the process instance & task instance pages
* add processInstanceUT & taskInstanceUT
* add processInstanceUT & taskInstanceUT
* modify processInstanceTest & taskInstanceTest
* Remove duplicate code
* add userServiceUT
5 years ago
afd5c75cd2
Fix the bug #1968 . ( #1969 )
...
When create a new task or edit an exist task.The task details window will be open.
Then if delete the task node or click the DataSource menu. And the task details window still open.
The task details window should be close.
5 years ago
29f2b41ed0
Refactor architecture ( #1926 )
...
* move version to parent pom
* move version properties to parent pom for easy management
* remove freemarker dependency
* delete CombinedApplicationServer
* #1871 correct spelling
* #1873 some updates for TaskQueueZkImpl
* #1875 remove unused properties in pom
* #1878
1. remove tomcat dependency
2. remove combined_logback.xml in api module
3. format pom.xml for not aligning
* #1885 fix api server startup failure
1. add jsp-2.1 dependency
2. remove jasper-runtime dependency
* add stringutils ut (#1921 )
* add stringutils ut
* Newfeature for #1675 . (#1908 )
Continue to finish the rest works, add the cache feature for dependence,mr,python,sub_process,procedure and shell.
* Add modify user name for process definition (#1919 )
* class overrides equals() and should therefore also override hashCode()
* #1862 add modify user in process difinition list
* #1862 add pg-1.2.2 ddl.sql
* modify ScriptRunnerTest
* add updateProessDifinition UT
* modify updateProcessDifinition UT
* modify updateProcessDifinition UT
* modify mysql 1.2.2 ddl.sql&dml.sql
* add scope test to mysql in pom
* modify pg-1.2.2 ddl.sql
* refactor module
* updates
Co-authored-by: khadgarmage <khadgar.mage@outlook.com>
Co-authored-by: zhukai <boness@qq.com>
Co-authored-by: Yelli <amarantine@my.com>
5 years ago
d937a6ae94
Add modify user name for process definition ( #1919 )
...
* class overrides equals() and should therefore also override hashCode()
* #1862 add modify user in process difinition list
* #1862 add pg-1.2.2 ddl.sql
* modify ScriptRunnerTest
* add updateProessDifinition UT
* modify updateProcessDifinition UT
* modify updateProcessDifinition UT
* modify mysql 1.2.2 ddl.sql&dml.sql
* add scope test to mysql in pom
* modify pg-1.2.2 ddl.sql
5 years ago
bcc734713b
Newfeature for #1675 . ( #1908 )
...
Continue to finish the rest works, add the cache feature for dependence,mr,python,sub_process,procedure and shell.
5 years ago
f942e5ced3
[feature] data synchronization function ( #1881 )
...
* feature：data synchronization function
* feature：data synchronization function
* feature：data synchronization function
* fix：add license
* fix：resource close bug
* fix：remove class author
* fix：Improve test coverage
* fix：add UT
* fix：add UT
* fix：data sync node renamed to datax
* fix：add UT
* fix: UT bug
* fix：Optimize variable name
* fix：pom
* fix：Variable name error
* fix：optimize the code
5 years ago
9549910fcc
Fix UDF function list delete data without refresh and page data display widened #1851 ( #1853 )
...
* fix udfs assignment and task instance page jump #1789
* jest add coverage display
* Fix data echo, style, popup cannot be closed and license
* Fix data echo, style, popup cannot be closed and license
* fix
* Requests the previous page when there is no data on the list page
* Fix DAG task nodes keep requesting API and tooltip background color modification
* Modify list tooltip theme color
* Fix UDF function list delete data without refresh and page data display widened
5 years ago
60bb2deb2a
Modify list tooltip theme color ( #1845 )
...
* fix udfs assignment and task instance page jump #1789
* jest add coverage display
* Fix data echo, style, popup cannot be closed and license
* Fix data echo, style, popup cannot be closed and license
* fix
* Requests the previous page when there is no data on the list page
* Fix DAG task nodes keep requesting API and tooltip background color modification
* Modify list tooltip theme color
5 years ago
1c77708a89
Supplementary data by schedule ( #1830 )
...
* Supplementary data by schedule
* fix sonar check bug
* fix code duplicated blocks
* ut
* loop by day
* MasterExecThread test
* test add licene
Co-authored-by: dailidong <dailidong66@gmail.com>
5 years ago
5739afb95a
Fix DAG task nodes keep requesting API and tooltip background color modification ( #1837 )
...
* fix udfs assignment and task instance page jump #1789
* jest add coverage display
* Fix data echo, style, popup cannot be closed and license
* Fix data echo, style, popup cannot be closed and license
* fix
* Requests the previous page when there is no data on the list page
* Fix DAG task nodes keep requesting API and tooltip background color modification
5 years ago
be4fa728e9
fix the bug #1816 ( #1834 )
5 years ago
d02422d030
Requests the previous page when there is no data on the list page( #1768 ) ( #1832 )
...
* fix udfs assignment and task instance page jump #1789
* jest add coverage display
* Fix data echo, style, popup cannot be closed and license
* Fix data echo, style, popup cannot be closed and license
* fix
* Requests the previous page when there is no data on the list page
5 years ago
512e7c1f6a
fix bug, add the cache logic in getInstancedetail. ( #1814 )
5 years ago
289ae6ac96
Implements the spark and flink type task, now they can be cache the previous input. ( #1795 )
5 years ago
24f362de5a
fix udfs assignment and task instance page jump #1789 ( #1792 )
...
* fix udfs assignment and task instance page jump #1789
* jest add coverage display
* Fix data echo, style, popup cannot be closed and license
* Fix data echo, style, popup cannot be closed and license
* fix
5 years ago
b6d6bb6416
Fixed some input box length restrictions and udfs not getting values #109 ( #1778 )
...
* Fix api url
* Fixed DAG zoom in and zoom out nodes separated from arrows
* Fix front-end code specifications
* Fix front-end code specifications
* Fix front-end code specifications
* jest unit test demo
* jest unit test demo
* Fix delete operation, no query interface request is made on the list page
* Fix delete operation, no query interface request is made on the list page
* Fixed some input box length restrictions and udfs not getting values
5 years ago
74a5506b9a
Fix delete operation, no query interface request is made on the list page #1768 ( #1777 )
...
* Fix api url
* Fixed DAG zoom in and zoom out nodes separated from arrows
* Fix front-end code specifications
* Fix front-end code specifications
* Fix front-end code specifications
* jest unit test demo
* jest unit test demo
* Fix delete operation, no query interface request is made on the list page
* Fix delete operation, no query interface request is made on the list page
5 years ago
03ef394399
fixbug: login interface cannot jump to home interface ( #1765 )
5 years ago
995b5ca4a1
jest unit test demo ( #1760 )
...
* Fix api url
* Fixed DAG zoom in and zoom out nodes separated from arrows
* Fix front-end code specifications
* Fix front-end code specifications
* Fix front-end code specifications
* jest unit test demo
* jest unit test demo
5 years ago
2087f464fb
Implements the sql type task, now it can be cache the previous input. ( #1745 )
5 years ago
b8fa7dac9d
Fix front-end code specifications ( #1726 )
...
* Fix api url
* Fixed DAG zoom in and zoom out nodes separated from arrows
* Fix front-end code specifications
* Fix front-end code specifications
* Fix front-end code specifications
5 years ago
d3d9619738
Fix sonarcloud analysis on merge PR ( #1707 )
...
* #1706 fix sonarcloud analysis on merge PR
* sonarcloud use cobertura report and don't run UT again; include ui source file; merge to one workflow
5 years ago
cfe174293f
Improve the user experience in the task definition page ( #1678 )
...
define the architecture (include actions.js, dag.vue,formModel.vue,mutations.js, and state.js) and implement one of the tasks , such as http.vue.
5 years ago
3477d28de8
Fixed DAG zoom in and zoom out nodes separated from arrows #1679 ( #1680 )
...
* Fix api url
* Fixed DAG zoom in and zoom out nodes separated from arrows
5 years ago
26ed786c4d
#1544 fix bug: workflow import ( #1676 )
...
* modify FileUtils.readFile2Str
* #1300 Add right alignment function in sql email content
* cancel formatted for alert_mail_template.ftl
* #747 sql task password Log desensitization
* cancel mail_temple
* edit ExcelUtils
* modify test method name
* #747 sql task password Log desensitization
* #1544 workflow import
* Constants add DATASOURCE_PASSWORD_REGEX
* #747 sql task password Log desensitization
* deal with import project have sub process
* modify export process addTaskNodeParam method name
* add testAddTaskNodeSpecialParam UT
* add ProcessDefinitionServiceTest-ut to pom
* add testImportSubProcess in ProcessDefinitionServiceTest
* add testImportSubProcess in ProcessDefinitionServiceTest
* add testImportProcessDefinition
5 years ago
22a2d43d7c
Fix api url ( #1672 )
5 years ago
426c027ddf
Click the run button to add the workflow name echo #1339 Point 11 ( #1638 )
...
* Increase script text box to zoom in and fix log loading
* Timing operation adds default value for start and end dates
* Click the run button to add the workflow name echo
5 years ago
779decc96d
Increase script text box to zoom in and fix log loading #1547 、#1247 ( #1604 )
...
* Increase script text box to zoom in and fix log loading
* Timing operation adds default value for start and end dates
5 years ago
9de928ea04
add profile nginx in order to deploy frontend ( #1599 )
...
* add profile nginx
* add dolphinscheduler-nginx.xml
5 years ago
026fdd9e1c
License Corrected Version ( #1565 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
* Script input box style fix
* console.log('Front-end third-party js, css introduced using npm
* Front-end supplemental license
* Modify naming
* Repair license
* replace cookie.js with js-cookie, add js-cookie license
* License Corrected Version
* License Corrected Version
5 years ago
b4daa85f20
replace cookie.js with js-cookie, add js-cookie license ( #1561 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
* Script input box style fix
* console.log('Front-end third-party js, css introduced using npm
* Front-end supplemental license
* Modify naming
* Repair license
* replace cookie.js with js-cookie, add js-cookie license
5 years ago
57aafc1507
Front-end supplemental license ( #1548 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
* Script input box style fix
* console.log('Front-end third-party js, css introduced using npm
* Front-end supplemental license
* Modify naming
5 years ago
6837bedce8
Front-end third-party js, css introduced using npm ( #1546 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
* Script input box style fix
* console.log('Front-end third-party js, css introduced using npm
5 years ago
15a402a3f2
Script input box style fix ( #1538 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
* Script input box style fix
5 years ago
99fc87f911
Menu arrow style fix ( #1531 )
...
* Password verification and v-for add key
* DAG automatic layout
* combo.js replacement
* combo.js replacement
* webpack upgrade to 4
* packjson has a file name that has not changed
* Solve jertty packing garbled
* Modify dashboard color
* Remove iconfont, awesome, replace with ans-ui icon
* Menu arrow style fix
5 years ago
zhukai
Rubik-W
break60
bao liang
Tboy
qiaozhanwei
孙朝和
liwenhe1993
Yelli
Tboy
魔方不在手
老佛爷
elonlo
Jave-Chen
Yelli
lgcareer