| 1187 | } |
| 1188 | |
| 1189 | [[noreturn]] void ImpalaServer::LineageLoggerFlushThread() { |
| 1190 | while (true) { |
| 1191 | sleep(5); |
| 1192 | Status status = lineage_logger_->Flush(); |
| 1193 | if (!status.ok()) { |
| 1194 | LOG(ERROR) << "Error flushing lineage event log: " << status.GetDetail(); |
| 1195 | if (FLAGS_abort_on_failed_lineage_event) { |
| 1196 | CLEAN_EXIT_WITH_ERROR("Shutting down Impala Server due to " |
| 1197 | "abort_on_failed_lineage_event=true"); |
| 1198 | } |
| 1199 | } |
| 1200 | } |
| 1201 | } |
| 1202 | |
| 1203 | void ImpalaServer::ArchiveQuery(const QueryHandle& query_handle) { |
| 1204 | vector<uint8_t> compressed_profile; |