renyupeng 3 лет назад
Родитель
Сommit
d5939ca962
1 измененных файлов с 2 добавлено и 1 удалено
  1. 2 1
      monitor/ApplicationCDCMonitor.py

+ 2 - 1
monitor/ApplicationCDCMonitor.py

@@ -37,10 +37,11 @@ class ApplicationCDCMonitor:
             if error is not None:
                 requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
                                                                self.cdc_changefeeds_url, task_id))
-                os.system(
+                status = os.system(
                     'cd /data/tidb-deploy/cdc-8300/bin; ./cdc cli changefeed create --pd=http://192.168.0.184:2379 '
                     '--sink-uri="mysql://data:hcst@2021@139.186.27.96:3390" --config ../conf/{task_id}.toml '
                     '--changefeed-id={task_id} --start-ts {tso}'.format(tso=tso, task_id=task_id))
+                print(status)
 
                 backResult = requests.get(
                     url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url, task_id),