flink task support(flink 任务支持) #711

LoveEvenWong · 2019-08-18T05:08:19Z

使用方式：
步骤１：在集群中安装flink
步骤２：在.escheduler_env.sh中配置FLINK_HOME
步骤３：启动项目
步骤４：在资源中心上传flink　jar包
步骤５：创建flink项目，选择上传的jar包
步骤６：执行任务，查看结果
　　　　　　　　

davidzollo · 2019-08-18T14:31:16Z

escheduler-ui/src/js/module/i18n/locale/zh_CN.js

@@ -474,5 +474,11 @@ export default {
 'warning of timeout': '超时告警',
 'Next five execution times': '接下来五次执行时间',
 'Execute time': '执行时间',
- 'Complement range': '补数范围'
+ 'Complement range': '补数范围',
+ 'Complement range': '补数范围',


Complement range repeated 3 times ？

and en_US.js also should be updated!

davidzollo · 2019-09-01T01:02:15Z

I have a question, does this feature require a flink-related jar?

LiemLin · 2019-09-02T01:29:39Z

Can you support flink stream SQL ?

LoveEvenWong · 2019-09-17T14:03:26Z

I have a question, does this feature require a flink-related jar?
Yes, just like the spark task, you need to upload the Flink jar in resource　center and then select the jar when creating the Flink task.

LoveEvenWong · 2019-09-17T14:10:04Z

Can you support flink stream SQL ?

Sorry for not supporting yet.

* package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (#806) * issue#728 (#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][#771] The edit timer did not assign the original data * [FEATURE][#236] Cross-project dependency * [FEATURE][#236] Cross-project dependency(增加跨项目依赖) * misspell words (#817) * (Docs): Fixed some typo errors (#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (#818) * Replace StringBuffer with StringBuilder inside the method (#816) * flink task support(flink 任务支持) (#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log

* flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh

* package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (apache#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (apache#806) * issue#728 (apache#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (apache#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (apache#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][apache#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (apache#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][apache#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][apache#771] The edit timer did not assign the original data * [FEATURE][apache#236] Cross-project dependency * [FEATURE][apache#236] Cross-project dependency(增加跨项目依赖) * misspell words (apache#817) * (Docs): Fixed some typo errors (apache#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (apache#818) * Replace StringBuffer with StringBuilder inside the method (apache#816) * flink task support(flink 任务支持) (apache#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log

…873) * package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (#806) * issue#728 (#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][#771] The edit timer did not assign the original data * [FEATURE][#236] Cross-project dependency * [FEATURE][#236] Cross-project dependency(增加跨项目依赖) * misspell words (#817) * (Docs): Fixed some typo errors (#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (#818) * Replace StringBuffer with StringBuilder inside the method (#816) * flink task support(flink 任务支持) (#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log * Delete the'babel-plugin-transform-remove-console'dependency package * 1.repair [BUG]#884,2.Add Scheduling Time Fields to Workflow Instance List，3.Add a reminder for empty data

…List；3.Add a reminder for empty data (#893) * package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (#806) * issue#728 (#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][#771] The edit timer did not assign the original data * [FEATURE][#236] Cross-project dependency * [FEATURE][#236] Cross-project dependency(增加跨项目依赖) * misspell words (#817) * (Docs): Fixed some typo errors (#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (#818) * Replace StringBuffer with StringBuilder inside the method (#816) * flink task support(flink 任务支持) (#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log * Delete the'babel-plugin-transform-remove-console'dependency package * 1.repair [BUG]#884,2.Add Scheduling Time Fields to Workflow Instance List，3.Add a reminder for empty data

flink task edit flink icon and add flink local deployMode task

* pr #711 flink task edit flink icon and add flink local deployMode task * pr #711 flink task edit flink icon and add flink local deployMode task

…th Source Code (#924) * package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (#806) * issue#728 (#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][#771] The edit timer did not assign the original data * [FEATURE][#236] Cross-project dependency * [FEATURE][#236] Cross-project dependency(增加跨项目依赖) * misspell words (#817) * (Docs): Fixed some typo errors (#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (#818) * Replace StringBuffer with StringBuilder inside the method (#816) * flink task support(flink 任务支持) (#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log * Delete the'babel-plugin-transform-remove-console'dependency package * 1.repair [BUG]#884,2.Add Scheduling Time Fields to Workflow Instance List，3.Add a reminder for empty data * 1.update logo 2.Workflow Definition Page Timing Component Replaced with Source Code

* package * 修改工作流实例页面状态为运行时，禁止删除，删除package.json包里面的babel-runtime和jasmine-core * bugfix-user-specified queue takes precedence over tenant queue (#769) Solve the problem that the user queue setting does not take effect * update markdown docs which can not display images normally (#806) * issue#728 (#746) The mailSender in PasswordAuthentication() and setFrom() may not be the same in actual use, and it's best to set it up separately. please add a example about this. * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler (#812) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization (#813) * service start exception modify * master，worker start modify * .env update * install-escheduler-ui.sh,monitor_server.py and install.sh scripts comment change to english and install-escheduler-ui.sh use escheduler change to dolphinscheduler * scripts name standardization * [BUG][#731]repair swagger annotation，interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete (#764) * 增加工作流导出导入功能，前端定时器表达式的秒和分钟的默认值从*修改成0 * 修改工作流导出导入功能由excel改为json减少依赖 * [BUG][#731]repair swagger annotation ,interface path:/escheduler/projects/{projectName}/process/batch-delete and /escheduler/projects/{projectName}/process/delete * [BUG][#771] The edit timer did not assign the original data * [FEATURE][#236] Cross-project dependency * [FEATURE][#236] Cross-project dependency(增加跨项目依赖) * misspell words (#817) * (Docs): Fixed some typo errors (#811) * Update EasyScheduler Proposal.md * Update frontend-deployment.md * Update frontend-development.md * Update 前端开发文档.md * Update system-manual.md * Update HttpClientTest.java * Update 系统使用手册.md * fix singleton with volatile (#818) * Replace StringBuffer with StringBuilder inside the method (#816) * flink task support(flink 任务支持) (#711) * flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh * 1.Delete the page section console.log; 2.Change project name； 3.Production configuration packaging clears console.log * Delete the'babel-plugin-transform-remove-console'dependency package * 1.repair [BUG]#884,2.Add Scheduling Time Fields to Workflow Instance List，3.Add a reminder for empty data * 1.update logo 2.Workflow Definition Page Timing Component Replaced with Source Code * epair bug #901，#909，#935

lipanpan and others added 3 commits August 18, 2019 12:58

flink任务支持

1fcd2f1

flink任务支持

a6d6f3c

Merge branch 'dev' into dev

0a1f1df

davidzollo reviewed Aug 18, 2019

View reviewed changes

davidzollo changed the title ~~flink 任务支持~~ flink task support(flink 任务支持) Aug 18, 2019

davidzollo added the feature new feature label Aug 18, 2019

LoveEvenWong added 2 commits August 20, 2019 13:51

Update zh_CN.js

32854df

Update FlinkArgsUtils.java

86a4a75

davidzollo mentioned this pull request Sep 3, 2019

Can you increase the support of flink?(能否增加flink的支持) #514

Closed

davidzollo requested a review from qiaozhanwei September 16, 2019 11:08

Update .escheduler_env.sh

a4d921d

LoveEvenWong mentioned this pull request Sep 17, 2019

[new feature][#711] add flink support #793

Closed

qiaozhanwei merged commit 02598a7 into apache:dev Sep 19, 2019

gary0416 pushed a commit to gary0416/incubator-dolphinscheduler that referenced this pull request Sep 23, 2019

flink task support(flink 任务支持) (apache#711)

6ecfc3e

* flink任务支持 * flink任务支持 * Update zh_CN.js * Update FlinkArgsUtils.java * Update .escheduler_env.sh

LoveEvenWong added a commit to LoveEvenWong/incubator-dolphinscheduler that referenced this pull request Sep 26, 2019

pr apache#711

c240bc5

flink task edit flink icon and add flink local deployMode task

LoveEvenWong added a commit to LoveEvenWong/incubator-dolphinscheduler that referenced this pull request Sep 26, 2019

pr apache#711

99fe0e1

flink task edit flink icon and add flink local deployMode task

qiaozhanwei pushed a commit that referenced this pull request Sep 27, 2019

pr#711　flink task edit (#906)

3e3ee3d

* pr #711 flink task edit flink icon and add flink local deployMode task * pr #711 flink task edit flink icon and add flink local deployMode task

davidzollo mentioned this pull request Mar 20, 2020

[QUESTION] Which version of Flink is used in DolphinScheduler #2226

Closed

snyk-bot mentioned this pull request Apr 7, 2021

[Snyk] Security upgrade css-loader from 0.28.11 to 1.0.0 Realtime-BigData/EasyScheduler#83

Open

snyk-bot mentioned this pull request May 6, 2021

[Snyk] Security upgrade css-loader from 0.28.11 to 1.0.0 Realtime-BigData/EasyScheduler#94

Open

snyk-bot mentioned this pull request May 25, 2021

[Snyk] Fix for 1 vulnerabilities Realtime-BigData/EasyScheduler#95

Open

snyk-bot mentioned this pull request Sep 12, 2021

[Snyk] Fix for 1 vulnerabilities Realtime-BigData/EasyScheduler#112

Open

William-GuoWei mentioned this pull request May 16, 2022

[Snyk] Security upgrade css-loader from 0.28.11 to 1.0.0 Realtime-BigData/EasyScheduler#158

Open

snyk-bot mentioned this pull request Sep 29, 2022

[Snyk] Fix for 13 vulnerabilities VVeggie/incubator-dolphinscheduler#103

Open

snyk-bot mentioned this pull request Oct 7, 2022

[Snyk] Fix for 40 vulnerabilities Realtime-BigData/EasyScheduler#175

Open

terrorizer1980 mentioned this pull request Jul 1, 2023

[Snyk] Security upgrade canvg from 1.5.1 to 2.0.0 terrorizer1980/dolphinscheduler#50

Open

VVeggie mentioned this pull request Nov 26, 2023

[Snyk] Security upgrade canvg from 1.5.1 to 2.0.0 VVeggie/incubator-dolphinscheduler#145

Open

William-GuoWei mentioned this pull request Nov 27, 2023

[Snyk] Fix for 18 vulnerabilities Realtime-BigData/EasyScheduler#219

Open

choupijiang mentioned this pull request Nov 27, 2023

[Snyk] Fix for 6 vulnerabilities choupijiang/dolphinscheduler#23

Open

terrorizer1980 mentioned this pull request Nov 29, 2023

[Snyk] Fix for 6 vulnerabilities terrorizer1980/dolphinscheduler#63

Open

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

flink task support(flink 任务支持) #711

flink task support(flink 任务支持) #711

LoveEvenWong commented Aug 18, 2019 •

edited

Loading

davidzollo Aug 18, 2019

LoveEvenWong Aug 20, 2019

davidzollo commented Sep 1, 2019

LiemLin commented Sep 2, 2019

LoveEvenWong commented Sep 17, 2019 •

edited

Loading

LoveEvenWong commented Sep 17, 2019

flink task support(flink 任务支持) #711

flink task support(flink 任务支持) #711

Conversation

LoveEvenWong commented Aug 18, 2019 • edited Loading

davidzollo Aug 18, 2019

Choose a reason for hiding this comment

LoveEvenWong Aug 20, 2019

Choose a reason for hiding this comment

davidzollo commented Sep 1, 2019

LiemLin commented Sep 2, 2019

LoveEvenWong commented Sep 17, 2019 • edited Loading

LoveEvenWong commented Sep 17, 2019

LoveEvenWong commented Aug 18, 2019 •

edited

Loading

LoveEvenWong commented Sep 17, 2019 •

edited

Loading