2025-12-09T03:45:03.225091Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Starting read session
2025-12-09T03:45:03.225150Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Starting session to cluster null (localhost:29962)
2025-12-09T03:45:03.225630Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:03.225642Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:03.225648Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:45:03.234049Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Successfully connected. Initializing session
2025-12-09T03:45:03.239007Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Server session id: disposition_from_time_consumer_1_13_9337329959500961024_v1
2025-12-09T03:45:03.239107Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:03.244683Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:45:03.249611Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:03.249686Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-09T03:45:03.249734Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:45:03.249746Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-09T03:45:03.250016Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-09T03:45:03.250132Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:45:03.263341Z :DEBUG: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:45:03.263574Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Closing read session. Close timeout: 5.000000s
2025-12-09T03:45:03.263607Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:5:6
2025-12-09T03:45:03.263617Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Counters: { Errors: 0 CurrentSessionLifetimeMs: 38 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:45:03.264014Z :NOTICE: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] 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:45:03.267302Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Closing read session. Close timeout: 0.000000s
2025-12-09T03:45:03.267319Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:5:6
2025-12-09T03:45:03.267330Z :INFO: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Counters: { Errors: 0 CurrentSessionLifetimeMs: 42 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:45:03.267341Z :NOTICE: [local] [local] [3b483bf5-223312e8-f94da03a-fbb0f751] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:45:09.478346Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Starting read session
2025-12-09T03:45:09.478387Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Starting session to cluster null (localhost:62047)
2025-12-09T03:45:09.478723Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:09.478733Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:09.478737Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:45:09.484872Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Successfully connected. Initializing session
2025-12-09T03:45:09.486922Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Server session id: disposition_time_ago_consumer_1_12_13827347921654249520_v1
2025-12-09T03:45:09.487015Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:09.488990Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:45:09.490189Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:09.490288Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-09T03:45:09.490331Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:45:09.490342Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-09T03:45:09.490442Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-09T03:45:09.490517Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:45:09.493470Z :DEBUG: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:45:09.493612Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Closing read session. Close timeout: 5.000000s
2025-12-09T03:45:09.493648Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:5:6
2025-12-09T03:45:09.493659Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:45:09.493909Z :NOTICE: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] 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:45:09.494159Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Closing read session. Close timeout: 0.000000s
2025-12-09T03:45:09.494173Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:5:6
2025-12-09T03:45:09.494183Z :INFO: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:45:09.494192Z :NOTICE: [local] [local] [7974973d-f00f4470-17b71751-491d4dbb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:40.477365Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Starting read session
2025-12-09T03:42:40.477415Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:40.477778Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.477790Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.477794Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:40.482631Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Successfully connected. Initializing session
2025-12-09T03:42:40.483861Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Server session id: test_3_session_consumer_1_11_8870670299501649741_v1
2025-12-09T03:42:40.483949Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.485321Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:40.486129Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.486189Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:42:40.486226Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:40.486236Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:42:40.486351Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:42:40.486434Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:40.488782Z :DEBUG: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:40.488890Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:40.488932Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:3:4
2025-12-09T03:42:40.488942Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:40.489121Z :NOTICE: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] 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.492429Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:40.492440Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:3:4
2025-12-09T03:42:40.492450Z :INFO: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:40.492461Z :NOTICE: [local] [local] [eda3692e-561157e6-a2f022be-266da27f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:03.901362Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Starting read session
2025-12-09T03:43:03.901420Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:03.901883Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.901898Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.901904Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:03.907745Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] Successfully connected. Initializing session
2025-12-09T03:43:03.910418Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] Server session id: test_filters_non_optional_field_consumer_1_11_4042316641799514049_v1
2025-12-09T03:43:03.910530Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.910976Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [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:43:04.906015Z :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:5
2025-12-09T03:43:04.906049Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1004 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:08.639959Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:08.640114Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-12-09T03:43:08.640168Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-12-09T03:43:08.640290Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] Commit offsets [5, 6). Partition stream id: 1
2025-12-09T03:43:08.640465Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:08.643514Z :DEBUG: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:08.644103Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:08.644152Z :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:5:6
2025-12-09T03:43:08.644165Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4742 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:08.644427Z :NOTICE: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] 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:08.644539Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:08.644553Z :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:5:6
2025-12-09T03:43:08.644580Z :INFO: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4743 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:08.644591Z :NOTICE: [local] [local] [91834385-e127df48-81c94a47-bd50f3c3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:57.367954Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Starting read session
2025-12-09T03:42:57.367991Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Starting session to cluster null (localhost:5893)
2025-12-09T03:42:57.368400Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.368412Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.368416Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:57.374028Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Successfully connected. Initializing session
2025-12-09T03:42:57.374960Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Server session id: test_restart_compute_node_consumer_1_22_2698904738034511542_v1
2025-12-09T03:42:57.375035Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:57.376321Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:42:57.376635Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:42:57.376737Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:57.376750Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:42:58.370241Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:0:0 null:test_restart_compute_node_output:0:3:0:6 null:test_restart_compute_node_output:3:2:0:12 null:test_restart_compute_node_output:2:1:0:6
2025-12-09T03:42:58.370280Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:02.405559Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:02.405645Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (6-6)
2025-12-09T03:43:02.405686Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (6-6)
2025-12-09T03:43:02.405795Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [6, 7). Partition stream id: 1
2025-12-09T03:43:02.405881Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:02.406130Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:02.406178Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-12-09T03:43:02.406214Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-09T03:43:02.406276Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [6, 7). Partition stream id: 3
2025-12-09T03:43:02.406344Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:02.406881Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:02.406935Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (12-12)
2025-12-09T03:43:02.406941Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-12-09T03:43:02.406986Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (12-12)
2025-12-09T03:43:02.407079Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-12-09T03:43:02.407103Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [12, 13). Partition stream id: 2
2025-12-09T03:43:02.407194Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:02.407222Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [7, 8). Partition stream id: 3
2025-12-09T03:43:02.407238Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:02.408769Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-09T03:43:02.408839Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-12-09T03:43:02.408953Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:02.408984Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 }
2025-12-09T03:43:02.408989Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (13-15)
2025-12-09T03:43:02.409009Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (13-13)
2025-12-09T03:43:02.409014Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:43:02.409018Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (14-14)
2025-12-09T03:43:02.409037Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (15-15)
2025-12-09T03:43:02.409081Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [13, 16). Partition stream id: 2
2025-12-09T03:43:02.409158Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-09T03:43:02.409458Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:02.409486Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (7-7)
2025-12-09T03:43:02.409504Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (7-7)
2025-12-09T03:43:02.409529Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Commit offsets [7, 8). Partition stream id: 1
2025-12-09T03:43:02.409570Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:02.410189Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-09T03:43:02.410416Z :DEBUG: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-09T03:43:02.410516Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:02.410534Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:0:0 null:test_restart_compute_node_output:0:3:7:8 null:test_restart_compute_node_output:3:2:15:16 null:test_restart_compute_node_output:2:1:7:8
2025-12-09T03:43:02.410554Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5042 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:02.410721Z :NOTICE: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] 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:02.410808Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:02.410816Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:0:0 null:test_restart_compute_node_output:0:3:7:8 null:test_restart_compute_node_output:3:2:15:16 null:test_restart_compute_node_output:2:1:7:8
2025-12-09T03:43:02.410822Z :INFO: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5042 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:02.410828Z :NOTICE: [local] [local] [6cc92ee4-2c6d28a-11bff989-80f0118a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:11.476756Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] Starting read session
2025-12-09T03:43:11.476818Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:11.477398Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.477414Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.477421Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:11.482298Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Successfully connected. Initializing session
2025-12-09T03:43:11.484343Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Server session id: test_start_new_query_consumer_1_7_111949406141646499_v1
2025-12-09T03:43:11.484462Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.486160Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:11.487021Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.487079Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:43:11.487120Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:43:11.487129Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:43:11.487229Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:43:11.487307Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-12-09T03:43:11.489888Z :DEBUG: [local] [local] [60e80927-362e93df-528be40a-1338db87] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:43:11.490006Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:11.490040Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:3:4
2025-12-09T03:43:11.490049Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:11.490364Z :NOTICE: [local] [local] [60e80927-362e93df-528be40a-1338db87] 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.490572Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:11.490591Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:3:4
2025-12-09T03:43:11.490602Z :INFO: [local] [local] [60e80927-362e93df-528be40a-1338db87] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:11.490614Z :NOTICE: [local] [local] [60e80927-362e93df-528be40a-1338db87] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
