Skip to content

Instantly share code, notes, and snippets.

@avantgardnerio

avantgardnerio/gist:7d0ca5925e7bf6c576fb79e652c3a0a5 Secret

Created December 3, 2022 00:39
Show Gist options
  • Save avantgardnerio/7d0ca5925e7bf6c576fb79e652c3a0a5 to your computer and use it in GitHub Desktop.
Save avantgardnerio/7d0ca5925e7bf6c576fb79e652c3a0a5 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
/snap/bin/cargo test --color=always --package coldb --bin coldb coldb::tests::multi_node_test -- --exact --nocapture
Finished test [unoptimized + debuginfo] target(s) in 0.10s
Running unittests src/main.rs (target/debug/deps/coldb-41c95cbbd62fdd09)
running 1 test
Node 3: Initializing raft with nodes: {1, 2, 3, 4}
Node 3: read_hard_state hs=None
Node 3: last_applied_state log=None mem=None
Node 3: last_applied_state log=None mem=None
Node 3: get_current_snapshot
Node 3: append_to_log log_idx=0-0 entry=Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }
Node 3: send_vote VoteRequest { term: 1, candidate_id: 3, last_log_id: Some(LogId { term: 0, index: 0 }) } to 1
Node 3: send_vote VoteRequest { term: 1, candidate_id: 3, last_log_id: Some(LogId { term: 0, index: 0 }) } to 2
Node 3: send_vote VoteRequest { term: 1, candidate_id: 3, last_log_id: Some(LogId { term: 0, index: 0 }) } to 4
Node 4: Initializing raft with nodes: {1, 2, 3, 4}
Node 5: read_hard_state hs=None
Node 5: last_applied_state log=None mem=None
Node 5: last_applied_state log=None mem=None
Node 5: get_current_snapshot
Node 4: read_hard_state hs=None
Node 4: last_applied_state log=None mem=None
Node 4: last_applied_state log=None mem=None
Node 4: get_current_snapshot
Node 4: append_to_log log_idx=0-0 entry=Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }
Node 4: send_vote VoteRequest { term: 1, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 1
Node 4: send_vote VoteRequest { term: 1, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 2
Node 4: send_vote VoteRequest { term: 1, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 3
Node 1: Initializing raft with nodes: {1, 2, 3, 4}
Node 1: read_hard_state hs=None
Node 1: last_applied_state log=None mem=None
Node 1: last_applied_state log=None mem=None
Node 1: get_current_snapshot
Node 1: append_to_log log_idx=0-0 entry=Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }
Node 1: send_vote VoteRequest { term: 1, candidate_id: 1, last_log_id: Some(LogId { term: 0, index: 0 }) } to 2
Node 1: send_vote VoteRequest { term: 1, candidate_id: 1, last_log_id: Some(LogId { term: 0, index: 0 }) } to 3
Node 1: send_vote VoteRequest { term: 1, candidate_id: 1, last_log_id: Some(LogId { term: 0, index: 0 }) } to 4
Node 2: Initializing raft with nodes: {1, 2, 3, 4}
Node 2: read_hard_state hs=None
Node 2: last_applied_state log=None mem=None
Node 2: last_applied_state log=None mem=None
Node 2: get_current_snapshot
Node 2: append_to_log log_idx=0-0 entry=Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }
Node 2: send_vote VoteRequest { term: 1, candidate_id: 2, last_log_id: Some(LogId { term: 0, index: 0 }) } to 1
Node 2: send_vote VoteRequest { term: 1, candidate_id: 2, last_log_id: Some(LogId { term: 0, index: 0 }) } to 3
Node 2: send_vote VoteRequest { term: 1, candidate_id: 2, last_log_id: Some(LogId { term: 0, index: 0 }) } to 4
Test: Waiting for a leader...
Node 3: received ReqVote from 4
Node 3: received ReqVote from 1
Node 3: received ReqVote from 2
Node 4: received ReqVote from 3
Node 4: received ReqVote from 1
Node 4: received ReqVote from 2
Node 1: received ReqVote from 3
Node 1: received ReqVote from 4
Node 1: received ReqVote from 2
Node 2: received ReqVote from 3
Node 2: received ReqVote from 4
Node 2: received ReqVote from 1
Node 4: send_vote VoteRequest { term: 2, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 1
Node 4: send_vote VoteRequest { term: 2, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 2
Node 4: send_vote VoteRequest { term: 2, candidate_id: 4, last_log_id: Some(LogId { term: 0, index: 0 }) } to 3
Node 1: received ReqVote from 4
Node 2: received ReqVote from 4
Node 3: received ReqVote from 4
Node 4: append_to_log log_idx=2-1 entry=Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }
Node 4: sending AppendEntriesRequest to 1 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: None, entries: [Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }], leader_commit: None }
Node 4: sending AppendEntriesRequest to 2 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: None, entries: [Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }], leader_commit: None }
Node 4: sending AppendEntriesRequest to 3 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: None, entries: [Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }], leader_commit: None }
Test: Node 1: has leader 4
Test: Node 2: has leader 4
Test: Node 3: has leader 4
Test: Node 4: has leader 4
Test: Cluster is stable metrics=RaftMetrics { running_state: Ok(()), id: 4, state: Leader, current_term: 2, last_log_index: Some(1), last_applied: None, current_leader: Some(4), membership_config: EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } }, snapshot: None, leader_metrics: Some(LeaderMetrics { replication: {} }) }
Node 4: sending AppendEntriesRequest to 1 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 0, index: 0 }), entries: [Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }], leader_commit: None }
Node 4: sending AppendEntriesRequest to 2 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 0, index: 0 }), entries: [Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }], leader_commit: None }
Node 4: sending AppendEntriesRequest to 3 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 0, index: 0 }), entries: [Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }], leader_commit: None }
Node 1: try_get_log_entries on empty range
Node 1: append_to_log log_idx=2-1 entry=Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }
Node 2: try_get_log_entries on empty range
Node 2: append_to_log log_idx=2-1 entry=Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }
Node 3: try_get_log_entries on empty range
Node 3: append_to_log log_idx=2-1 entry=Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }
Node 4: apply_to_state_machine
Node 4: membership=Some(EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } })
Node 4: apply_to_state_machine
Node 4: LogId { term: 2, index: 1 } Empty request!
Node 1: apply_to_state_machine
Node 1: membership=Some(EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } })
Node 1: LogId { term: 2, index: 1 } Empty request!
Node 2: apply_to_state_machine
Node 2: membership=Some(EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } })
Node 2: LogId { term: 2, index: 1 } Empty request!
Node 3: apply_to_state_machine
Node 3: membership=Some(EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } })
Node 3: LogId { term: 2, index: 1 } Empty request!
Test: Adding node 5 to main cluster as a learner
Node 4: sending AppendEntriesRequest to 5 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: None, entries: [Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }, Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }], leader_commit: Some(LogId { term: 2, index: 1 }) }
Node 5: try_get_log_entries on empty range
Node 5: delete_conflict_logs_since LogId { term: 0, index: 0 }
Node 5: last_applied_state log=None mem=None
Node 5: append_to_log log_idx=0-0 entry=Entry { log_id: LogId { term: 0, index: 0 }, payload: Membership(Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} }) }
Node 5: append_to_log log_idx=2-1 entry=Entry { log_id: LogId { term: 2, index: 1 }, payload: Blank }
Node 5: apply_to_state_machine
Node 5: membership=Some(EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } })
Node 5: LogId { term: 2, index: 1 } Empty request!
Test: add_learner log_id=AddLearnerResponse { matched: Some(LogId { term: 2, index: 1 }) } metrics=RaftMetrics { running_state: Ok(()), id: 4, state: Leader, current_term: 2, last_log_index: Some(1), last_applied: Some(LogId { term: 2, index: 1 }), current_leader: Some(4), membership_config: EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } }, snapshot: None, leader_metrics: Some(LeaderMetrics { replication: {1: ReplicationMetrics { matched: Some(LogId { term: 2, index: 1 }) }, 3: ReplicationMetrics { matched: Some(LogId { term: 2, index: 1 }) }, 5: ReplicationMetrics { matched: Some(LogId { term: 2, index: 1 }) }, 2: ReplicationMetrics { matched: Some(LogId { term: 2, index: 1 }) }} }) }
Node 1: do_handshake
Node 1: do_action_create_prepared_statement query=create table person (id int primary key, name string) handle=54cd40b7-de27-4ee7-9ecd-14192ab872f9
Node 1: preparing ReqCreateTable table=person
Node 1: do_put_prepared_statement_update handle=54cd40b7-de27-4ee7-9ecd-14192ab872f9
Node 4: received ClientRequest from=1
Node 4: append_to_log log_idx=2-2 entry=Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }
Node 4: sending AppendEntriesRequest to 1 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 1 }), entries: [Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }], leader_commit: Some(LogId { term: 2, index: 1 }) }
Node 4: sending AppendEntriesRequest to 2 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 1 }), entries: [Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }], leader_commit: Some(LogId { term: 2, index: 1 }) }
Node 4: sending AppendEntriesRequest to 3 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 1 }), entries: [Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }], leader_commit: Some(LogId { term: 2, index: 1 }) }
Node 4: sending AppendEntriesRequest to 5 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 1 }), entries: [Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }], leader_commit: Some(LogId { term: 2, index: 1 }) }
Node 1: try_get_log_entries on empty range
Node 1: append_to_log log_idx=2-2 entry=Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }
Node 2: try_get_log_entries on empty range
Node 2: append_to_log log_idx=2-2 entry=Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }
Node 3: try_get_log_entries on empty range
Node 3: append_to_log log_idx=2-2 entry=Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }
Node 5: try_get_log_entries on empty range
Node 5: append_to_log log_idx=2-2 entry=Entry { log_id: LogId { term: 2, index: 2 }, payload: Normal(ClientRequest { client: 1, serial: 1, req: Some(CreateTable(ReqCreateTable { name: "person", schema: Some(SchemaResult { schema: [255, 255, 255, 255, 120, 1, 0, 0, 16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 248, 0, 0, 0, 184, 0, 0, 0, 124, 0, 0, 0, 56, 0, 0, 0, 4, 0, 0, 0, 44, 255, 255, 255, 16, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 2, 20, 0, 0, 0, 28, 255, 255, 255, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 7, 0, 0, 0, 95, 95, 115, 116, 97, 116, 101, 0, 92, 255, 255, 255, 16, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 190, 255, 255, 255, 64, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 95, 95, 116, 120, 110, 95, 105, 100, 0, 0, 0, 0, 16, 0, 22, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 2, 24, 0, 0, 0, 0, 0, 6, 0, 8, 0, 4, 0, 6, 0, 0, 0, 64, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 95, 95, 108, 111, 103, 95, 105, 100, 120, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0] }), pk_cols: ["id"] })) }) }
Node 4: apply_to_state_machine
Node 4: initializing store
Node 4: Initializing store
Node 4: creating table: person
Node 1: Created table success=true
Node 1: apply_to_state_machine
Node 1: initializing store
Node 1: Initializing store
Node 1: creating table: person
Node 2: apply_to_state_machine
Node 2: initializing store
Node 2: Initializing store
Node 2: creating table: person
Node 3: apply_to_state_machine
Node 3: initializing store
Node 3: Initializing store
Node 3: creating table: person
Node 5: apply_to_state_machine
Node 5: initializing store
Node 5: Initializing store
Node 5: creating table: person
Node 1: do_action_create_prepared_statement query=insert into person (id, name) values (1, 'Hopper'), (2, 'Kay') handle=e141328a-e912-4960-8803-0daf43baa898
Node 1: Registered table person into FlightSQL datafusion context
Node 1: do_put_prepared_statement_update handle=e141328a-e912-4960-8803-0daf43baa898
Node 4: received ClientRequest from=1
Node 4: append_to_log log_idx=2-3 entry=Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }
Node 4: sending AppendEntriesRequest to 1 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 2 }), entries: [Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }], leader_commit: Some(LogId { term: 2, index: 2 }) }
Node 4: sending AppendEntriesRequest to 2 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 2 }), entries: [Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }], leader_commit: Some(LogId { term: 2, index: 2 }) }
Node 4: sending AppendEntriesRequest to 3 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 2 }), entries: [Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }], leader_commit: Some(LogId { term: 2, index: 2 }) }
Node 4: sending AppendEntriesRequest to 5 AppendEntriesRequest { term: 2, leader_id: 4, prev_log_id: Some(LogId { term: 2, index: 2 }), entries: [Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }], leader_commit: Some(LogId { term: 2, index: 2 }) }
Node 1: try_get_log_entries on empty range
Node 1: append_to_log log_idx=2-3 entry=Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }
Node 2: try_get_log_entries on empty range
Node 2: append_to_log log_idx=2-3 entry=Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }
Node 3: try_get_log_entries on empty range
Node 3: append_to_log log_idx=2-3 entry=Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }
Node 5: try_get_log_entries on empty range
Node 5: append_to_log log_idx=2-3 entry=Entry { log_id: LogId { term: 2, index: 3 }, payload: Normal(ClientRequest { client: 1, serial: 3, req: Some(BatchInsert(ReqBatchInsert { txn_id: 0, table_name: "person", data: [FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 0, 0, 10, 0, 14, 0, 12, 0, 11, 0, 4, 0, 10, 0, 0, 0, 20, 0, 0, 0, 0, 0, 0, 1, 4, 0, 10, 0, 12, 0, 0, 0, 8, 0, 4, 0, 10, 0, 0, 0, 8, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 68, 0, 0, 0, 4, 0, 0, 0, 212, 255, 255, 255, 24, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 5, 16, 0, 0, 0, 0, 0, 0, 0, 4, 0, 4, 0, 4, 0, 0, 0, 4, 0, 0, 0, 110, 97, 109, 101, 0, 0, 0, 0, 16, 0, 20, 0, 16, 0, 0, 0, 15, 0, 4, 0, 0, 0, 8, 0, 16, 0, 0, 0, 24, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 2, 28, 0, 0, 0, 8, 0, 12, 0, 4, 0, 11, 0, 8, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 2, 0, 0, 0, 105, 100, 0, 0], app_metadata: [], data_body: [] }, FlightData { flight_descriptor: None, data_header: [16, 0, 0, 0, 12, 0, 26, 0, 24, 0, 23, 0, 4, 0, 8, 0, 12, 0, 0, 0, 32, 0, 0, 0, 56, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 3, 4, 0, 10, 0, 20, 0, 12, 0, 8, 0, 4, 0, 10, 0, 0, 0, 52, 0, 0, 0, 12, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 8, 0, 0, 0, 0, 0, 0, 0, 16, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 0, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0], app_metadata: [], data_body: [255, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 2, 0, 0, 0, 255, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 6, 0, 0, 0, 9, 0, 0, 0, 0, 0, 0, 0, 72, 111, 112, 112, 101, 114, 75, 97, 121, 0, 0, 0, 0, 0, 0, 0] }] })) }) }
Node 4: apply_to_state_machine
Node 4: inserting batch into person
Node 4: inserting 2 rows into person
Node 4: Inserted keys {Key { fields: [Int32(1)], orderings: [Asc] }, Key { fields: [Int32(2)], orderings: [Asc] }} found conflicting txns: []
+----+--------+-----------+----------+---------+
| id | name | __log_idx | __txn_id | __state |
+----+--------+-----------+----------+---------+
| 1 | Hopper | 3 | 0 | 3 |
| 2 | Kay | 3 | 0 | 3 |
+----+--------+-----------+----------+---------+
Node 1: Inserted: success=true
Node 1: apply_to_state_machine
Node 1: inserting batch into person
Node 1: inserting 2 rows into person
Node 1: Inserted keys {Key { fields: [Int32(1)], orderings: [Asc] }, Key { fields: [Int32(2)], orderings: [Asc] }} found conflicting txns: []
+----+--------+-----------+----------+---------+
| id | name | __log_idx | __txn_id | __state |
+----+--------+-----------+----------+---------+
| 1 | Hopper | 3 | 0 | 3 |
| 2 | Kay | 3 | 0 | 3 |
+----+--------+-----------+----------+---------+
Node 2: apply_to_state_machine
Node 2: inserting batch into person
Node 2: inserting 2 rows into person
Node 2: Inserted keys {Key { fields: [Int32(1)], orderings: [Asc] }, Key { fields: [Int32(2)], orderings: [Asc] }} found conflicting txns: []
+----+--------+-----------+----------+---------+
| id | name | __log_idx | __txn_id | __state |
+----+--------+-----------+----------+---------+
| 1 | Hopper | 3 | 0 | 3 |
| 2 | Kay | 3 | 0 | 3 |
+----+--------+-----------+----------+---------+
Node 3: apply_to_state_machine
Node 3: inserting batch into person
Node 3: inserting 2 rows into person
Node 3: Inserted keys {Key { fields: [Int32(2)], orderings: [Asc] }, Key { fields: [Int32(1)], orderings: [Asc] }} found conflicting txns: []
+----+--------+-----------+----------+---------+
| id | name | __log_idx | __txn_id | __state |
+----+--------+-----------+----------+---------+
| 1 | Hopper | 3 | 0 | 3 |
| 2 | Kay | 3 | 0 | 3 |
+----+--------+-----------+----------+---------+
Node 5: apply_to_state_machine
Node 5: inserting batch into person
Node 5: inserting 2 rows into person
Node 5: Inserted keys {Key { fields: [Int32(2)], orderings: [Asc] }, Key { fields: [Int32(1)], orderings: [Asc] }} found conflicting txns: []
+----+--------+-----------+----------+---------+
| id | name | __log_idx | __txn_id | __state |
+----+--------+-----------+----------+---------+
| 1 | Hopper | 3 | 0 | 3 |
| 2 | Kay | 3 | 0 | 3 |
+----+--------+-----------+----------+---------+
Node 1: do_action_create_prepared_statement query=select * from person handle=f0997c8c-d5ea-401f-bdc1-07afe8e1d0f0
Node 1: Registered table person into FlightSQL datafusion context
Node 1: get_flight_info_prepared_statement handle=f0997c8c-d5ea-401f-bdc1-07afe8e1d0f0
Node 1: do_get_fallback type_url: type.googleapis.com/arrow.flight.protocol.sql.FetchResults
Node 1: do_get_fallback handle=f0997c8c-d5ea-401f-bdc1-07afe8e1d0f0 returning 1 batches
Test: shutting down learner=RaftMetrics { running_state: Ok(()), id: 5, state: Learner, current_term: 2, last_log_index: Some(3), last_applied: Some(LogId { term: 2, index: 3 }), current_leader: Some(4), membership_config: EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } }, snapshot: None, leader_metrics: None }
Test: shutting down leader=RaftMetrics { running_state: Ok(()), id: 4, state: Leader, current_term: 2, last_log_index: Some(3), last_applied: Some(LogId { term: 2, index: 3 }), current_leader: Some(4), membership_config: EffectiveMembership { log_id: LogId { term: 0, index: 0 }, membership: Membership { configs: [{1, 2, 3, 4}], all_nodes: {1, 2, 3, 4} } }, snapshot: None, leader_metrics: Some(LeaderMetrics { replication: {1: ReplicationMetrics { matched: Some(LogId { term: 2, index: 3 }) }, 3: ReplicationMetrics { matched: Some(LogId { term: 2, index: 3 }) }, 5: ReplicationMetrics { matched: Some(LogId { term: 2, index: 3 }) }, 2: ReplicationMetrics { matched: Some(LogId { term: 2, index: 3 }) }} }) }
test coldb::tests::multi_node_test ... ok
test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 4 filtered out; finished in 5.71s
Process finished with exit code 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment