| 130 | } |
| 131 | |
| 132 | Status HdfsScanNodeMt::CreateAndOpenScanner(HdfsPartitionDescriptor* partition, |
| 133 | ScannerContext* context, scoped_ptr<HdfsScanner>* scanner) { |
| 134 | Status status = CreateAndOpenScannerHelper(partition, context, scanner); |
| 135 | if (!status.ok() && scanner->get() != nullptr) { |
| 136 | scanner->get()->Close(nullptr); |
| 137 | scanner->reset(); |
| 138 | } |
| 139 | return status; |
| 140 | } |
| 141 | |
| 142 | void HdfsScanNodeMt::Close(RuntimeState* state) { |
| 143 | if (is_closed()) return; |