2025-12-09T03:42:41.506403Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Starting read session
2025-12-09T03:42:41.506454Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:41.506868Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:41.506881Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:41.506887Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:41.512066Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Successfully connected. Initializing session
2025-12-09T03:42:41.513163Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Server session id: test_3_session_consumer_1_13_7985376042280282427_v1
2025-12-09T03:42:41.513236Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:41.514677Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:42.507244Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:0:2
2025-12-09T03:42:42.507282Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:46.553812Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.553874Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-09T03:42:46.553911Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:46.554052Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-09T03:42:46.554142Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-12-09T03:42:46.554601Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:46.554718Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-09T03:42:46.554773Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-09T03:42:46.554838Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-09T03:42:46.554929Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-12-09T03:42:46.556956Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:46.557030Z :DEBUG: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-09T03:42:46.557126Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:46.557163Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:3:4
2025-12-09T03:42:46.557172Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5050 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:46.557370Z :NOTICE: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] 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.557450Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:46.557459Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:3:4
2025-12-09T03:42:46.557467Z :INFO: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5051 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:46.557476Z :NOTICE: [local] [local] [b8b9e007-9558ad3c-d1cdf9c-dd62d0e7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:20.790201Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Starting read session
2025-12-09T03:43:20.790245Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Starting session to cluster null (localhost:15610)
2025-12-09T03:43:20.790730Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:20.790744Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:20.790751Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:20.796342Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] Successfully connected. Initializing session
2025-12-09T03:43:20.797499Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] Server session id: test_filters_non_optional_field_consumer_1_15_2950687477879389018_v1
2025-12-09T03:43:20.797589Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:20.798997Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [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:21.791265Z :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:7
2025-12-09T03:43:21.791312Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:24.079112Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:24.079193Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-12-09T03:43:24.079240Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-12-09T03:43:24.079357Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] Commit offsets [7, 8). Partition stream id: 1
2025-12-09T03:43:24.079450Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:43:24.081904Z :DEBUG: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:24.082079Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:24.082105Z :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:7:8
2025-12-09T03:43:24.082116Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3291 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:24.082375Z :NOTICE: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] 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:24.082508Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:24.082520Z :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:7:8
2025-12-09T03:43:24.082541Z :INFO: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3292 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:24.082550Z :NOTICE: [local] [local] [88f9143b-bbb524f1-47f30adf-666d6cbd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:11.709836Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Starting read session
2025-12-09T03:43:11.709886Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:11.710421Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.710436Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.710443Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:11.715850Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] Successfully connected. Initializing session
2025-12-09T03:43:11.716932Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] Server session id: test_start_new_query_consumer_1_9_2291573460257211498_v1
2025-12-09T03:43:11.717000Z :DEBUG: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:11.718341Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] [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:12.709432Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:12.709491Z :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:4
2025-12-09T03:43:12.709505Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] 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:12.710116Z :NOTICE: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] 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:12.713441Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:12.713461Z :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:4
2025-12-09T03:43:12.713472Z :INFO: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:12.713487Z :NOTICE: [local] [local] [4dd93b1c-914e6ae9-157851fa-93bde6c5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
