2025-12-12T12:33:09.278550Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Starting read session
2025-12-12T12:33:09.278596Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Starting session to cluster null (localhost:64299)
2025-12-12T12:33:09.279048Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:09.279063Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:09.279068Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:33:09.284919Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Successfully connected. Initializing session
2025-12-12T12:33:09.286082Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Server session id: disposition_from_time_consumer_1_11_3507507273585215374_v1
2025-12-12T12:33:09.287137Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:09.291873Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:33:09.292735Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:09.292792Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-12T12:33:09.292842Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:33:09.292857Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:33:09.292979Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-12T12:33:09.293073Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:33:09.297436Z :DEBUG: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:33:09.297578Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Closing read session. Close timeout: 5.000000s
2025-12-12T12:33:09.297973Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:3:4
2025-12-12T12:33:09.298935Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 19 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:33:09.299170Z :NOTICE: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:33:09.299280Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Closing read session. Close timeout: 0.000000s
2025-12-12T12:33:09.299290Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:3:4
2025-12-12T12:33:09.299297Z :INFO: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 20 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:33:09.299306Z :NOTICE: [local] [local] [fea03b07-41f01e69-68b40686-e9c87c4f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:36.135310Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Starting read session
2025-12-12T12:27:36.135360Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Starting session to cluster null (localhost:12669)
2025-12-12T12:27:36.135906Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.135919Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.135926Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:36.141892Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Successfully connected. Initializing session
2025-12-12T12:27:36.143176Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Server session id: disposition_time_ago_consumer_1_10_13953524612515077471_v1
2025-12-12T12:27:36.143252Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.144524Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:36.145330Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.145385Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-12T12:27:36.145409Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:27:36.145421Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:27:36.145535Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-12T12:27:36.145629Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:27:36.148284Z :DEBUG: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:36.148422Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:36.148461Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:3:4
2025-12-12T12:27:36.148472Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:36.148747Z :NOTICE: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:27:36.152119Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:36.152136Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:3:4
2025-12-12T12:27:36.152146Z :INFO: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:36.152161Z :NOTICE: [local] [local] [3e96e85f-f930ec20-ee82531f-e3a2595] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:36.042338Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Starting read session
2025-12-12T12:27:36.042380Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Starting session to cluster null (localhost:25827)
2025-12-12T12:27:36.042781Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.042795Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.042801Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:36.048468Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Successfully connected. Initializing session
2025-12-12T12:27:36.049662Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Server session id: test_time_order_recoverer[v1-kikimr0]_v1_consumer_1_14_11183640957248401982_v1
2025-12-12T12:27:36.049775Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.051383Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_time_order_recoverer[v1-kikimr0]_v1_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:37.043280Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:0:0
2025-12-12T12:27:37.043324Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:54.346906Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:54.347027Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:27:54.347087Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:54.347197Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:27:54.347247Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] The application data is transferred to the client. Number of messages 1, size 23 bytes
2025-12-12T12:27:54.350535Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:54.350649Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-12-12T12:27:54.350707Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T12:27:54.350720Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-12-12T12:27:54.350795Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Commit offsets [1, 3). Partition stream id: 1
2025-12-12T12:27:54.350928Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] The application data is transferred to the client. Number of messages 2, size 46 bytes
2025-12-12T12:27:54.352628Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:27:54.353533Z :DEBUG: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-12-12T12:27:54.355083Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:54.355118Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:2:3
2025-12-12T12:27:54.355142Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18312 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:54.356813Z :NOTICE: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:27:54.358996Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:54.359035Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:2:3
2025-12-12T12:27:54.359046Z :INFO: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18316 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:54.359072Z :NOTICE: [local] [local] [7540696a-1fd4f35-dc8d20e5-fa7001bb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:45.701752Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Starting read session
2025-12-12T12:27:45.702531Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Starting session to cluster null (localhost:29692)
2025-12-12T12:27:45.703014Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:45.703025Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:45.703030Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:45.711557Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Successfully connected. Initializing session
2025-12-12T12:27:45.712983Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Server session id: restart_1_consumer_1_13_9545917936177623920_v1
2025-12-12T12:27:45.713037Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:45.715060Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_1_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:45.715998Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:45.716209Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:27:45.716252Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:45.716370Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:27:45.716418Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-12-12T12:27:45.719327Z :DEBUG: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:27:45.719486Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:45.719522Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_1_output:0:1:0:1
2025-12-12T12:27:45.719533Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:45.719760Z :NOTICE: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:27:45.723166Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:45.723182Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_1_output:0:1:0:1
2025-12-12T12:27:45.723194Z :INFO: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 21 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:45.723207Z :NOTICE: [local] [local] [950b5ffb-9f43498e-92b77557-4280a94f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:20.383716Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Starting read session
2025-12-12T12:28:20.383763Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:20.384207Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:20.384221Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:20.384227Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:20.392022Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] Successfully connected. Initializing session
2025-12-12T12:28:20.393069Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] Server session id: test_3_session_consumer_1_10_491956979356655939_v1
2025-12-12T12:28:20.393140Z :DEBUG: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:20.399907Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-12T12:28:21.383189Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:21.383243Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:0:2
2025-12-12T12:28:21.383258Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:21.383527Z :NOTICE: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:28:21.383663Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:21.383675Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:0:2
2025-12-12T12:28:21.383683Z :INFO: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:21.383693Z :NOTICE: [local] [local] [a412fc4a-89deccde-16a0a24b-4c028b85] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:35:47.444872Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Starting read session
2025-12-12T12:35:47.444916Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] Starting session to cluster null (localhost:63390)
2025-12-12T12:35:47.445370Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:47.446534Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:47.446551Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:35:47.452372Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Successfully connected. Initializing session
2025-12-12T12:35:47.453412Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Server session id: test_filters_non_optional_field_consumer_1_9_14312696536866063480_v1
2025-12-12T12:35:47.453514Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:47.455247Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:35:48.447091Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:0:4
2025-12-12T12:35:48.447123Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:51.230145Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:51.230243Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-12-12T12:35:51.230316Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:35:51.230437Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Commit offsets [4, 5). Partition stream id: 1
2025-12-12T12:35:51.230597Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:35:51.233472Z :DEBUG: [local] [local] [646309cb-98715800-11674999-3e8664d6] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:35:51.233642Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Closing read session. Close timeout: 5.000000s
2025-12-12T12:35:51.233685Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:4:5
2025-12-12T12:35:51.233697Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3788 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:35:51.233935Z :NOTICE: [local] [local] [646309cb-98715800-11674999-3e8664d6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:35:51.234087Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Closing read session. Close timeout: 0.000000s
2025-12-12T12:35:51.234098Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:4:5
2025-12-12T12:35:51.234126Z :INFO: [local] [local] [646309cb-98715800-11674999-3e8664d6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3789 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:51.234136Z :NOTICE: [local] [local] [646309cb-98715800-11674999-3e8664d6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:23.750534Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Starting read session
2025-12-12T12:28:23.750585Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Starting session to cluster null (localhost:8973)
2025-12-12T12:28:23.751029Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:23.751048Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:23.751054Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:23.756319Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Successfully connected. Initializing session
2025-12-12T12:28:23.762540Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Server session id: test_restart_compute_node_consumer_1_18_13816426169186428690_v1
2025-12-12T12:28:23.762675Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:23.765638Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:28:23.765748Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-12T12:28:23.765759Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:28:23.765765Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:24.754097Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:0:8 null:test_restart_compute_node_output:2:2:0:4 null:test_restart_compute_node_output:1:1:0:4
2025-12-12T12:28:24.754145Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:46.042081Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:46.042193Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (4-4)
2025-12-12T12:28:46.042248Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (4-4)
2025-12-12T12:28:46.043991Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [4, 5). Partition stream id: 2
2025-12-12T12:28:46.044140Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:46.049400Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:46.049482Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (5-5)
2025-12-12T12:28:46.049526Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (5-5)
2025-12-12T12:28:46.049786Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [5, 6). Partition stream id: 2
2025-12-12T12:28:46.049880Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:46.054514Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-12T12:28:46.054791Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:46.054837Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (8-8)
2025-12-12T12:28:46.054873Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (8-8)
2025-12-12T12:28:46.054884Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (4-4)
2025-12-12T12:28:46.054912Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (4-4)
2025-12-12T12:28:46.054947Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [8, 9). Partition stream id: 3
2025-12-12T12:28:46.055066Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:46.055160Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-12T12:28:46.055718Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [4, 5). Partition stream id: 1
2025-12-12T12:28:46.055786Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:46.057539Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:46.057593Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (5-5)
2025-12-12T12:28:46.057625Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (5-5)
2025-12-12T12:28:46.057642Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (9-11)
2025-12-12T12:28:46.057649Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (9-9)
2025-12-12T12:28:46.057656Z :DEBUG: [local] Take Data. Partition 3. Read: {1, 0} (10-10)
2025-12-12T12:28:46.057674Z :DEBUG: [local] Take Data. Partition 3. Read: {1, 1} (11-11)
2025-12-12T12:28:46.057705Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [5, 6). Partition stream id: 1
2025-12-12T12:28:46.057819Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:46.057849Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Commit offsets [9, 12). Partition stream id: 3
2025-12-12T12:28:46.057857Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-12T12:28:46.057979Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:46.058259Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 3 partition_cookie: 1 }
2025-12-12T12:28:46.060378Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-12T12:28:46.061084Z :DEBUG: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] [null] Committed response: cookies { assign_id: 3 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-12T12:28:46.061191Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:46.061216Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:11:12 null:test_restart_compute_node_output:2:2:5:6 null:test_restart_compute_node_output:1:1:5:6
2025-12-12T12:28:46.061235Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22310 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:46.061460Z :NOTICE: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:28:46.061573Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:46.061591Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:11:12 null:test_restart_compute_node_output:2:2:5:6 null:test_restart_compute_node_output:1:1:5:6
2025-12-12T12:28:46.061599Z :INFO: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22311 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:46.061609Z :NOTICE: [local] [local] [59ef3c78-fce4c334-f45454b9-82abeffe] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:17.169716Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Starting read session
2025-12-12T12:27:17.169770Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:17.170262Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:17.170592Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:17.170604Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:17.176232Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Successfully connected. Initializing session
2025-12-12T12:27:17.177846Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Server session id: test_start_new_query_consumer_1_6_9609348076431874605_v1
2025-12-12T12:27:17.177983Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:17.181013Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:18.171249Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:0:2
2025-12-12T12:27:18.171289Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:20.014334Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.014416Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-12T12:27:20.014461Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:27:20.014571Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-12T12:27:20.014691Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:20.015108Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.015183Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-12T12:27:20.015263Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-12T12:27:20.015327Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-12T12:27:20.015423Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:20.017715Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:27:20.018280Z :DEBUG: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-12T12:27:20.018555Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:20.018578Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:3:4
2025-12-12T12:27:20.018588Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2848 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:20.018831Z :NOTICE: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-12T12:27:20.018936Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:20.018945Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:3:4
2025-12-12T12:27:20.018953Z :INFO: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2849 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:20.018973Z :NOTICE: [local] [local] [ccf1ac58-fb936f58-555b1cde-4e72619d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
