2025-12-09T03:42:46.729836Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Starting read session
2025-12-09T03:42:46.729870Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:46.730233Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.730245Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.730248Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:46.736201Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Successfully connected. Initializing session
2025-12-09T03:42:46.738290Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Server session id: test_3_session_consumer_1_16_13092984414774156829_v1
2025-12-09T03:42:46.738400Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.738884Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:46.739731Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.739797Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-09T03:42:46.739834Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-09T03:42:46.739846Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-09T03:42:46.739932Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-09T03:42:46.740026Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:46.742983Z :DEBUG: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:46.743305Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:46.743350Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:5:6
2025-12-09T03:42:46.743362Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] 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:46.743601Z :NOTICE: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] 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.743753Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:46.743765Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:5:6
2025-12-09T03:42:46.743773Z :INFO: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:46.743781Z :NOTICE: [local] [local] [b723a289-f3640b2f-ed4585d1-bb0d2f4b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:35.540549Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Starting read session
2025-12-09T03:43:35.540593Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:35.541079Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:35.541093Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:35.541099Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:35.545686Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] Successfully connected. Initializing session
2025-12-09T03:43:35.546883Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] Server session id: test_filters_non_optional_field_consumer_1_19_10640997012640097244_v1
2025-12-09T03:43:35.547004Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:35.548515Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [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:36.541271Z :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:9
2025-12-09T03:43:36.541308Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:39.286576Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:39.286677Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-12-09T03:43:39.286732Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (9-9)
2025-12-09T03:43:39.286837Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] Commit offsets [9, 10). Partition stream id: 1
2025-12-09T03:43:39.286947Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:39.289529Z :DEBUG: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:39.289663Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:39.289689Z :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:9:10
2025-12-09T03:43:39.289697Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3749 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:39.289920Z :NOTICE: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] 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:39.290069Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:39.290083Z :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:9:10
2025-12-09T03:43:39.290110Z :INFO: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3749 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:39.290117Z :NOTICE: [local] [local] [8fe37328-787bbe94-1f928918-d487fef9] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:13.940177Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Starting read session
2025-12-09T03:43:13.940227Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:13.940656Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:13.940669Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:13.940674Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:13.950653Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] Successfully connected. Initializing session
2025-12-09T03:43:13.954122Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] Server session id: test_start_new_query_consumer_1_11_16298996514565843896_v1
2025-12-09T03:43:13.955218Z :DEBUG: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:13.958237Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output3". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-09T03:43:14.939613Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:14.939684Z :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:0:2
2025-12-09T03:43:14.939697Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] 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:14.940269Z :NOTICE: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] 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:14.940339Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:14.940346Z :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:0:2
2025-12-09T03:43:14.940350Z :INFO: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:14.940355Z :NOTICE: [local] [local] [585e387c-1d550ddd-ac182d1e-326e708b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
