diff --git a/velox/connectors/hive/storage_adapters/abfs/AbfsFileSystem.cpp b/velox/connectors/hive/storage_adapters/abfs/AbfsFileSystem.cpp index ca4304c5890d..3afcb7091793 100644 --- a/velox/connectors/hive/storage_adapters/abfs/AbfsFileSystem.cpp +++ b/velox/connectors/hive/storage_adapters/abfs/AbfsFileSystem.cpp @@ -94,9 +94,8 @@ class AbfsReadFile::Impl { fileClient_ = BlobClientProviderFactory::getBlobClient(path_, abfsAccount); } - void initialize(const FileOptions& options) { + void initialize() { if (eTag_.empty() || length_ == -1) { - try { VLOG(1) << "Fetching properties from remote file system for " << path_; auto properties = fileClient_->GetProperties(); diff --git a/velox/connectors/hive/storage_adapters/abfs/tests/AbfsFileSystemTest.cpp b/velox/connectors/hive/storage_adapters/abfs/tests/AbfsFileSystemTest.cpp index e317d76ee264..96118ff1c959 100644 --- a/velox/connectors/hive/storage_adapters/abfs/tests/AbfsFileSystemTest.cpp +++ b/velox/connectors/hive/storage_adapters/abfs/tests/AbfsFileSystemTest.cpp @@ -73,7 +73,7 @@ class AbfsFileSystemTest : public testing::Test { azuriteServer = std::make_shared(port); azuriteServer->start(); auto tempFile = createFile(); - azuriteServer->addFile(tempFile->path, filePath); + azuriteServer->addFile(tempFile->getPath(), filePath); auto connectionStringProvider = std::make_shared( facebook::velox::filesystems::test::AzuriteAccountName, diff --git a/velox/connectors/hive/storage_adapters/abfs/tests/VegasFileSystemTest.cpp b/velox/connectors/hive/storage_adapters/abfs/tests/VegasFileSystemTest.cpp index 633188ce8920..39a2d9451b4d 100644 --- a/velox/connectors/hive/storage_adapters/abfs/tests/VegasFileSystemTest.cpp +++ b/velox/connectors/hive/storage_adapters/abfs/tests/VegasFileSystemTest.cpp @@ -78,7 +78,7 @@ class VegasFileSystemTest : public testing::Test { static_cast(stoi(port_))); azuriteServer_->start(); auto tempFile = createFile(); - azuriteServer_->addFile(tempFile->path, filePath); + azuriteServer_->addFile(tempFile->getPath(), filePath); auto connectionStringProvider = std::make_shared( facebook::velox::filesystems::test::AzuriteAccountName, @@ -209,7 +209,7 @@ TEST_F(VegasFileSystemTest, readFileWithPartialOverlaps) { const std::string fullPath = facebook::velox::filesystems::test::AzuriteABFSEndpoint + path; auto tempFile = VegasFileSystemTest::createFile(); - azuriteServer_->addFile(tempFile->path, path); + azuriteServer_->addFile(tempFile->getPath(), path); auto config = VegasFileSystemTest::hiveConfig(); auto abfs = filesystems::getFileSystem(fullPath, config); @@ -307,7 +307,7 @@ TEST_F(VegasFileSystemTest, readFileWithJournalDelete) { const std::string fullPath = facebook::velox::filesystems::test::AzuriteABFSEndpoint + path; auto tempFile = VegasFileSystemTest::createFile(); - azuriteServer_->addFile(tempFile->path, path); + azuriteServer_->addFile(tempFile->getPath(), path); auto config = VegasFileSystemTest::hiveConfig(); auto abfs = filesystems::getFileSystem(fullPath, config); @@ -338,7 +338,7 @@ TEST_F(VegasFileSystemTest, readFileWithMapDelete) { const std::string fullPath = facebook::velox::filesystems::test::AzuriteABFSEndpoint + path; auto tempFile = VegasFileSystemTest::createFile(); - azuriteServer_->addFile(tempFile->path, path); + azuriteServer_->addFile(tempFile->getPath(), path); auto config = VegasFileSystemTest::hiveConfig(); auto abfs = filesystems::getFileSystem(fullPath, config); @@ -371,7 +371,7 @@ TEST_F(VegasFileSystemTest, readFileSemaphoreAlreadyExists) { const std::string fullPath = facebook::velox::filesystems::test::AzuriteABFSEndpoint + path; auto tempFile = VegasFileSystemTest::createFile(); - azuriteServer_->addFile(tempFile->path, path); + azuriteServer_->addFile(tempFile->getPath(), path); unsigned char md5output[MD5_DIGEST_LENGTH]; MD5(reinterpret_cast(fullPath.c_str()), diff --git a/velox/experimental/wave/common/tests/BlockTest.cpp b/velox/experimental/wave/common/tests/BlockTest.cpp index 03c902ae6997..4723f721da25 100644 --- a/velox/experimental/wave/common/tests/BlockTest.cpp +++ b/velox/experimental/wave/common/tests/BlockTest.cpp @@ -155,8 +155,8 @@ class BlockTest : public testing::Test { } stream.wait(); elapsed = getCurrentTimeMicro() - startMicros; - std::cout << "Flags " << (use256 ? "256" : "") - << " to indices: " << " to indices no smem: " << elapsed << "us, " + std::cout << "Flags " << (use256 ? "256" : "") << " to indices: " + << " to indices no smem: " << elapsed << "us, " << kNumFlags / static_cast(elapsed) << " Mrows/s" << std::endl; }