| 558 | } |
| 559 | |
| 560 | Status ExecEnv::InitHadoopConfig() { |
| 561 | if (frontend_ != nullptr) { |
| 562 | // Get the fs.defaultFS value set in core-site.xml and assign it to |
| 563 | // configured_defaultFs |
| 564 | TGetHadoopConfigRequest config_request; |
| 565 | config_request.__set_name(DEFAULT_FS); |
| 566 | TGetHadoopConfigResponse config_response; |
| 567 | RETURN_IF_ERROR(frontend_->GetHadoopConfig(config_request, &config_response)); |
| 568 | if (config_response.__isset.value) { |
| 569 | default_fs_ = config_response.value; |
| 570 | } else { |
| 571 | default_fs_ = "hdfs://"; |
| 572 | } |
| 573 | } |
| 574 | return Status::OK(); |
| 575 | } |
| 576 | |
| 577 | Status ExecEnv::StartStatestoreSubscriberService() { |
| 578 | LOG(INFO) << "Starting statestore subscriber service"; |