2025-11-11T14:16:45.330319Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Starting read session
2025-11-11T14:16:45.330361Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:45.330725Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.330739Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.330745Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:45.335587Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Successfully connected. Initializing session
2025-11-11T14:16:45.336615Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Server session id: test_3_session_consumer_1_12_16726353781839530309_v1
2025-11-11T14:16:45.336691Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.337920Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:45.338552Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.338596Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:16:45.338623Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:45.338635Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:16:45.338701Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:16:45.338771Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:45.340769Z :DEBUG: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:45.340877Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:45.340930Z :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-11-11T14:16:45.340940Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Counters: { Errors: 0 CurrentSessionLifetimeMs: 10 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:45.341130Z :NOTICE: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] 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-11-11T14:16:45.341389Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:45.341397Z :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-11-11T14:16:45.341425Z :INFO: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:45.341435Z :NOTICE: [local] [local] [c734010-eba51926-abecc44c-dffc24ec] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:11.461088Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Starting read session
2025-11-11T14:18:11.461131Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:11.461850Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:11.473459Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:11.473482Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:11.478897Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Successfully connected. Initializing session
2025-11-11T14:18:11.493737Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Server session id: test_filters_non_optional_field_consumer_1_13_17660066915920590321_v1
2025-11-11T14:18:11.503913Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:11.504091Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:12.469541Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:0:5
2025-11-11T14:18:12.469579Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1008 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:15.784004Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:15.784920Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-11-11T14:18:15.788506Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-11-11T14:18:15.788667Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Commit offsets [5, 6). Partition stream id: 1
2025-11-11T14:18:15.788846Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:15.791748Z :DEBUG: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:15.791902Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:15.791943Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:5:6
2025-11-11T14:18:15.791954Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4330 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:15.797575Z :NOTICE: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] 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-11-11T14:18:15.797715Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:15.797732Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:5:6
2025-11-11T14:18:15.797755Z :INFO: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4336 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:15.797766Z :NOTICE: [local] [local] [2c931c86-db52cb1c-bf61e342-929ed339] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:38.118180Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Starting read session
2025-11-11T14:17:38.118228Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:38.118648Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.118660Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.118665Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:38.122901Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Successfully connected. Initializing session
2025-11-11T14:17:38.123834Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Server session id: test_filters_optional_field_consumer_1_13_4628943014527564652_v1
2025-11-11T14:17:38.123891Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.125159Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:39.119709Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:0:6
2025-11-11T14:17:39.119754Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:41.641743Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:41.641821Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-11-11T14:17:41.641861Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-11-11T14:17:41.641968Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Commit offsets [6, 7). Partition stream id: 1
2025-11-11T14:17:41.642080Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:41.645512Z :DEBUG: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:41.646287Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:41.646321Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:6:7
2025-11-11T14:17:41.646334Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3528 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:41.646565Z :NOTICE: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] 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-11-11T14:17:41.646696Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:41.646709Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:6:7
2025-11-11T14:17:41.646731Z :INFO: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3528 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:41.646740Z :NOTICE: [local] [local] [f86306f1-9dc342ad-9ad79c4e-97fe1651] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:15.543835Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Starting read session
2025-11-11T14:16:15.543873Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:15.544250Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.544263Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.544269Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:15.549925Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Successfully connected. Initializing session
2025-11-11T14:16:15.558425Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Server session id: test_start_new_query_consumer_1_8_10455496780816507290_v1
2025-11-11T14:16:15.558511Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.562306Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output3". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:15.566194Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.566268Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:15.566289Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:15.566298Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:15.569623Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:15.569774Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] The application data is transferred to the client. Number of messages 2, size 12 bytes
2025-11-11T14:16:15.572652Z :DEBUG: [local] [local] [164b0862-851157be-afab78cd-5a43b712] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:15.572804Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:15.572862Z :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-11-11T14:16:15.572874Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:15.573217Z :NOTICE: [local] [local] [164b0862-851157be-afab78cd-5a43b712] 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-11-11T14:16:15.576548Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:15.576560Z :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-11-11T14:16:15.576569Z :INFO: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Counters: { Errors: 0 CurrentSessionLifetimeMs: 32 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:15.576590Z :NOTICE: [local] [local] [164b0862-851157be-afab78cd-5a43b712] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
