2025-12-09T03:42:46.629092Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Starting read session
2025-12-09T03:42:46.629142Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:46.629693Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.629710Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.629716Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:46.642014Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Successfully connected. Initializing session
2025-12-09T03:42:46.646083Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Server session id: test_3_session_consumer_1_15_14738971070417445263_v1
2025-12-09T03:42:46.646176Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.646310Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:46.647378Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.647449Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-09T03:42:46.647489Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:42:46.647500Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-09T03:42:46.647606Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-09T03:42:46.647709Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:46.650426Z :DEBUG: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:46.650555Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:46.650595Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:5:6
2025-12-09T03:42:46.650606Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 21 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:46.650799Z :NOTICE: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] 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:46.651028Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:46.651038Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:5:6
2025-12-09T03:42:46.651052Z :INFO: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 21 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:46.651062Z :NOTICE: [local] [local] [45948d20-f1d0c6cc-42695c74-3b0e86f1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:26.945355Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Starting read session
2025-12-09T03:43:26.945403Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:26.945907Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:26.945922Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:26.945928Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:26.951983Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] Successfully connected. Initializing session
2025-12-09T03:43:26.953919Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] Server session id: test_filters_non_optional_field_consumer_1_17_16867855572373145981_v1
2025-12-09T03:43:26.954016Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:26.955335Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [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:27.946256Z :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:8
2025-12-09T03:43:27.946303Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:31.632376Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:31.632451Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-12-09T03:43:31.632523Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-12-09T03:43:31.632654Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] Commit offsets [8, 9). Partition stream id: 1
2025-12-09T03:43:31.632737Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:31.634877Z :DEBUG: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:31.635051Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:31.635080Z :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:8:9
2025-12-09T03:43:31.635087Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4689 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:31.635280Z :NOTICE: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] 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:31.635468Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:31.635493Z :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:8:9
2025-12-09T03:43:31.635516Z :INFO: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4690 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:31.635530Z :NOTICE: [local] [local] [e2a784c-c3959d71-bcd99bfc-29621c76] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:12.820648Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Starting read session
2025-12-09T03:43:12.820694Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:12.821128Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.821141Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.821147Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:12.836302Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] Successfully connected. Initializing session
2025-12-09T03:43:12.837432Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] Server session id: test_start_new_query_consumer_1_10_7693816958538000519_v1
2025-12-09T03:43:12.837505Z :DEBUG: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:12.839717Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-09T03:43:13.820211Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:13.820265Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:4
2025-12-09T03:43:13.820278Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] 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:13.820581Z :NOTICE: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] 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:13.820670Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:13.820679Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:4
2025-12-09T03:43:13.820685Z :INFO: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:13.820699Z :NOTICE: [local] [local] [57b5b091-e60c18e7-25bb3f65-f09cdbf7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
