原型图-Scalable前端页面
2024-11-20 16:31:37 0 举报1111
作者其他创作
大纲/内容
第
query
Period：
Sink Type:
*Status:
Flink Job Name：
页面接口：（1）查询接口（2）新增/修改主任务接口（3）删除主任务（4）新增/修改子任务（5）删除子任务
COMPLETED
Template Codes:
Show Status:
Execution :
* Time Zone:
Effective
Exec Status：
[{\"biz_type\":\"mid_spark_exec_task\
INIT
confirm
下一页
主任务调度自定义重跑
data/...
*sort：
Country of Trade：
Entry Date：
60
Flow Code：
cancel
Extract
ID
Sub Task Name
Sub Task Type
Flink Job Name
Extract Table_Names
Data Business Type
Exec Level
Market
Time Zone
Biz Type
status
Exec SQL
createTime
updateTime
Actions
1
SOD_COMPARE_EXT169_EXTRACT
scalable-job-sod-margin
pt_account.t_account ...
sod_margin
sod-margin
US
America/New_York
EXT169
Enable
select * from Copy
2024-11-01 12:00:00
2024-07-01 12:00:00
2
SOD_COMPARE_EXT169_ODS
select * from Copy
Delete
Data Business Type：
Other:
页
Alarm Business Type：
Edit
Spark Param Extra：
Owners：
1024
Order No:
mid_spark_exec_task
0.5
Start Date:
Dependency:
SOD_COMPARE_EXT169
Run Time：
omni-job-pt-purchase-sales-us
https://pre-office.webullbroker.com/office/omni/dp/scalableTask/record
注意：（1）Copy 表示需要该表格栏内容较长，需要使用查看详情的样式，并能copy（2）... 表示需要同样使用查看详情的样式，不需要copy
上一页
Add
Notification:
JP_MONTHLY_STATEMENT
Set Plan
*Single taskManager slots：
*Flow Type：
Task Name：
Delay Time(minutes):
*Sub Type：
Config Business Type：
Job Type: EXTRACT 和 MID_ADSCalendar Meta Code:使用接口查询后进行选择注意：当Job Type为 EXTRACT 时，jobKey对应的label使用Flink Job Name，当JobType为MID_ADS时，jobKey对应的label为Sub Type
Exec Status:
Based Date：
Pre Condition：
Exec SQL：
2048
Business Code：
4
*Flink Job Name：
Market：
Alarm Receivers：
Template
Extra Key：
Task Name
Exec Date
Exec Stage
Exec Status
Fail Time
Fail Reason
Step Run Begin Time
Step State
updateBy
1234
2024-11-01
2024-11-01 12:57:00
... Copy
-
IDLE
shenke
0.1
JP
SOD_COMPARE_EXT1
2024-11-10
Biz Code
Status
Period
sod
Effective
Daily
*Calendar Meta Code：
*Sub Task Type：
Rerun
Alarm
entry_date
*TaskManager Memory Limit：
Sub Task Type: span style=\"font-size:inherit;\
add
Fail Reason：
status:
2024-11-01 12:50:00
us_default
Day
{hiveOdsDatabase}.ods_biz_inspect_ext169_di
Code：
{interact.extra.interact_id}
*Mutex Key：
Calculate:
*JobManager Memory Limit：
Implement:字段最好能直接从父任务带过来
Dependency Business
Exec status
Exec Id
Config Date
Version
Target Table Name
Csv path
Sink Condition
pt_account.t_account...
RUNNING
Q2HQS1RKA00S7515VGE4NILDDB
last_trading_date
pt_ods_uat_us.ods_biz_inspect_ext981_di
{\"path\":\"omni/{yyyy}...COPY
and biz_type='biz_ac... COPY
FAIL
...
DMHUGLJ1CJULA5NSG4DDCQ6E58
Exec Stage：
UNIVERSAL
2024-10-01
*Business Type：
*JobManager Memory Request：
*Plan Type：
Pre Condition 和 Plan的编辑逻辑复杂，需要另开弹框页面实现，参照Report Config-->Set export template --> File Columns
Implement:
OK
UnitCode: span style=\"font-size:inherit;\
Unit Code：
*Job Name：
Run Args：
Sink:
Exec Stage:
Y
MID_ADS
Detail
Set Pre Condition
Interact Id:
{\"biz_id\
Spark Param Tpl:
Template Codes：多选框，内容由后端接口提供
CROSS_LEVEL
Task Name：：
Code
Flow Type
Business Type
Mutex Key
Call Entry
Pre Condition
Plan
Default Base Date
Based Date
Interact ID
JP_MONTHLY_STATEMENT_GENERATE_ADVANCE
NPL
[{\"job\":... COPY
{\"type\":\"CR.... COPY
Business Type：
Flink Config 配置修改，点击 Edit 按钮弹出
Invalid
多选框
*JobManager Cpu Limit：
Extract Table Name：
Flow Type：
Plan Id
Type
Entry Date
Exec Type
Source Database Name
Source Table Name
Stage
Sort
On Off
Elapsed Time
dwd_tra_exchange_order_mf
ON
FINISHED
362
GENERAL_ADS
ads_ledger_report_df
Add Sub
.......
Stage Retry Total：
*Job Type：
Notify Type：
Business Date：
save
*Sub Task Name：
select * from ...
https://pre-office.webullbroker.com/office/omni/dp/jobFlow/taskExecRecord
Task Config Type：
{endDate.prev_0_month_last_trade_day}
Exec Level:
20
Plan：
Name
Flow Code
Start Date
End Date
Date Type
Schedule UK
ON OFF
Trigger Time
Trigger Req Id
interact
Default Based Date
Interact Param Json
Interact Id
ipo_refund_center
ipo_refund
2024-10-28
2024-11-03
Natural
1790
1049733017030234112
{\"test\":... COPY
2024-11-05
Analysis:
Target Table Name：
Job Flow Config Plan 内容修改
and biz_type='EXT169'
omni_4g1c_4c
Task Config Name：
*Business Type:
https://pre-office.webullbroker.com/office/omni/dp/jobFlow/reqInfo
Is Notified:
Currency：
Csv Path：
*TaskManager Cpu Limit：
Custom Run
100
Asia/Tokyo
*Task Name：
https://pre-office.webullbroker.com/office/omni/dp/scalableTask/check
Name：
*Code：
Fail Time:
ES
EX
*TaskManager Cpu Request：
Execute Date
Unit Code
Country Of Trade
Business Date
Dag Date
Extra Key
Remark
Create Time
Update Time
rollday_finished
Futures
US-FUTURE-TD0
genearte :
页面接口：（1）查询接口（2）详情接口（3）重跑接口/自定义重跑接口
omni-pt-dataplatform-test-flink
Exec Date：
0
STOCKS
子任务配置，点击Add Sub 按钮后弹出
Custom Rerun
*stage：
Task Name:搜索框，输入后使用接口进行模糊搜索
shenke_18888888888
End Date:
*date：
*Timezone：
TEST_TEMPLATE
version:
页面接口：（1）查询接口（2）添加接口
*Call Entry：
Data Business Type:
Effective
Step State：
JPY
https://pre-office.webullbroker.com/office/omni/dp/scalableTask/config
Param：
Param
GPL
Extract:
config Date:
EXTRACT
Origin
* Task Config Id：
Wait Over Time(minutes):
*TaskManager Memory Request：
*JobManager Cpu Request：
Biz Code：
1.0
*Country Code：
* Market：
https://pre-office.webullbroker.com/office/omni/dp/jobFlow/config
*Parallelism：
Job Flow Config 配置修改/新增，点击 Edit 按钮弹出
Job Flow Config Pre Condition配置修改
Sink Condition:
Default Based Date：
GNL
收藏
0 条评论
下一页
