renyupeng 3 lat temu
rodzic
commit
c851c19428
1 zmienionych plików z 2 dodań i 0 usunięć
  1. 2 0
      monitor/ApplicationCDCMonitor.py

+ 2 - 0
monitor/ApplicationCDCMonitor.py

@@ -36,6 +36,8 @@ class ApplicationCDCMonitor:
             for errtask in errtasks:
             for errtask in errtasks:
                 errtask_id = errtask['id']
                 errtask_id = errtask['id']
                 print(errtask, '-----error--------')
                 print(errtask, '-----error--------')
+                requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
+                                                               self.cdc_changefeeds_url, errtask_id))
                 os.system(
                 os.system(
                     'cd /data/tidb-deploy/cdc-8300/bin; ./cdc cli changefeed create --pd=http://192.168.0.184:2379 '
                     '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 '
                     '--sink-uri="mysql://data:hcst@2021@139.186.27.96:3390" --config ../conf/{task_id}.toml '