(self, cursor, report)
| 271 | increment(self._metrics[NUM_QUERIES_CANCELLED]) |
| 272 | |
| 273 | def _cancel(self, cursor, report): |
| 274 | if not report.query_id: |
| 275 | return |
| 276 | |
| 277 | try: |
| 278 | LOG.debug("Attempting cancellation of query with id %s", report.query_id) |
| 279 | cursor.cancel_operation() |
| 280 | LOG.debug("Sent cancellation request for query with id %s", report.query_id) |
| 281 | except Exception as e: |
| 282 | LOG.debug("Error cancelling query with id %s: %s", report.query_id, e) |
| 283 | try: |
| 284 | LOG.debug("Attempting to cancel query through the web server.") |
| 285 | self.impalad.cancel_query(report.query_id) |
| 286 | except Exception as e: |
| 287 | LOG.debug("Error cancelling query %s through the web server: %s", |
| 288 | report.query_id, e) |
| 289 | |
| 290 | def _check_for_memory_errors(self, report, cursor, caught_exception): |
| 291 | """To be called after a query failure to check for signs of failed due to a |
no test coverage detected