Skip to content

Commit ee00ebb

Browse files
committed
remove kind of dead code
1 parent 63c48ce commit ee00ebb

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

src/Storages/StorageReplicatedMergeTree.cpp

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4588,15 +4588,6 @@ void StorageReplicatedMergeTree::selectPartsToExport()
45884588
return false;
45894589
}
45904590

4591-
std::string next_idx_string;
4592-
if (!zk->tryGet(next_idx_path, next_idx_string, &next_idx_stat))
4593-
{
4594-
LOG_INFO(log, "Failed to get next_idx, skipping");
4595-
return false;
4596-
}
4597-
4598-
const std::size_t next_idx_zk = std::stoull(next_idx_string.c_str());
4599-
46004591
std::size_t parts_to_do = std::stoull(parts_to_do_string.c_str());
46014592

46024593
if (parts_to_do == 0)
@@ -4610,8 +4601,6 @@ void StorageReplicatedMergeTree::selectPartsToExport()
46104601
Coordination::Requests ops;
46114602
ops.emplace_back(zkutil::makeCheckRequest(lock_path, lock_stat.version));
46124603
ops.emplace_back(zkutil::makeCheckRequest(parts_to_do_path, parts_to_do_stat.version));
4613-
ops.emplace_back(zkutil::makeCheckRequest(next_idx_path, next_idx_stat.version));
4614-
ops.emplace_back(zkutil::makeSetRequest(next_idx_path, std::to_string(std::max(next_idx_zk, next_idx_local + 1)), next_idx_stat.version));
46154604
ops.emplace_back(zkutil::makeSetRequest(part_status_path, "COMPLETED", -1));
46164605
ops.emplace_back(zkutil::makeRemoveRequest(lock_path, lock_stat.version));
46174606
ops.emplace_back(zkutil::makeSetRequest(parts_to_do_path, std::to_string(parts_to_do), parts_to_do_stat.version));

0 commit comments

Comments
 (0)