2025-12-12T12:30:54.520987Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Starting read session
2025-12-12T12:30:54.521017Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Starting session to cluster null (localhost:23455)
2025-12-12T12:30:54.521325Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:30:54.521342Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:30:54.521345Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:30:54.525404Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Successfully connected. Initializing session
2025-12-12T12:30:54.526301Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Server session id: continue_2_consumer_1_9_4048594121038319026_v1
2025-12-12T12:30:54.526364Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:30:54.527644Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "continue_2_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:30:54.527781Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "continue_2_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:30:54.528305Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:30:54.528350Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-3)
2025-12-12T12:30:54.528376Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-12T12:30:54.528395Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-12-12T12:30:54.528401Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (2-2)
2025-12-12T12:30:54.528404Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (3-3)
2025-12-12T12:30:54.528481Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Commit offsets [0, 4). Partition stream id: 1
2025-12-12T12:30:54.528553Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] The application data is transferred to the client. Number of messages 4, size 4 bytes
2025-12-12T12:30:54.530696Z :DEBUG: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 4 messages
2025-12-12T12:30:54.530788Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Closing read session. Close timeout: 5.000000s
2025-12-12T12:30:54.530809Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_2_output:0:2:0:0 null:continue_2_output:1:1:3:4
2025-12-12T12:30:54.530815Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 9 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:30:54.530955Z :NOTICE: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] 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:30:54.531057Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Closing read session. Close timeout: 0.000000s
2025-12-12T12:30:54.531072Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_2_output:0:2:0:0 null:continue_2_output:1:1:3:4
2025-12-12T12:30:54.531090Z :INFO: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 10 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:30:54.531097Z :NOTICE: [local] [local] [b6799465-a487e918-ed420946-eb3b43a1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:32:10.019685Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Starting read session
2025-12-12T12:32:10.019731Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Starting session to cluster null (localhost:64299)
2025-12-12T12:32:10.020063Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:32:10.020073Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:32:10.020077Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:32:10.024008Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] Successfully connected. Initializing session
2025-12-12T12:32:10.025237Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] Server session id: disposition_fresh_consumer_1_7_4571311205465974173_v1
2025-12-12T12:32:10.025426Z :DEBUG: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:32:10.026559Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_fresh_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:32:11.020162Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-12-12T12:32:11.020197Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-12-12T12:32:40.019351Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Closing read session. Close timeout: 5.000000s
2025-12-12T12:32:40.019393Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-12-12T12:32:40.019415Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:32:40.019679Z :NOTICE: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] 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:32:40.019806Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Closing read session. Close timeout: 0.000000s
2025-12-12T12:32:40.019814Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-12-12T12:32:40.019820Z :INFO: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:32:40.019830Z :NOTICE: [local] [local] [7d35ab85-d1606227-23d2646d-9da42dbc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:26:50.377060Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Starting read session
2025-12-12T12:26:50.377122Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Starting session to cluster null (localhost:12669)
2025-12-12T12:26:50.377693Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:50.378319Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:50.378334Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:26:50.387518Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Successfully connected. Initializing session
2025-12-12T12:26:50.390320Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Server session id: disposition_oldest_consumer_1_6_4570978178233060577_v1
2025-12-12T12:26:50.390415Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:50.392428Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_oldest_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:26:50.393112Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:50.393179Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-11)
2025-12-12T12:26:50.393222Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-12T12:26:50.393234Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-12-12T12:26:50.393243Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (8-8)
2025-12-12T12:26:50.393249Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (9-9)
2025-12-12T12:26:50.393257Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (10-10)
2025-12-12T12:26:50.393262Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (11-11)
2025-12-12T12:26:50.393401Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Commit offsets [6, 12). Partition stream id: 1
2025-12-12T12:26:50.393510Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] The application data is transferred to the client. Number of messages 6, size 6 bytes
2025-12-12T12:26:50.396969Z :DEBUG: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 6 messages
2025-12-12T12:26:50.397142Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Closing read session. Close timeout: 5.000000s
2025-12-12T12:26:50.397182Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:11:12
2025-12-12T12:26:50.397194Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Counters: { Errors: 0 CurrentSessionLifetimeMs: 20 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:26:50.397395Z :NOTICE: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] 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:26:50.397546Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:50.397558Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:11:12
2025-12-12T12:26:50.397571Z :INFO: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Counters: { Errors: 0 CurrentSessionLifetimeMs: 20 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:50.397592Z :NOTICE: [local] [local] [a2297494-869c672a-5b93d39f-1a2ea849] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:26:53.441958Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Starting read session
2025-12-12T12:26:53.442006Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Starting session to cluster null (localhost:10793)
2025-12-12T12:26:53.442549Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:53.442566Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:53.442573Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:26:53.451364Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Successfully connected. Initializing session
2025-12-12T12:26:53.474533Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Server session id: pq_test_pq_read_write_True_consumer_1_6_702974732672054052_v1
2025-12-12T12:26:53.474624Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:53.479080Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_True_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:26:53.480801Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:53.499395Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-7)
2025-12-12T12:26:53.499450Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:26:53.499461Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:26:53.499468Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-12T12:26:53.499474Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-12T12:26:53.499494Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-12-12T12:26:53.499500Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (5-5)
2025-12-12T12:26:53.499505Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 5} (6-6)
2025-12-12T12:26:53.499511Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 6} (7-7)
2025-12-12T12:26:53.499662Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Commit offsets [0, 8). Partition stream id: 1
2025-12-12T12:26:53.499804Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] The application data is transferred to the client. Number of messages 8, size 163 bytes
2025-12-12T12:26:53.503424Z :DEBUG: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 8 messages
2025-12-12T12:26:53.504741Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Closing read session. Close timeout: 5.000000s
2025-12-12T12:26:53.504787Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_True_output:0:1:7:8
2025-12-12T12:26:53.504798Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Counters: { Errors: 0 CurrentSessionLifetimeMs: 62 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:26:53.505021Z :NOTICE: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] 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:26:53.513306Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:53.513329Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_True_output:0:1:7:8
2025-12-12T12:26:53.513364Z :INFO: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Counters: { Errors: 0 CurrentSessionLifetimeMs: 71 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:53.513380Z :NOTICE: [local] [local] [eb49ec37-b02705d5-3595bf7c-ab27b439] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:26:54.117224Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Starting read session
2025-12-12T12:26:54.117269Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Starting session to cluster null (localhost:25827)
2025-12-12T12:26:54.117745Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:54.117760Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:54.117766Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:26:54.123699Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Successfully connected. Initializing session
2025-12-12T12:26:54.124874Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Server session id: recovery_consumer_1_9_5664294036315321128_v1
2025-12-12T12:26:54.125041Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:54.127605Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "recovery_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:26:54.127766Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "recovery_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:26:54.128739Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:54.128797Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-13)
2025-12-12T12:26:54.128834Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-12T12:26:54.128842Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-12-12T12:26:54.128849Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (8-8)
2025-12-12T12:26:54.128854Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (9-9)
2025-12-12T12:26:54.128861Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (10-10)
2025-12-12T12:26:54.128866Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 1} (11-11)
2025-12-12T12:26:54.128871Z :DEBUG: [local] Take Data. Partition 0. Read: {4, 0} (12-12)
2025-12-12T12:26:54.128875Z :DEBUG: [local] Take Data. Partition 0. Read: {5, 0} (13-13)
2025-12-12T12:26:54.129007Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Commit offsets [6, 14). Partition stream id: 1
2025-12-12T12:26:54.129083Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] The application data is transferred to the client. Number of messages 8, size 16 bytes
2025-12-12T12:26:54.129399Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:54.129450Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (14-15)
2025-12-12T12:26:54.129492Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (14-14)
2025-12-12T12:26:54.129500Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (15-15)
2025-12-12T12:26:54.129571Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Commit offsets [14, 16). Partition stream id: 2
2025-12-12T12:26:54.129663Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] The application data is transferred to the client. Number of messages 2, size 4 bytes
2025-12-12T12:26:54.133429Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-12T12:26:54.133548Z :DEBUG: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-12-12T12:26:54.133734Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Closing read session. Close timeout: 5.000000s
2025-12-12T12:26:54.133765Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:recovery_output:1:2:15:16 null:recovery_output:0:1:13:14
2025-12-12T12:26:54.133776Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:26:54.133994Z :NOTICE: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] 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:26:54.134107Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:54.134116Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:recovery_output:1:2:15:16 null:recovery_output:0:1:13:14
2025-12-12T12:26:54.134123Z :INFO: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:54.134130Z :NOTICE: [local] [local] [a2abd12f-1ebee67f-98472e41-2ab5c4a4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:07.537797Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Starting read session
2025-12-12T12:27:07.537979Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Starting session to cluster null (localhost:29692)
2025-12-12T12:27:07.539186Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:07.539202Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:07.539209Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:07.559155Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Successfully connected. Initializing session
2025-12-12T12:27:07.560422Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Server session id: pq_kikimr_streaming_v1_consumer_1_9_10683646564492598485_v1
2025-12-12T12:27:07.562416Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:07.563305Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:07.563935Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:27:07.565940Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:07.566026Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (20-29)
2025-12-12T12:27:07.566075Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (20-20)
2025-12-12T12:27:07.566105Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (21-21)
2025-12-12T12:27:07.566114Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (22-22)
2025-12-12T12:27:07.566119Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (23-23)
2025-12-12T12:27:07.566129Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 0} (24-24)
2025-12-12T12:27:07.566135Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 1} (25-25)
2025-12-12T12:27:07.566140Z :DEBUG: [local] Take Data. Partition 1. Read: {5, 0} (26-26)
2025-12-12T12:27:07.566145Z :DEBUG: [local] Take Data. Partition 1. Read: {5, 1} (27-27)
2025-12-12T12:27:07.566152Z :DEBUG: [local] Take Data. Partition 1. Read: {5, 2} (28-28)
2025-12-12T12:27:07.566162Z :DEBUG: [local] Take Data. Partition 1. Read: {5, 3} (29-29)
2025-12-12T12:27:07.566293Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Commit offsets [20, 30). Partition stream id: 2
2025-12-12T12:27:07.566463Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] The application data is transferred to the client. Number of messages 10, size 20 bytes
2025-12-12T12:27:07.569647Z :DEBUG: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-12-12T12:27:07.569812Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:07.569867Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:29:30 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-12-12T12:27:07.569880Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 32 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:07.570325Z :NOTICE: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] 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:07.570576Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:07.570594Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:29:30 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-12-12T12:27:07.570609Z :INFO: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 32 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:07.570621Z :NOTICE: [local] [local] [58380f60-e69bcea2-7f22baa7-dc877e7c] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:17.737349Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Starting read session
2025-12-12T12:28:17.737418Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:17.737974Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.737989Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.737995Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:17.749786Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Successfully connected. Initializing session
2025-12-12T12:28:17.751646Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Server session id: test_3_session_consumer_1_8_1116802366242165180_v1
2025-12-12T12:28:17.751767Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.753069Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:17.756117Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:17.756204Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:28:17.756256Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:28:17.756275Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:28:17.756439Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:28:17.757500Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:17.760430Z :DEBUG: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:17.760589Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:17.760662Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:1:2
2025-12-12T12:28:17.760678Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Counters: { Errors: 0 CurrentSessionLifetimeMs: 23 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:17.761136Z :NOTICE: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] 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.761250Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:17.761261Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:1:2
2025-12-12T12:28:17.761284Z :INFO: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Counters: { Errors: 0 CurrentSessionLifetimeMs: 23 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:17.761294Z :NOTICE: [local] [local] [a2a2aa13-5c225faa-a430a92-3d3aa044] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:36.584150Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Starting read session
2025-12-12T12:27:36.584214Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Starting session to cluster null (localhost:9655)
2025-12-12T12:27:36.584727Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.584741Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.584747Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:36.591266Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Successfully connected. Initializing session
2025-12-12T12:27:36.592374Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Server session id: test_filter_missing_fields_consumer_1_5_14014456665865630226_v1
2025-12-12T12:27:36.592455Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.594033Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filter_missing_fields_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:37.586366Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:0:0
2025-12-12T12:27:37.586406Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:40.640287Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:40.641235Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:40.641305Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:27:40.641353Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:40.641377Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-12T12:27:40.641385Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T12:27:40.641519Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:27:40.641699Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:40.641759Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Commit offsets [1, 2). Partition stream id: 1
2025-12-12T12:27:40.641767Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:27:40.645920Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:27:40.646437Z :DEBUG: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-12T12:27:40.646654Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:40.646718Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:1:2
2025-12-12T12:27:40.646732Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4062 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:40.647093Z :NOTICE: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] 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:40.647236Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:40.647247Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:1:2
2025-12-12T12:27:40.647256Z :INFO: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4063 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:40.647266Z :NOTICE: [local] [local] [8c8bd2d3-4f87d3e4-1280be3b-c9e442a5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:35:31.337298Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Starting read session
2025-12-12T12:35:31.347387Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Starting session to cluster null (localhost:63390)
2025-12-12T12:35:31.348154Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:31.348168Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:31.348176Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:35:31.354659Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] Successfully connected. Initializing session
2025-12-12T12:35:31.357516Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] Server session id: test_filters_non_optional_field_consumer_1_5_14192291901178130710_v1
2025-12-12T12:35:31.358869Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:31.359506Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [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:32.350646Z :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:2
2025-12-12T12:35:32.353716Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1013 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:35.761191Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:35.763181Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-12T12:35:35.763243Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:35:35.763360Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-12T12:35:35.763489Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:35:35.766950Z :DEBUG: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:35:35.772245Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Closing read session. Close timeout: 5.000000s
2025-12-12T12:35:35.772281Z :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:2:3
2025-12-12T12:35:35.772303Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4435 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:35:35.773608Z :NOTICE: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] 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:35.775207Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Closing read session. Close timeout: 0.000000s
2025-12-12T12:35:35.775229Z :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:2:3
2025-12-12T12:35:35.775253Z :INFO: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4437 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:35.775267Z :NOTICE: [local] [local] [1aaec589-c26cc37c-5fbdaa93-6e119c27] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:31.673499Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Starting read session
2025-12-12T12:27:31.674209Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Starting session to cluster null (localhost:4719)
2025-12-12T12:27:31.674881Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:31.675609Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:31.675627Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:31.681287Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Successfully connected. Initializing session
2025-12-12T12:27:31.682476Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Server session id: test_read_raw_format_with_row_dispatcher_consumer_1_5_13636456327081222404_v1
2025-12-12T12:27:31.682524Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:31.684894Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_read_raw_format_with_row_dispatcher_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:32.675266Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:0:2
2025-12-12T12:27:32.675311Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:36.516672Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.516777Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-12T12:27:36.516825Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:27:36.518573Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-12T12:27:36.518743Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-12-12T12:27:36.519307Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:36.523063Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-12T12:27:36.523120Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-12T12:27:36.524757Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:27:36.527097Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-12T12:27:36.527230Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-12-12T12:27:36.528662Z :DEBUG: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-12T12:27:36.528842Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:36.528872Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:3:4
2025-12-12T12:27:36.528886Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4855 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:36.529114Z :NOTICE: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] 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.529312Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:36.529327Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:3:4
2025-12-12T12:27:36.529337Z :INFO: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4855 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:36.529349Z :NOTICE: [local] [local] [42c4cc1d-d18c2bb9-c3eaf160-1b9730b6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:02.077874Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Starting read session
2025-12-12T12:28:02.077916Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Starting session to cluster null (localhost:8973)
2025-12-12T12:28:02.078509Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:02.078523Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:02.078530Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:02.100799Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Successfully connected. Initializing session
2025-12-12T12:28:02.102047Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Server session id: test_restart_compute_node_consumer_1_9_4732566594829063805_v1
2025-12-12T12:28:02.102313Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:02.103928Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:02.104735Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [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:02.104825Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:28:02.106849Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:28:03.079236Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:0:0 null:test_restart_compute_node_output:1:3:0:0 null:test_restart_compute_node_output:2:2:0:0 null:test_restart_compute_node_output:0:1:0:0
2025-12-12T12:28:03.079272Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:06.127316Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:06.127431Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (0-0)
2025-12-12T12:28:06.127493Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (0-0)
2025-12-12T12:28:06.127646Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [0, 1). Partition stream id: 4
2025-12-12T12:28:06.127787Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.129616Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:06.129697Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-12-12T12:28:06.129726Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (0-0)
2025-12-12T12:28:06.129741Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-12T12:28:06.129770Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (0-0)
2025-12-12T12:28:06.129770Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (1-3)
2025-12-12T12:28:06.129804Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (1-1)
2025-12-12T12:28:06.129814Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (2-2)
2025-12-12T12:28:06.129823Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (3-3)
2025-12-12T12:28:06.129831Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [0, 1). Partition stream id: 3
2025-12-12T12:28:06.129962Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.130000Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [0, 1). Partition stream id: 2
2025-12-12T12:28:06.130055Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.130084Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [1, 4). Partition stream id: 4
2025-12-12T12:28:06.130141Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-12T12:28:06.131887Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:06.132079Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:06.132145Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (1-1)
2025-12-12T12:28:06.132175Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (1-1)
2025-12-12T12:28:06.132217Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-12-12T12:28:06.132226Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (1-1)
2025-12-12T12:28:06.132280Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [1, 2). Partition stream id: 2
2025-12-12T12:28:06.132395Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.132439Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Commit offsets [1, 2). Partition stream id: 3
2025-12-12T12:28:06.132498Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.133210Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 3 partition_cookie: 1 }
2025-12-12T12:28:06.133291Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-12T12:28:06.133322Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-12T12:28:06.134207Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-12T12:28:06.135476Z :DEBUG: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] [null] Committed response: cookies { assign_id: 3 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-12T12:28:06.135599Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:06.135632Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:3:4 null:test_restart_compute_node_output:1:3:1:2 null:test_restart_compute_node_output:2:2:1:2 null:test_restart_compute_node_output:0:1:0:0
2025-12-12T12:28:06.135647Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4057 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:06.135905Z :NOTICE: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] 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:06.136028Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:06.136046Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:3:4 null:test_restart_compute_node_output:1:3:1:2 null:test_restart_compute_node_output:2:2:1:2 null:test_restart_compute_node_output:0:1:0:0
2025-12-12T12:28:06.136054Z :INFO: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4058 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:06.136063Z :NOTICE: [local] [local] [6f038b2d-3bbc7d8d-8b3139ea-e5a69cac] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:13.859309Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Starting read session
2025-12-12T12:27:13.859354Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:13.859864Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:13.859877Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:13.859884Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:13.866258Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] Successfully connected. Initializing session
2025-12-12T12:27:13.867466Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] Server session id: test_start_new_query_consumer_1_4_8259069028130066637_v1
2025-12-12T12:27:13.868035Z :DEBUG: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:13.869154Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-12T12:27:14.858382Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:14.858454Z :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:14.858468Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] 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:14.858804Z :NOTICE: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] 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:14.858920Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:14.858929Z :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:14.858946Z :INFO: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:14.858957Z :NOTICE: [local] [local] [f3ed77bf-5d1b34ad-d1bbe147-783f4ac7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:01.085894Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Starting read session
2025-12-12T12:28:01.085946Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Starting session to cluster null (localhost:9685)
2025-12-12T12:28:01.086471Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:01.086486Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:01.086492Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:01.091851Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Successfully connected. Initializing session
2025-12-12T12:28:01.092888Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Server session id: test_stop_start_with_filter_consumer_1_7_7572139248943560724_v1
2025-12-12T12:28:01.092954Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:01.095617Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_with_filter_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:02.087306Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:0:0
2025-12-12T12:28:02.087346Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:06.029642Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:06.029749Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:28:06.029839Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:28:06.030413Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:06.030497Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-12T12:28:06.030556Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-12T12:28:06.031146Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:28:06.031238Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.031273Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Commit offsets [1, 2). Partition stream id: 1
2025-12-12T12:28:06.031311Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:06.033717Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:06.033806Z :DEBUG: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-12T12:28:06.033883Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:06.033909Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:1:2
2025-12-12T12:28:06.033920Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4948 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:06.034160Z :NOTICE: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] 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:06.034290Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:06.034298Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:1:2
2025-12-12T12:28:06.034305Z :INFO: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4948 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:06.034313Z :NOTICE: [local] [local] [7cd47fee-7045e392-7a9fcf1d-b48fc0b2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:30.305819Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Starting read session
2025-12-12T12:28:30.305855Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Starting session to cluster null (localhost:5162)
2025-12-12T12:28:30.306263Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.306274Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.306281Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:30.312524Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] Successfully connected. Initializing session
2025-12-12T12:28:30.316441Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_7_17725851542720168594_v1
2025-12-12T12:28:30.316533Z :DEBUG: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.318459Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [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:28:30.318758Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] [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:28:31.307261Z :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:0:0
2025-12-12T12:28:31.307307Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-12-12T12:29:00.305350Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Closing read session. Close timeout: 5.000000s
2025-12-12T12:29:00.305398Z :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:0:0
2025-12-12T12:29:00.305410Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:29:00.305965Z :NOTICE: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] 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:00.306110Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:29:00.306122Z :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:0:0
2025-12-12T12:29:00.306129Z :INFO: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:29:00.306139Z :NOTICE: [local] [local] [cb0dbab5-3d8c2f4e-6dc1960b-19e7493b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:30.368273Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Starting read session
2025-12-12T12:28:30.368338Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Starting session to cluster null (localhost:28037)
2025-12-12T12:28:30.368982Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.368998Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.369005Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:30.378578Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] Successfully connected. Initializing session
2025-12-12T12:28:30.379873Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] Server session id: test_watermarks_no_shared_consumer_1_6_13586376294923833858_v1
2025-12-12T12:28:30.379981Z :DEBUG: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:30.381287Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:31.371267Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-12-12T12:28:31.371299Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-12-12T12:29:00.367643Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Closing read session. Close timeout: 5.000000s
2025-12-12T12:29:00.367696Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-12-12T12:29:00.367708Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:29:00.368053Z :NOTICE: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] 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:00.368242Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Closing read session. Close timeout: 0.000000s
2025-12-12T12:29:00.368252Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-12-12T12:29:00.368260Z :INFO: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:29:00.368280Z :NOTICE: [local] [local] [30efc6f5-b0c79540-22789bb3-93c9159e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:26:44.290533Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Starting read session
2025-12-12T12:26:44.290570Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Starting session to cluster null (localhost:31370)
2025-12-12T12:26:44.291026Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:44.291041Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:44.291047Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:26:44.297317Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Successfully connected. Initializing session
2025-12-12T12:26:44.298624Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Server session id: test_state_load_mode2_consumer_1_6_8350050350382204137_v1
2025-12-12T12:26:44.298767Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:44.300416Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_state_load_mode2_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:26:44.301483Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:26:44.301533Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-12T12:26:44.301577Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:26:44.301697Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-12T12:26:44.301783Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-12-12T12:26:44.304675Z :DEBUG: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:26:44.304854Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Closing read session. Close timeout: 5.000000s
2025-12-12T12:26:44.304893Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_state_load_mode2_output:0:1:0:1
2025-12-12T12:26:44.304924Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:26:44.305157Z :NOTICE: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] 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:26:44.308745Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:44.308762Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_state_load_mode2_output:0:1:0:1
2025-12-12T12:26:44.308771Z :INFO: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:44.308792Z :NOTICE: [local] [local] [86d81bce-2c9f222b-5fbfe7b4-b1f79dac] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
