2025-12-09T03:42:40.587387Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Starting read session
2025-12-09T03:42:40.587438Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:40.587942Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.587958Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.587964Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:40.592619Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Successfully connected. Initializing session
2025-12-09T03:42:40.594200Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Server session id: test_3_session_consumer_1_12_7462517728365530907_v1
2025-12-09T03:42:40.594345Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.595863Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:40.596740Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:40.596800Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-09T03:42:40.596854Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:40.596866Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-09T03:42:40.596969Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-09T03:42:40.597044Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:40.599892Z :DEBUG: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:40.600042Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:40.600074Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:3:4
2025-12-09T03:42:40.600085Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:40.600325Z :NOTICE: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] 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.600428Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:40.600440Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:3:4
2025-12-09T03:42:40.600449Z :INFO: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:40.600459Z :NOTICE: [local] [local] [2d5ed233-d0a77161-fbb5a818-b5b3e1be] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:12.731731Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Starting read session
2025-12-09T03:43:12.731779Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:12.732334Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.732348Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.732354Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:12.739353Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] Successfully connected. Initializing session
2025-12-09T03:43:12.740431Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] Server session id: test_filters_non_optional_field_consumer_1_13_6341008521124814637_v1
2025-12-09T03:43:12.740498Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.741822Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [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:13.733264Z :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:6
2025-12-09T03:43:13.733307Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:16.272846Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:16.272930Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-12-09T03:43:16.272982Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-09T03:43:16.273115Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] Commit offsets [6, 7). Partition stream id: 1
2025-12-09T03:43:16.273225Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:16.276052Z :DEBUG: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:16.276213Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:16.276255Z :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:6:7
2025-12-09T03:43:16.276274Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3544 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:16.276547Z :NOTICE: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] 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:16.276695Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:16.276710Z :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:6:7
2025-12-09T03:43:16.276732Z :INFO: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3545 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:16.276741Z :NOTICE: [local] [local] [fb0771a5-a7b0e37c-1cb4bfd1-68ee8d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:11.578876Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Starting read session
2025-12-09T03:43:11.578922Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:11.579316Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.579329Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.579335Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:11.584497Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Successfully connected. Initializing session
2025-12-09T03:43:11.585826Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Server session id: test_start_new_query_consumer_1_8_11923042452739450659_v1
2025-12-09T03:43:11.585930Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.587271Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output3". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:11.588077Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.588144Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:43:11.588195Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:11.588206Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:43:11.588347Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:43:11.588481Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] The application data is transferred to the client. Number of messages 2, size 12 bytes
2025-12-09T03:43:11.591339Z :DEBUG: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:43:11.591502Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:11.591541Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output3:0:1:1:2
2025-12-09T03:43:11.591552Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:11.592196Z :NOTICE: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] 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.592314Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:11.592327Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output3:0:1:1:2
2025-12-09T03:43:11.592347Z :INFO: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:11.592357Z :NOTICE: [local] [local] [11554a6a-f3da8093-5037b16e-578ee49] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
