2025-12-09T03:44:56.033790Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Starting read session
2025-12-09T03:44:56.033830Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Starting session to cluster null (localhost:29962)
2025-12-09T03:44:56.034227Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:56.034239Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:56.034245Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:56.041423Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Successfully connected. Initializing session
2025-12-09T03:44:56.042419Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Server session id: disposition_from_time_consumer_1_11_9708433953177946840_v1
2025-12-09T03:44:56.042518Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:56.043525Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:56.044207Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:56.044255Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:44:56.044301Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:44:56.044310Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:44:56.044429Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:44:56.044501Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:44:56.046530Z :DEBUG: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:56.046633Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:56.046670Z :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-09T03:44:56.046680Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:56.046862Z :NOTICE: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] 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-09T03:44:56.047008Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:56.047017Z :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-09T03:44:56.047035Z :INFO: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:56.047042Z :NOTICE: [local] [local] [ec0c7460-5ef5da75-b7c494ce-4d2bba94] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:39.178774Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Starting read session
2025-12-09T03:44:39.178838Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Starting session to cluster null (localhost:62047)
2025-12-09T03:44:39.179311Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:39.179326Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:39.179332Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:39.183852Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Successfully connected. Initializing session
2025-12-09T03:44:39.185065Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Server session id: disposition_time_ago_consumer_1_10_4433268019896787122_v1
2025-12-09T03:44:39.185154Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:39.186482Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:39.187348Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:39.187429Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:44:39.187466Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:44:39.187479Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:44:39.187564Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:44:39.187664Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:44:39.190297Z :DEBUG: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:39.190453Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:39.190483Z :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-09T03:44:39.190492Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:39.190842Z :NOTICE: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] 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-09T03:44:39.194117Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:39.194126Z :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-09T03:44:39.194132Z :INFO: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:39.194143Z :NOTICE: [local] [local] [6c90d225-c9648962-c3649972-7f56f716] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:10.286199Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Starting read session
2025-12-09T03:44:10.286234Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Starting session to cluster null (localhost:8635)
2025-12-09T03:44:10.286766Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:10.286780Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:10.286786Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:10.291898Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Successfully connected. Initializing session
2025-12-09T03:44:10.293054Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Server session id: test_time_order_recoverer[v1-kikimr0]_v1_consumer_1_14_6362491358317720126_v1
2025-12-09T03:44:10.293160Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:10.294635Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [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-09T03:44:11.287296Z :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-09T03:44:11.287339Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:27.444325Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:27.444401Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:44:27.444444Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:44:27.445060Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:27.445102Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:44:27.445128Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-12-09T03:44:27.445213Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] The application data is transferred to the client. Number of messages 1, size 23 bytes
2025-12-09T03:44:27.445226Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-09T03:44:27.445238Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-12-09T03:44:27.445266Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Commit offsets [1, 3). Partition stream id: 1
2025-12-09T03:44:27.445319Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] The application data is transferred to the client. Number of messages 2, size 46 bytes
2025-12-09T03:44:27.448316Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:44:27.448415Z :DEBUG: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-12-09T03:44:27.448528Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:27.448557Z :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-09T03:44:27.448575Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17162 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:27.448799Z :NOTICE: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] 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-09T03:44:27.448929Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:27.448939Z :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-09T03:44:27.448947Z :INFO: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17162 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:27.448955Z :NOTICE: [local] [local] [b09352-bcfce554-edef7e9f-c61dcc69] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:51.251766Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Starting read session
2025-12-09T03:42:51.251827Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Starting session to cluster null (localhost:6559)
2025-12-09T03:42:51.252193Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:51.252203Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:51.252207Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:51.257457Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Successfully connected. Initializing session
2025-12-09T03:42:51.258697Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Server session id: restart_1_consumer_1_14_18056953756798092320_v1
2025-12-09T03:42:51.258826Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:51.260087Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_1_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:51.260777Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:51.260838Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:42:51.260885Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:51.260980Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:42:51.261088Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-12-09T03:42:51.263781Z :DEBUG: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:42:51.263925Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:51.263960Z :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-09T03:42:51.263971Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:51.264184Z :NOTICE: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] 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-09T03:42:51.264274Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:51.264280Z :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-09T03:42:51.264289Z :INFO: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:51.264296Z :NOTICE: [local] [local] [a8243761-cc81c0b9-7ac241a7-af5cd1d1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:39.373452Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Starting read session
2025-12-09T03:42:39.373499Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:39.374100Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.374122Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.374129Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:39.380264Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] Successfully connected. Initializing session
2025-12-09T03:42:39.381680Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] Server session id: test_3_session_consumer_1_10_9234810356474320960_v1
2025-12-09T03:42:39.381796Z :DEBUG: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.383162Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] [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-09T03:42:40.372184Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:40.372252Z :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-09T03:42:40.372264Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Counters: { Errors: 0 CurrentSessionLifetimeMs: 998 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:40.372562Z :NOTICE: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] 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-09T03:42:40.375915Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:40.375932Z :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-09T03:42:40.375943Z :INFO: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:40.375957Z :NOTICE: [local] [local] [1d3e5cf6-627616f2-68377140-f971a737] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:57.420388Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Starting read session
2025-12-09T03:42:57.420450Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Starting session to cluster null (localhost:15610)
2025-12-09T03:42:57.420907Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.420921Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.420927Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:57.426275Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Successfully connected. Initializing session
2025-12-09T03:42:57.427261Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Server session id: test_filters_non_optional_field_consumer_1_9_15326613221669766623_v1
2025-12-09T03:42:57.427355Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.428797Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:58.421306Z :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-09T03:42:58.421348Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:01.024680Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:01.024758Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-12-09T03:43:01.024798Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:43:01.024973Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Commit offsets [4, 5). Partition stream id: 1
2025-12-09T03:43:01.025157Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:01.027616Z :DEBUG: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:01.027773Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:01.027803Z :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-09T03:43:01.027816Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3607 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:01.028146Z :NOTICE: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] 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-09T03:43:01.028252Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:01.028264Z :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-09T03:43:01.028285Z :INFO: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3607 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:01.028296Z :NOTICE: [local] [local] [4ffd4789-d838c8f3-68c38f42-c1eb1bd5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:48.558505Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Starting read session
2025-12-09T03:42:48.558574Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Starting session to cluster null (localhost:5893)
2025-12-09T03:42:48.559103Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:48.559119Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:48.559126Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:48.564683Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Successfully connected. Initializing session
2025-12-09T03:42:48.566143Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Server session id: test_restart_compute_node_consumer_1_18_15317290134988230155_v1
2025-12-09T03:42:48.566194Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:48.567707Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:42:48.567924Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:42:48.567994Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:42:48.568006Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:49.559253Z :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:4 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:0
2025-12-09T03:42:49.559288Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:53.421237Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.421312Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (4-4)
2025-12-09T03:42:53.421367Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (4-4)
2025-12-09T03:42:53.421511Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [4, 5). Partition stream id: 2
2025-12-09T03:42:53.421630Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.421886Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.422034Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (8-8)
2025-12-09T03:42:53.422073Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (8-8)
2025-12-09T03:42:53.422091Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (5-5)
2025-12-09T03:42:53.422099Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (5-5)
2025-12-09T03:42:53.422115Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [8, 9). Partition stream id: 3
2025-12-09T03:42:53.422130Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-12-09T03:42:53.422217Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:42:53.422218Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.422268Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [5, 6). Partition stream id: 2
2025-12-09T03:42:53.422275Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.422292Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [4, 5). Partition stream id: 4
2025-12-09T03:42:53.422308Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.422502Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.425032Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-09T03:42:53.425262Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.425308Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:53.425328Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-12-09T03:42:53.425338Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-09T03:42:53.425410Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-12-09T03:42:53.425434Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (9-9)
2025-12-09T03:42:53.425444Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (9-9)
2025-12-09T03:42:53.425486Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-12-09T03:42:53.425521Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [5, 6). Partition stream id: 4
2025-12-09T03:42:53.425847Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.425897Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [9, 10). Partition stream id: 3
2025-12-09T03:42:53.425904Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.426036Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.426087Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (10-11)
2025-12-09T03:42:53.426108Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (10-10)
2025-12-09T03:42:53.426117Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (11-11)
2025-12-09T03:42:53.426731Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Commit offsets [10, 12). Partition stream id: 3
2025-12-09T03:42:53.426804Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-12-09T03:42:53.427151Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 }
2025-12-09T03:42:53.427895Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-09T03:42:53.428658Z :DEBUG: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 3 }
Closing session. Got 8 messages
2025-12-09T03:42:53.428753Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:53.428779Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:5:6 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:0:0
2025-12-09T03:42:53.428789Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4870 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:53.429200Z :NOTICE: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] 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-09T03:42:53.429388Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:53.429410Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:5:6 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:0:0
2025-12-09T03:42:53.429419Z :INFO: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4870 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:53.429431Z :NOTICE: [local] [local] [f05dedbe-7ade1607-4b1035cb-eab3093a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:11.363899Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Starting read session
2025-12-09T03:43:11.363945Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:11.364393Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.364407Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.364413Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:11.369305Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Successfully connected. Initializing session
2025-12-09T03:43:11.370457Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Server session id: test_start_new_query_consumer_1_6_11233587157808901372_v1
2025-12-09T03:43:11.370554Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.372147Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:11.373017Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.373066Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:43:11.373104Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:43:11.373115Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:43:11.373229Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:43:11.373328Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-12-09T03:43:11.375838Z :DEBUG: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:43:11.375950Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:11.375980Z :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-09T03:43:11.375990Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:11.376221Z :NOTICE: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] 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-09T03:43:11.376335Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:11.376344Z :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-09T03:43:11.376360Z :INFO: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:11.376369Z :NOTICE: [local] [local] [4721e2c4-3194a73e-3e1021bd-7393f888] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
