fix

facebookincubator · Jan 2, 2025 · 108152c · 108152c
1 parent 8790f7e
commit 108152c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsFileSystemTest.cpp b/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsFileSystemTest.cpp
@@ -95,7 +95,7 @@ class HdfsFileSystemTest : public testing::Test {
 std::shared_ptr<filesystems::test::HdfsMiniCluster>
     HdfsFileSystemTest::miniCluster = nullptr;
 std::atomic<bool> HdfsFileSystemTest::startThreads = false;
-std::string HdfsFileSystemTest::fullDestinationPath_ = "";
+std::string HdfsFileSystemTest::fullDestinationPath_;
 
 void readData(ReadFile* readFile) {
   ASSERT_EQ(readFile->size(), 15 + kOneMB);
@@ -192,9 +192,7 @@ hdfsFS connectHdfsDriver(
     const std::string port) {
   filesystems::arrow::io::internal::LibHdfsShim* libhdfs_shim;
   auto status = filesystems::arrow::io::internal::ConnectLibHdfs(&libhdfs_shim);
-  if (!status.ok()) {
-    LOG(ERROR) << "ConnectLibHdfs failed ";
-  }
+  VELOX_CHECK(status.ok(), "ConnectLibHdfs failed.");
 
   // Connect to HDFS with the builder object
   hdfsBuilder* builder = libhdfs_shim->NewBuilder();

diff --git a/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.cpp b/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.cpp
@@ -94,7 +94,7 @@ void HdfsMiniCluster::addFile(std::string source, std::string destination) {
       source,
       destination);
   bool isExited =
-      filePutProcess->wait_for(std::chrono::duration<int, std::milli>(5000));
+      filePutProcess->wait_for(std::chrono::duration<int, std::milli>(15000));
   if (!isExited) {
     VELOX_FAIL(
         "Failed to add file to hdfs, exit code: {}",