@@ -35,6 +35,7 @@ class ApplicationCDCMonitor:
tso = json['checkpoint_tso']
error = json['error']
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(