Skip to content

A
airflow-dags-hub
Commit 70c9613c authored by 唐香港's avatar 唐香港
Browse files
Options

Update alarm_flink_job.py

parent 9f3b9480
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 2 deletions
dags/flink/alarm_flink_job.py
View file @ 70c9613c
...@@ -17,8 +17,7 @@ START_DATE = datetime.now() - timedelta(minutes=30) ...@@ -17,8 +17,7 @@ START_DATE = datetime.now() - timedelta(minutes=30)
SCHEDULE_INTERVAL = timedelta(minutes=15) SCHEDULE_INTERVAL = timedelta(minutes=15)
SERVICES = [ SERVICES = [
'mv-cluster9002-test-flin-jobmanager', 'cpc-cluster9002-test-fli-jobmanager',
'cpc-cluster9001-test-fli-jobmanager',
'mv-cluster9003-test-flin-jobmanager', 'mv-cluster9003-test-flin-jobmanager',
'mv-cluster9005-test-flin-jobmanager' 'mv-cluster9005-test-flin-jobmanager'
] ]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment