Skip to content

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

Update alarm_flink_job.py

parent d1ef9b57
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
dags/flink/alarm_flink_job.py
View file @ 95f7e9fa
...@@ -14,7 +14,7 @@ import airflow ...@@ -14,7 +14,7 @@ import airflow
#variable parameter #variable parameter
DAG_ID = 'alarm_flink_job' DAG_ID = 'alarm_flink_job'
START_DATE = datetime.now() - timedelta(minutes=10) START_DATE = datetime.now() - timedelta(minutes=10)
SCHEDULE_INTERVAL = timedelta(minutes=10) SCHEDULE_INTERVAL = timedelta(minutes=5)
SERVICES = [ SERVICES = [
'cpc-cluster01-prod-flink-jobmanager', 'cpc-cluster01-prod-flink-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