| 746 | } |
| 747 | |
| 748 | Status ImpalaServer::InitLineageLogging() { |
| 749 | if (!IsLineageLoggingEnabled()) { |
| 750 | LOG(INFO) << "Lineage logging is disabled"; |
| 751 | return Status::OK(); |
| 752 | } |
| 753 | lineage_logger_.reset(new SimpleLogger(FLAGS_lineage_event_log_dir, |
| 754 | LINEAGE_LOG_FILE_PREFIX, FLAGS_max_lineage_log_file_size)); |
| 755 | RETURN_IF_ERROR(lineage_logger_->Init()); |
| 756 | RETURN_IF_ERROR(Thread::Create("impala-server", "lineage-log-flush", |
| 757 | &ImpalaServer::LineageLoggerFlushThread, this, &lineage_logger_flush_thread_)); |
| 758 | return Status::OK(); |
| 759 | } |
| 760 | |
| 761 | bool ImpalaServer::IsAuditEventLoggingEnabled() { |
| 762 | return !FLAGS_audit_event_log_dir.empty(); |