2025-12-09T03:45:51.838607Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Starting read session
2025-12-09T03:45:51.838654Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Starting session to cluster null (localhost:31865)
2025-12-09T03:45:51.839093Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:51.839105Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:51.839111Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:45:51.844566Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Successfully connected. Initializing session
2025-12-09T03:45:51.845470Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Server session id: continue_2_consumer_1_9_145223918629924642_v1
2025-12-09T03:45:51.845551Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:51.847002Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "continue_2_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:45:51.847212Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "continue_2_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:45:51.850707Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:45:51.850762Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-3)
2025-12-09T03:45:51.850806Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-09T03:45:51.850814Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-12-09T03:45:51.850819Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (2-2)
2025-12-09T03:45:51.850823Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (3-3)
2025-12-09T03:45:51.850924Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Commit offsets [0, 4). Partition stream id: 1
2025-12-09T03:45:51.851023Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] The application data is transferred to the client. Number of messages 4, size 4 bytes
2025-12-09T03:45:51.853220Z :DEBUG: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 4 messages
2025-12-09T03:45:51.853338Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Closing read session. Close timeout: 5.000000s
2025-12-09T03:45:51.853367Z :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-09T03:45:51.853375Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:45:51.853574Z :NOTICE: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] 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:51.853703Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Closing read session. Close timeout: 0.000000s
2025-12-09T03:45:51.853714Z :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-09T03:45:51.853731Z :INFO: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:45:51.853741Z :NOTICE: [local] [local] [bab3a479-5d19bdd5-55df4eea-a08d786c] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:57.842975Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Starting read session
2025-12-09T03:43:57.843008Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Starting session to cluster null (localhost:29962)
2025-12-09T03:43:57.843408Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:57.843421Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:57.843427Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:57.848182Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] Successfully connected. Initializing session
2025-12-09T03:43:57.849104Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] Server session id: disposition_fresh_consumer_1_7_3282516358626731063_v1
2025-12-09T03:43:57.849163Z :DEBUG: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:57.850298Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_fresh_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:58.844256Z :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-09T03:43:58.844296Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] 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-09T03:44:27.842601Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:27.842657Z :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-09T03:44:27.842673Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:27.842947Z :NOTICE: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-09T03:44:27.843101Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:27.843112Z :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-09T03:44:27.843120Z :INFO: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:27.843133Z :NOTICE: [local] [local] [2e916bc5-4c732b8f-ddc6f31f-c5a1a046] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:49.050448Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Starting read session
2025-12-09T03:43:49.050481Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Starting session to cluster null (localhost:62047)
2025-12-09T03:43:49.050795Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:49.050804Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:49.050809Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:49.055678Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Successfully connected. Initializing session
2025-12-09T03:43:49.056628Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Server session id: disposition_oldest_consumer_1_6_3426669636892140088_v1
2025-12-09T03:43:49.056678Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:49.057855Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_oldest_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:49.058859Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:49.058924Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-11)
2025-12-09T03:43:49.058957Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-09T03:43:49.058968Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-12-09T03:43:49.058973Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (8-8)
2025-12-09T03:43:49.058977Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (9-9)
2025-12-09T03:43:49.058983Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (10-10)
2025-12-09T03:43:49.058986Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (11-11)
2025-12-09T03:43:49.059091Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Commit offsets [6, 12). Partition stream id: 1
2025-12-09T03:43:49.059184Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] The application data is transferred to the client. Number of messages 6, size 6 bytes
2025-12-09T03:43:49.061969Z :DEBUG: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 6 messages
2025-12-09T03:43:49.062129Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:49.062167Z :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-09T03:43:49.062177Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:49.062389Z :NOTICE: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] 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:49.062479Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:49.062488Z :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-09T03:43:49.062498Z :INFO: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:49.062514Z :NOTICE: [local] [local] [bcc0cebd-8157b158-590fe0c2-ba2c77a1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:06.499161Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Starting read session
2025-12-09T03:43:06.499211Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Starting session to cluster null (localhost:32293)
2025-12-09T03:43:06.499802Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.499817Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.499823Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:06.515363Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] Successfully connected. Initializing session
2025-12-09T03:43:06.521011Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] Server session id: pq_test_pq_read_write_True_consumer_1_6_17673142074469528108_v1
2025-12-09T03:43:06.521115Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.525166Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [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-09T03:43:06.527377Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.527486Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-7)
2025-12-09T03:43:06.527511Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:06.527524Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:43:06.527532Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-09T03:43:06.527540Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-09T03:43:06.527552Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-12-09T03:43:06.527560Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (5-5)
2025-12-09T03:43:06.527568Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 5} (6-6)
2025-12-09T03:43:06.527575Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 6} (7-7)
2025-12-09T03:43:06.527923Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] Commit offsets [0, 8). Partition stream id: 1
2025-12-09T03:43:06.528090Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] The application data is transferred to the client. Number of messages 8, size 163 bytes
2025-12-09T03:43:06.531776Z :DEBUG: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 8 messages
2025-12-09T03:43:06.534699Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:06.534744Z :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-09T03:43:06.534756Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 35 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:06.535076Z :NOTICE: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] 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:06.535712Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:06.535733Z :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-09T03:43:06.535757Z :INFO: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 36 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:06.535769Z :NOTICE: [local] [local] [262cf62e-fa230d95-d7e522fa-6d37fadc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:27.662783Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Starting read session
2025-12-09T03:43:27.662828Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Starting session to cluster null (localhost:8635)
2025-12-09T03:43:27.663276Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:27.663291Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:27.663297Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:27.668553Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Successfully connected. Initializing session
2025-12-09T03:43:27.669467Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Server session id: recovery_consumer_1_9_9208474043698581454_v1
2025-12-09T03:43:27.669526Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:27.670682Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "recovery_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:27.670860Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "recovery_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:43:27.671532Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:27.671617Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-13)
2025-12-09T03:43:27.671680Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-09T03:43:27.671703Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-12-09T03:43:27.671711Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (8-8)
2025-12-09T03:43:27.671717Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (9-9)
2025-12-09T03:43:27.671726Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (10-10)
2025-12-09T03:43:27.671731Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (11-11)
2025-12-09T03:43:27.671737Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 5} (12-12)
2025-12-09T03:43:27.671742Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 6} (13-13)
2025-12-09T03:43:27.671872Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Commit offsets [6, 14). Partition stream id: 1
2025-12-09T03:43:27.671945Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] The application data is transferred to the client. Number of messages 8, size 16 bytes
2025-12-09T03:43:27.672038Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:27.672108Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (14-15)
2025-12-09T03:43:27.672148Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (14-14)
2025-12-09T03:43:27.672158Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (15-15)
2025-12-09T03:43:27.672196Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Commit offsets [14, 16). Partition stream id: 2
2025-12-09T03:43:27.672314Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] The application data is transferred to the client. Number of messages 2, size 4 bytes
2025-12-09T03:43:27.674098Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-09T03:43:27.674177Z :DEBUG: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-12-09T03:43:27.674250Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:27.674296Z :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-09T03:43:27.674307Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:27.674538Z :NOTICE: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] 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:27.677855Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:27.677868Z :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-09T03:43:27.677876Z :INFO: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:27.677888Z :NOTICE: [local] [local] [860907b4-e80edc7f-a00cb48f-7cf576e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:27.408244Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Starting read session
2025-12-09T03:42:27.408291Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Starting session to cluster null (localhost:6559)
2025-12-09T03:42:27.408783Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:27.408796Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:27.408802Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:27.415135Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Successfully connected. Initializing session
2025-12-09T03:42:27.416041Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Server session id: pq_kikimr_streaming_v1_consumer_1_9_17146065170962762505_v1
2025-12-09T03:42:27.416135Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:27.417474Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:42:27.417643Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:27.418398Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:27.418460Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-13)
2025-12-09T03:42:27.418507Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (6-6)
2025-12-09T03:42:27.418517Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (7-7)
2025-12-09T03:42:27.418524Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 1} (8-8)
2025-12-09T03:42:27.418529Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 2} (9-9)
2025-12-09T03:42:27.418537Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 3} (10-10)
2025-12-09T03:42:27.418543Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 4} (11-11)
2025-12-09T03:42:27.418548Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 5} (12-12)
2025-12-09T03:42:27.418553Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 6} (13-13)
2025-12-09T03:42:27.418666Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Commit offsets [6, 14). Partition stream id: 1
2025-12-09T03:42:27.421965Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] The application data is transferred to the client. Number of messages 8, size 16 bytes
2025-12-09T03:42:27.422184Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:27.422280Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (14-15)
2025-12-09T03:42:27.423882Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:27.423951Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (14-14)
2025-12-09T03:42:27.423972Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (15-15)
2025-12-09T03:42:27.424041Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Commit offsets [14, 16). Partition stream id: 2
2025-12-09T03:42:27.424152Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] The application data is transferred to the client. Number of messages 2, size 4 bytes
2025-12-09T03:42:27.425553Z :DEBUG: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 10 messages
2025-12-09T03:42:27.425685Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:27.426123Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:0:2:15:16 null:pq_kikimr_streaming_v1_output:1:1:13:14
2025-12-09T03:42:27.426143Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:27.426356Z :NOTICE: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] 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:27.426490Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:27.426503Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:0:2:15:16 null:pq_kikimr_streaming_v1_output:1:1:13:14
2025-12-09T03:42:27.426511Z :INFO: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:27.426521Z :NOTICE: [local] [local] [9d1a6424-694b25f2-76b3e108-c6603830] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:36.783840Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Starting read session
2025-12-09T03:42:36.783894Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:36.784434Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.784447Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.784454Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:36.790221Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Successfully connected. Initializing session
2025-12-09T03:42:36.791265Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Server session id: test_3_session_consumer_1_8_142653125747679577_v1
2025-12-09T03:42:36.791355Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.792831Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:36.793853Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.793932Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:42:36.793968Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:36.793977Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:42:36.794119Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:42:36.794210Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:36.796976Z :DEBUG: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:36.797141Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:36.797180Z :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-09T03:42:36.797190Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:36.797440Z :NOTICE: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] 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:36.800773Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:36.800786Z :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-09T03:42:36.800797Z :INFO: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:36.800810Z :NOTICE: [local] [local] [bf48a5c6-1b959783-7c4042cd-7beade4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:48.414566Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Starting read session
2025-12-09T03:43:48.414610Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Starting session to cluster null (localhost:25686)
2025-12-09T03:43:48.414952Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:48.414964Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:48.414970Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:48.420070Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Successfully connected. Initializing session
2025-12-09T03:43:48.421051Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Server session id: test_filter_missing_fields_consumer_1_5_5201989767673984971_v1
2025-12-09T03:43:48.421133Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:48.426669Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filter_missing_fields_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:49.415244Z :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-09T03:43:49.415270Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:52.832382Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:52.832499Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:43:52.832543Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:52.832654Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:43:52.832780Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:52.832945Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:52.832987Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-09T03:43:52.833022Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-09T03:43:52.833083Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Commit offsets [1, 2). Partition stream id: 1
2025-12-09T03:43:52.833184Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:52.835286Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:43:52.835362Z :DEBUG: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-09T03:43:52.835436Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:52.835462Z :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-09T03:43:52.835472Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4420 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:52.835672Z :NOTICE: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] 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:52.835767Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:52.835774Z :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-09T03:43:52.835779Z :INFO: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4421 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:52.835785Z :NOTICE: [local] [local] [28f7e7d-bccc200b-e2e1de3b-b603686] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:40.926239Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Starting read session
2025-12-09T03:42:40.926295Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Starting session to cluster null (localhost:15610)
2025-12-09T03:42:40.926827Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.926841Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.926848Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:40.932168Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Successfully connected. Initializing session
2025-12-09T03:42:40.933228Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Server session id: test_filters_non_optional_field_consumer_1_5_8827153497281442964_v1
2025-12-09T03:42:40.933283Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.934558Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:41.927282Z :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-09T03:42:41.927321Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:45.674059Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:45.674162Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-09T03:42:45.674227Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:45.674370Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-09T03:42:45.674501Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:45.677100Z :DEBUG: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:42:45.677253Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:45.677289Z :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-09T03:42:45.677301Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4751 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:45.677759Z :NOTICE: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] 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:45.677898Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:45.677908Z :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-09T03:42:45.677929Z :INFO: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4751 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:45.677939Z :NOTICE: [local] [local] [cde1799c-33fea1b1-421c5d8-fa0e44c1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:43.505540Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Starting read session
2025-12-09T03:42:43.505590Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Starting session to cluster null (localhost:12636)
2025-12-09T03:42:43.505950Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:43.505961Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:43.505964Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:43.510843Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Successfully connected. Initializing session
2025-12-09T03:42:43.511739Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Server session id: test_read_raw_format_with_row_dispatcher_consumer_1_5_4951368764590833031_v1
2025-12-09T03:42:43.511788Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:43.512897Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [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-09T03:42:44.506212Z :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-09T03:42:44.506248Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:48.805283Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:48.805393Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-09T03:42:48.805439Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:48.805523Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-09T03:42:48.805636Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-12-09T03:42:48.806858Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:48.808534Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:48.810117Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-09T03:42:48.810164Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-09T03:42:48.810236Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-09T03:42:48.810335Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-12-09T03:42:48.811812Z :DEBUG: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-09T03:42:48.811984Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:48.812016Z :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-09T03:42:48.812029Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5306 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:48.812310Z :NOTICE: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] 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:48.812480Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:48.812493Z :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-09T03:42:48.812502Z :INFO: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5306 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:48.812513Z :NOTICE: [local] [local] [d13cc506-db8e49e9-cb926767-66712174] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:13.880039Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Starting read session
2025-12-09T03:42:13.880085Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Starting session to cluster null (localhost:5893)
2025-12-09T03:42:13.880581Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:13.880596Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:13.880602Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:13.886767Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Successfully connected. Initializing session
2025-12-09T03:42:13.888241Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Server session id: test_restart_compute_node_consumer_1_8_1421660952358473420_v1
2025-12-09T03:42:13.888302Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:13.890491Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:42:13.890674Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:13.890865Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:42:13.890929Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:42:14.881246Z :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:2:3:0:0 null:test_restart_compute_node_output:0:2:0:0 null:test_restart_compute_node_output:1:1:0:0
2025-12-09T03:42:14.881276Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:17.220077Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:17.220295Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (0-0)
2025-12-09T03:42:17.220344Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (0-0)
2025-12-09T03:42:17.220639Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:17.220685Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (0-0)
2025-12-09T03:42:17.220712Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (0-0)
2025-12-09T03:42:17.221129Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [0, 1). Partition stream id: 3
2025-12-09T03:42:17.221252Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:17.221357Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:17.221400Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [0, 1). Partition stream id: 4
2025-12-09T03:42:17.221417Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (1-3)
2025-12-09T03:42:17.221409Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:42:17.221478Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:17.221489Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:17.221515Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (1-1)
2025-12-09T03:42:17.221536Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [0, 1). Partition stream id: 2
2025-12-09T03:42:17.221515Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (1-1)
2025-12-09T03:42:17.221538Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (2-2)
2025-12-09T03:42:17.221574Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (3-3)
2025-12-09T03:42:17.221590Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:17.221592Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (1-1)
2025-12-09T03:42:17.221621Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [1, 4). Partition stream id: 4
2025-12-09T03:42:17.221665Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-09T03:42:17.221684Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [1, 2). Partition stream id: 3
2025-12-09T03:42:17.221691Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:17.223778Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-09T03:42:17.223879Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:17.223916Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-12-09T03:42:17.223945Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-09T03:42:17.224450Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:17.224515Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-09T03:42:17.224531Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-09T03:42:17.224554Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-09T03:42:17.224608Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Commit offsets [1, 2). Partition stream id: 2
2025-12-09T03:42:17.224661Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:17.225603Z :DEBUG: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-09T03:42:17.225712Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:17.225741Z :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:2:3:1:2 null:test_restart_compute_node_output:0:2:1:2 null:test_restart_compute_node_output:1:1:0:0
2025-12-09T03:42:17.225762Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3345 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:17.226008Z :NOTICE: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] 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:17.226206Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:17.226218Z :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:2:3:1:2 null:test_restart_compute_node_output:0:2:1:2 null:test_restart_compute_node_output:1:1:0:0
2025-12-09T03:42:17.226231Z :INFO: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3346 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:17.226241Z :NOTICE: [local] [local] [2719858e-b01e1496-7f3040ed-22ddce4d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:08.569484Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Starting read session
2025-12-09T03:43:08.569535Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:08.570080Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:08.570099Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:08.570106Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:08.576007Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] Successfully connected. Initializing session
2025-12-09T03:43:08.577005Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] Server session id: test_start_new_query_consumer_1_4_18392870731801007395_v1
2025-12-09T03:43:08.577074Z :DEBUG: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:08.578754Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] [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-09T03:43:09.569347Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:09.569404Z :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-09T03:43:09.569422Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:09.569751Z :NOTICE: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] 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:09.569850Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:09.569862Z :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-09T03:43:09.569870Z :INFO: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:09.569880Z :NOTICE: [local] [local] [91034357-64f477b0-2d1e9d86-b5da6efa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:30.334931Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Starting read session
2025-12-09T03:44:30.334980Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Starting session to cluster null (localhost:20444)
2025-12-09T03:44:30.335496Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:30.335509Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:30.335517Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:30.340317Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Successfully connected. Initializing session
2025-12-09T03:44:30.341159Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Server session id: test_stop_start_with_filter_consumer_1_7_750113935885607067_v1
2025-12-09T03:44:30.341205Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:30.342369Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_with_filter_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:31.336262Z :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-09T03:44:31.336296Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:35.160789Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:35.160929Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:44:35.160956Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:44:35.161103Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:44:35.161230Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:35.161310Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:35.161354Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-12-09T03:44:35.161387Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-12-09T03:44:35.161432Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Commit offsets [1, 2). Partition stream id: 1
2025-12-09T03:44:35.161503Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:44:35.164402Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:44:35.164520Z :DEBUG: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-09T03:44:35.164615Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:35.164645Z :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-09T03:44:35.164662Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4829 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:35.164862Z :NOTICE: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-12-09T03:44:35.166156Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:35.166174Z :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-09T03:44:35.166183Z :INFO: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4831 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:35.166195Z :NOTICE: [local] [local] [583b805-a1a57bfd-6b26b24a-41808632] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:03.956370Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Starting read session
2025-12-09T03:43:03.956431Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Starting session to cluster null (localhost:4927)
2025-12-09T03:43:03.957095Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.957553Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.957566Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:03.963841Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] Successfully connected. Initializing session
2025-12-09T03:43:03.965868Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_7_7868850577842000231_v1
2025-12-09T03:43:03.965957Z :DEBUG: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:03.982417Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:43:03.982626Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:04.957291Z :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-09T03:43:04.957343Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] 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-09T03:43:33.960201Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:33.960239Z :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-09T03:43:33.960253Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:33.960652Z :NOTICE: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] 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:33.960826Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:33.960838Z :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-09T03:43:33.960846Z :INFO: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30004 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:33.960857Z :NOTICE: [local] [local] [4fad6447-b07b098d-92e7f9d6-78986bdd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:34.455883Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Starting read session
2025-12-09T03:42:34.455921Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Starting session to cluster null (localhost:21992)
2025-12-09T03:42:34.456365Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:34.456379Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:34.456384Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:34.461973Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] Successfully connected. Initializing session
2025-12-09T03:42:34.463261Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] Server session id: test_watermarks_no_shared_consumer_1_6_12297564563444764246_v1
2025-12-09T03:42:34.463326Z :DEBUG: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:34.464661Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:35.457302Z :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-09T03:42:35.457342Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] 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-09T03:43:04.455485Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:04.455524Z :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-09T03:43:04.455537Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:04.455852Z :NOTICE: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] 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:04.455978Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:04.455990Z :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-09T03:43:04.455997Z :INFO: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:04.456007Z :NOTICE: [local] [local] [4fc83ce9-9e7c7ff8-2676d8dc-b6b73aab] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:50.334700Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Starting read session
2025-12-09T03:43:50.334753Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Starting session to cluster null (localhost:29288)
2025-12-09T03:43:50.335113Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.335124Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.335129Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:50.339620Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Successfully connected. Initializing session
2025-12-09T03:43:50.340744Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Server session id: test_state_load_mode2_consumer_1_6_2491720248517776992_v1
2025-12-09T03:43:50.340809Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.342194Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_state_load_mode2_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:50.343011Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:50.343069Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:43:50.343123Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:50.343240Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:43:50.343314Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-12-09T03:43:50.345552Z :DEBUG: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:50.345693Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:50.345756Z :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-09T03:43:50.345766Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:50.345969Z :NOTICE: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] 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:50.346089Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:50.346098Z :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-09T03:43:50.346104Z :INFO: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:50.346122Z :NOTICE: [local] [local] [960f03ef-e4efecb0-da5f319c-fe4ffef1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
