2025-12-12T12:33:01.553853Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Starting read session
2025-12-12T12:33:01.553897Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Starting session to cluster null (localhost:64299)
2025-12-12T12:33:01.554370Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:01.554386Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:01.554392Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:33:01.559759Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Successfully connected. Initializing session
2025-12-12T12:33:01.564140Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Server session id: disposition_from_time_consumer_1_9_2216942760010379404_v1
2025-12-12T12:33:01.564871Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:01.565742Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:33:01.566628Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:01.566823Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:33:01.566858Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:33:01.566869Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:33:01.566957Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:33:01.567062Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:33:01.569794Z :DEBUG: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:33:01.569946Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Closing read session. Close timeout: 5.000000s
2025-12-12T12:33:01.569989Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:1:2
2025-12-12T12:33:01.570014Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:33:01.570425Z :NOTICE: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] 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:01.570522Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Closing read session. Close timeout: 0.000000s
2025-12-12T12:33:01.570535Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:1:2
2025-12-12T12:33:01.570544Z :INFO: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:33:01.570554Z :NOTICE: [local] [local] [d0417ef0-7c7164c9-d0dacf0c-c712e34e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:06.136106Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Starting read session
2025-12-12T12:27:06.141005Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Starting session to cluster null (localhost:12669)
2025-12-12T12:27:06.141631Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:06.141644Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:06.141651Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:06.147341Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Successfully connected. Initializing session
2025-12-12T12:27:06.148846Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Server session id: disposition_time_ago_consumer_1_8_12876158413663662902_v1
2025-12-12T12:27:06.148948Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:06.153969Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:06.156426Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:06.156513Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:27:06.156555Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:06.156568Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:27:06.156700Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:27:06.156777Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:27:06.159974Z :DEBUG: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:06.160160Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:06.160199Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:1:2
2025-12-12T12:27:06.160211Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Counters: { Errors: 0 CurrentSessionLifetimeMs: 24 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:06.160481Z :NOTICE: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] 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:06.165018Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:06.165058Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:1:2
2025-12-12T12:27:06.165074Z :INFO: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Counters: { Errors: 0 CurrentSessionLifetimeMs: 28 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:06.165098Z :NOTICE: [local] [local] [6a1bc9da-272718dc-78fca520-ce59a498] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:08.540851Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Starting read session
2025-12-12T12:27:08.540900Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Starting session to cluster null (localhost:25827)
2025-12-12T12:27:08.541371Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:08.541384Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:08.541389Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:08.546994Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Successfully connected. Initializing session
2025-12-12T12:27:08.548132Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Server session id: test_match_recognize[v1-kikimr0]_v1_consumer_1_11_7464206464124657610_v1
2025-12-12T12:27:08.548197Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:08.550498Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_match_recognize[v1-kikimr0]_v1_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:09.542297Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:0
2025-12-12T12:27:09.542337Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:24.075394Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:24.075487Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:27:24.075535Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:24.079212Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:27:24.079403Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] The application data is transferred to the client. Number of messages 1, size 91 bytes
2025-12-12T12:27:24.086623Z :DEBUG: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:27:24.090142Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:24.090173Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:1
2025-12-12T12:27:24.090185Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15549 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:24.090722Z :NOTICE: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] 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:24.095013Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:24.095034Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:1
2025-12-12T12:27:24.095071Z :INFO: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15554 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:24.095192Z :NOTICE: [local] [local] [93677786-206ec40f-208a64b0-bd9b1a99] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:28.886387Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Starting read session
2025-12-12T12:27:28.886443Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Starting session to cluster null (localhost:29692)
2025-12-12T12:27:28.886992Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:28.887025Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:28.887032Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:28.892556Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Successfully connected. Initializing session
2025-12-12T12:27:28.893659Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Server session id: restart_2_consumer_1_11_12502095793309993867_v1
2025-12-12T12:27:28.893721Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:28.895698Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_2_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:28.896506Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:28.896579Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:27:28.896640Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:28.896756Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:27:28.896833Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-12-12T12:27:28.901525Z :DEBUG: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:27:28.901702Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:28.901755Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_2_output:0:1:0:1
2025-12-12T12:27:28.901770Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:28.902042Z :NOTICE: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] 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:28.902182Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:28.902192Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_2_output:0:1:0:1
2025-12-12T12:27:28.902201Z :INFO: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:28.902211Z :NOTICE: [local] [local] [7e99067d-65c2dc59-30246603-9f64c88b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:17.840192Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Starting read session
2025-12-12T12:28:17.840255Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:17.840757Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.840768Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.840774Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:17.846111Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Successfully connected. Initializing session
2025-12-12T12:28:17.847557Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Server session id: test_3_session_consumer_1_9_17416338294120911312_v1
2025-12-12T12:28:17.848328Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.849116Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:17.850710Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.850786Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:28:17.850841Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:28:17.850852Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:28:17.850966Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:28:17.851082Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:17.854004Z :DEBUG: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:17.854160Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:17.854207Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:1:2
2025-12-12T12:28:17.854218Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:17.854459Z :NOTICE: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] 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:17.854582Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:17.854592Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:1:2
2025-12-12T12:28:17.854600Z :INFO: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:17.854609Z :NOTICE: [local] [local] [b980f6df-a6b671fb-ae0c8341-8fb24d35] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:35:39.768694Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Starting read session
2025-12-12T12:35:39.768729Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Starting session to cluster null (localhost:63390)
2025-12-12T12:35:39.769144Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:39.770011Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:39.770022Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:35:39.774880Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] Successfully connected. Initializing session
2025-12-12T12:35:39.776148Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] Server session id: test_filters_non_optional_field_consumer_1_7_7345721654507875518_v1
2025-12-12T12:35:39.776595Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:39.777603Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [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:40.769568Z :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:3
2025-12-12T12:35:40.771038Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:43.365857Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:43.365946Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-12T12:35:43.366003Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-12T12:35:43.366104Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-12T12:35:43.366176Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:35:43.369887Z :DEBUG: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:35:43.370074Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Closing read session. Close timeout: 5.000000s
2025-12-12T12:35:43.370102Z :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:3:4
2025-12-12T12:35:43.370113Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3601 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:35:43.370365Z :NOTICE: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] 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:43.371203Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Closing read session. Close timeout: 0.000000s
2025-12-12T12:35:43.371221Z :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:3:4
2025-12-12T12:35:43.371243Z :INFO: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3602 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:43.371260Z :NOTICE: [local] [local] [dae55343-1f58a18b-6a818b89-fa2f9314] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:10.768669Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Starting read session
2025-12-12T12:28:10.768722Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Starting session to cluster null (localhost:8973)
2025-12-12T12:28:10.769336Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:10.769361Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:10.769820Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:10.775791Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Successfully connected. Initializing session
2025-12-12T12:28:10.781999Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Server session id: test_restart_compute_node_consumer_1_14_7384265332086835478_v1
2025-12-12T12:28:10.782090Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:10.783825Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-12T12:28:10.783981Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:28:10.783996Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:10.784119Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:28:10.784742Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:10.784800Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-3)
2025-12-12T12:28:10.784841Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (2-2)
2025-12-12T12:28:10.784850Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (3-3)
2025-12-12T12:28:10.784941Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Commit offsets [2, 4). Partition stream id: 4
2025-12-12T12:28:10.785022Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-12-12T12:28:10.788124Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Committed response: cookies { assign_id: 3 partition_cookie: 1 }
2025-12-12T12:28:11.770283Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:3:4 null:test_restart_compute_node_output:0:3:0:0 null:test_restart_compute_node_output:3:2:0:4 null:test_restart_compute_node_output:2:1:0:2
2025-12-12T12:28:11.770326Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:12.664122Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:12.664635Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (4-4)
2025-12-12T12:28:12.664679Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (4-4)
2025-12-12T12:28:12.664758Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Commit offsets [4, 5). Partition stream id: 2
2025-12-12T12:28:12.664877Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:12.666968Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:12.667046Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (5-7)
2025-12-12T12:28:12.667081Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (5-5)
2025-12-12T12:28:12.667094Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (6-6)
2025-12-12T12:28:12.667102Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (7-7)
2025-12-12T12:28:12.667174Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Commit offsets [5, 8). Partition stream id: 2
2025-12-12T12:28:12.667268Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-12T12:28:12.667957Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:12.669423Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-12T12:28:18.644754Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:18.644838Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (2-2)
2025-12-12T12:28:18.644887Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (2-2)
2025-12-12T12:28:18.644954Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-12T12:28:18.645037Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:18.645303Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:18.645354Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (3-3)
2025-12-12T12:28:18.645391Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (3-3)
2025-12-12T12:28:18.645446Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-12T12:28:18.645546Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:18.645972Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-12T12:28:18.646783Z :DEBUG: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-12T12:28:18.647357Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:18.647394Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:3:4 null:test_restart_compute_node_output:0:3:0:0 null:test_restart_compute_node_output:3:2:7:8 null:test_restart_compute_node_output:2:1:3:4
2025-12-12T12:28:18.647408Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 7878 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:18.647683Z :NOTICE: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] 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:18.648495Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:18.648512Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:3:4 null:test_restart_compute_node_output:0:3:0:0 null:test_restart_compute_node_output:3:2:7:8 null:test_restart_compute_node_output:2:1:3:4
2025-12-12T12:28:18.648531Z :INFO: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 7879 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:18.648543Z :NOTICE: [local] [local] [b0fa955b-5ed609b5-1c4bc4c7-d288265c] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:14.969455Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Starting read session
2025-12-12T12:27:14.969511Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:14.970039Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:14.970054Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:14.970060Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:14.981990Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] Successfully connected. Initializing session
2025-12-12T12:27:14.983186Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] Server session id: test_start_new_query_consumer_1_5_5379831911278395119_v1
2025-12-12T12:27:14.983311Z :DEBUG: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:14.984617Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-12T12:27:15.968913Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:15.968964Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:2
2025-12-12T12:27:15.968977Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:15.969575Z :NOTICE: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] 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:15.969663Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:15.969672Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:2
2025-12-12T12:27:15.969680Z :INFO: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:15.969689Z :NOTICE: [local] [local] [cb23aad0-f3c7a4bc-efa37c89-a004b285] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:29:02.396659Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Starting read session
2025-12-12T12:29:02.396708Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Starting session to cluster null (localhost:5162)
2025-12-12T12:29:02.397167Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.397180Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.397186Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:29:02.402300Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Successfully connected. Initializing session
2025-12-12T12:29:02.403608Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_8_11041672276043910030_v1
2025-12-12T12:29:02.403677Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.404912Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:29:02.405120Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:29:02.405754Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.405815Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:29:02.405855Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-12T12:29:02.405864Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-12-12T12:29:02.405959Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:29:02.406040Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-12-12T12:29:02.408432Z :DEBUG: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:29:02.408582Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Closing read session. Close timeout: 5.000000s
2025-12-12T12:29:02.408629Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:0:2:0:0 null:test_idle_watermarks_no_shared_output:1:1:1:2
2025-12-12T12:29:02.408641Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:29:02.408873Z :NOTICE: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] 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:29:02.409025Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:29:02.409036Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:0:2:0:0 null:test_idle_watermarks_no_shared_output:1:1:1:2
2025-12-12T12:29:02.409045Z :INFO: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:29:02.409071Z :NOTICE: [local] [local] [c95a04f7-27f436eb-7aadf056-56a068b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:29:02.437544Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Starting read session
2025-12-12T12:29:02.437593Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Starting session to cluster null (localhost:28037)
2025-12-12T12:29:02.438006Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.438020Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.438026Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:29:02.442884Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Successfully connected. Initializing session
2025-12-12T12:29:02.444224Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Server session id: test_watermarks_no_shared_consumer_1_7_13437999283885737263_v1
2025-12-12T12:29:02.444278Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.445594Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:29:02.446482Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:29:02.446534Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:29:02.446581Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:29:02.446595Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:29:02.446690Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:29:02.446773Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-12-12T12:29:02.449227Z :DEBUG: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:29:02.449353Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Closing read session. Close timeout: 5.000000s
2025-12-12T12:29:02.449386Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:1:2
2025-12-12T12:29:02.449396Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:29:02.449602Z :NOTICE: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] 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:29:02.452909Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Closing read session. Close timeout: 0.000000s
2025-12-12T12:29:02.452925Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:1:2
2025-12-12T12:29:02.452934Z :INFO: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:29:02.452948Z :NOTICE: [local] [local] [faa6acb-7e87abc1-88b921f6-ad32ab45] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
