Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
wenym1 committed Oct 14, 2024
1 parent 604b5b6 commit af34fd8
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 10 deletions.
5 changes: 4 additions & 1 deletion src/meta/src/barrier/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -245,7 +245,10 @@ impl CheckpointControl {
fn total_command_num(&self) -> usize {
self.command_ctx_queue.len()
+ match &self.completing_task {
CompletingTask::Completing { .. } => 1,
CompletingTask::Completing {
command_ctx: Some(_),
..
} => 1,
_ => 0,
}
}
Expand Down
9 changes: 0 additions & 9 deletions src/meta/src/hummock/manager/transaction.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
// See the License for the specific language governing permissions and
// limitations under the License.

use std::cell::LazyCell;
use std::collections::{BTreeMap, HashMap};
use std::ops::{Deref, DerefMut};
use std::sync::Arc;
Expand Down Expand Up @@ -146,14 +145,6 @@ impl<'a> HummockVersionTransaction<'a> {
}
}

let max_epoch_to_commit = LazyCell::new(|| {
tables_to_commit
.values()
.cloned()
.max()
.expect("non empty tables_to_commit")
});

// Append SSTs to a new version.
for (compaction_group_id, inserted_table_infos) in commit_sstables {
let group_deltas = &mut new_version_delta
Expand Down

0 comments on commit af34fd8

Please sign in to comment.