renyupeng 3 年 前
コミット
ccb913ddc2
1 ファイル変更1 行追加1 行削除
  1. 1 1
      monitor/ApplicationCDCMonitor.py

+ 1 - 1
monitor/ApplicationCDCMonitor.py

@@ -69,7 +69,7 @@ class ApplicationCDCMonitor:
                         '--sink-uri="mysql://data:hcst@2021@139.186.27.96:3390" --config ../conf/{task_id}.toml '
                         '--changefeed-id={task_id} '.format(task_id=task_id))
                 else:
-                    if back['error'] is not None:
+                    if back['error_msg'] is not None:
                         requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
                                                                        self.cdc_changefeeds_url, task_id))
                         os.system(