Skip to content

Commit 026c385

Browse files
committed
fix
1 parent a938519 commit 026c385

1 file changed

Lines changed: 0 additions & 4 deletions

File tree

src/paimon/core/operation/file_store_commit_impl_test.cpp

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -401,7 +401,6 @@ TEST_F(FileStoreCommitImplTest, TestCommitWithConflictSnapshotAndRetryTenTimes)
401401
.Finish());
402402

403403
ASSERT_OK_AND_ASSIGN(auto commit, FileStoreCommit::Create(std::move(commit_context)));
404-
auto commit_impl = dynamic_cast<FileStoreCommitImpl*>(commit.get());
405404
std::string latest_hint = PathUtil::JoinPath(table_path, "snapshot/LATEST");
406405

407406
auto* mock_fs = dynamic_cast<GmockFileSystem*>(fs.get());
@@ -442,7 +441,6 @@ TEST_F(FileStoreCommitImplTest, TestCommitWithConflictSnapshotAndRetryOnce) {
442441
.Finish());
443442

444443
ASSERT_OK_AND_ASSIGN(auto commit, FileStoreCommit::Create(std::move(commit_context)));
445-
auto commit_impl = dynamic_cast<FileStoreCommitImpl*>(commit.get());
446444
std::string latest_hint = PathUtil::JoinPath(table_path, "snapshot/LATEST");
447445
auto* mock_fs = dynamic_cast<GmockFileSystem*>(fs.get());
448446
EXPECT_CALL(*mock_fs, ReadFile(testing::StrEq(latest_hint), testing::_))
@@ -504,7 +502,6 @@ TEST_F(FileStoreCommitImplTest, TestCommitWithAtomicWriteSnapshotTimeoutAndActua
504502

505503
ASSERT_OK_AND_ASSIGN(auto commit, FileStoreCommit::Create(std::move(commit_context)));
506504
std::string new_snapshot_6 = PathUtil::JoinPath(table_path, "snapshot/snapshot-6");
507-
auto commit_impl = dynamic_cast<FileStoreCommitImpl*>(commit.get());
508505
auto* mock_fs = dynamic_cast<GmockFileSystem*>(fs.get());
509506
EXPECT_CALL(*mock_fs, AtomicStore(testing::StrEq(new_snapshot_6), testing::_))
510507
.WillOnce(testing::Invoke([&](const std::string& path, const std::string& content) {
@@ -534,7 +531,6 @@ TEST_F(FileStoreCommitImplTest, TestCommitWithAtomicWriteSnapshotTimeoutAndActua
534531
ASSERT_OK_AND_ASSIGN(auto commit_2, FileStoreCommit::Create(std::move(commit_context_2)));
535532
ASSERT_OK_AND_ASSIGN(int32_t num_committed, commit_2->FilterAndCommit({{1, msgs}}));
536533
ASSERT_EQ(0, num_committed);
537-
auto commit_impl_2 = dynamic_cast<FileStoreCommitImpl*>(commit_2.get());
538534
std::string new_snapshot_7 = PathUtil::JoinPath(table_path, "snapshot/snapshot-7");
539535
EXPECT_CALL(*mock_fs, AtomicStore(testing::StrEq(new_snapshot_7), testing::_))
540536
.WillOnce(testing::Invoke([&](const std::string& path, const std::string& content) {

0 commit comments

Comments
 (0)