|
@@ -29,13 +29,14 @@ class ApplicationCDCMonitor:
|
|
|
repo = requests.get(url='http://{}:{}{}?'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
|
|
|
headers=headers)
|
|
|
message = repo.json()
|
|
|
- # print(message)
|
|
|
+ print(message)
|
|
|
for json in message:
|
|
|
task_id = json['id']
|
|
|
tso = json['checkpoint_tso']
|
|
|
error = json['error']
|
|
|
+ print(error,'-----',task_id)
|
|
|
if error is not None:
|
|
|
- print(error)
|
|
|
+
|
|
|
requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
|
|
|
self.cdc_changefeeds_url, task_id))
|
|
|
status = os.system(
|