tmp

JkSelf · Sep 29, 2024 · 44a5d5f · 44a5d5f
1 parent 4cbdc28
commit 44a5d5f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 7 deletions.
diff --git a/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.cpp b/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.cpp
@@ -30,7 +30,7 @@ void HdfsMiniCluster::start() {
         httpPortOption,
         httpPort_,
         nameNodePortOption,
-        nameNodePort,
+        nameNodePort_,
         configurationOption,
         turnOffPermissions);
     serverProcess_->wait_for(std::chrono::duration<int, std::milli>(60000));

diff --git a/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.h b/velox/connectors/hive/storage_adapters/hdfs/tests/HdfsMiniCluster.h
@@ -32,7 +32,6 @@ static const std::string noMapReduceOption{"-nomr"};
 static const std::string formatNameNodeOption{"-format"};
 static const std::string httpPortOption{"-nnhttpport"};
 static const std::string nameNodePortOption{"-nnport"};
-static const std::string nameNodePort{"7878"};
 static const std::string configurationOption{"-D"};
 static const std::string turnOffPermissions{"dfs.permissions=false"};
 static const std::string filesystemCommand{"fs"};

diff --git a/velox/connectors/hive/storage_adapters/hdfs/tests/InsertIntoHdfsTest.cpp b/velox/connectors/hive/storage_adapters/hdfs/tests/InsertIntoHdfsTest.cpp
@@ -39,12 +39,10 @@ class InsertIntoHdfsTest : public HiveConnectorTestBase {
   void SetUp() override {
     HiveConnectorTestBase::SetUp();
     if (miniCluster == nullptr) {
-      auto httpPort = getFreePort();
-      nameNodePort = std::to_string(getFreePort());
-      std::cout << "the httpPort is " << httpPort << " the nameNode port is "
-                << nameNodePort << "\n";
+      auto ports = facebook::velox::exec::test::getFreePorts(2);
+      nameNodePort = std::to_string(ports[0]);
       miniCluster = std::make_shared<filesystems::test::HdfsMiniCluster>(
-          std::to_string(httpPort), nameNodePort);
+          std::to_string(ports[1]), nameNodePort);
       miniCluster->start();
     }
   }