2025-12-12T12:28:21.601219Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Starting read session
2025-12-12T12:28:21.601253Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:21.601717Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.601728Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.601734Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:21.619923Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Successfully connected. Initializing session
2025-12-12T12:28:21.621000Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Server session id: test_3_session_consumer_1_12_16695868534728662085_v1
2025-12-12T12:28:21.621082Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.623185Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:21.624056Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.624138Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-12T12:28:21.624173Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:28:21.624184Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:28:21.624314Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-12T12:28:21.624389Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:21.627178Z :DEBUG: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:21.627449Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:21.627482Z :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-12T12:28:21.627493Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 26 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:21.627658Z :NOTICE: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] 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-12T12:28:21.630588Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:21.630603Z :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-12T12:28:21.630619Z :INFO: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:21.630633Z :NOTICE: [local] [local] [27914759-a7187aeb-58fa7b58-3e043fd7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:36:02.861625Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Starting read session
2025-12-12T12:36:02.861659Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Starting session to cluster null (localhost:63390)
2025-12-12T12:36:02.862503Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:02.862521Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:02.862528Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:36:02.869093Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Successfully connected. Initializing session
2025-12-12T12:36:02.870311Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Server session id: test_filters_non_optional_field_consumer_1_13_2955887286452938513_v1
2025-12-12T12:36:02.870419Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:02.872271Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:36:03.867088Z :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-12T12:36:03.867127Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1005 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:06.352117Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:06.358637Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-12-12T12:36:06.358700Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-12T12:36:06.358831Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Commit offsets [6, 7). Partition stream id: 1
2025-12-12T12:36:06.358955Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:36:06.361935Z :DEBUG: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:36:06.363528Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Closing read session. Close timeout: 5.000000s
2025-12-12T12:36:06.363585Z :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-12T12:36:06.363595Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3501 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:36:06.367073Z :NOTICE: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] 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-12T12:36:06.367723Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Closing read session. Close timeout: 0.000000s
2025-12-12T12:36:06.367741Z :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-12T12:36:06.367764Z :INFO: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3506 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:06.367785Z :NOTICE: [local] [local] [ad62d52c-cff5bc97-a9efbfa3-9c953302] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:20.193921Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Starting read session
2025-12-12T12:27:20.193974Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:20.194453Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.194466Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.194472Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:20.200691Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Successfully connected. Initializing session
2025-12-12T12:27:20.201774Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Server session id: test_start_new_query_consumer_1_9_5679075229001430876_v1
2025-12-12T12:27:20.201886Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.204422Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output3". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:20.205474Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.205562Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-12T12:27:20.205615Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:20.205634Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:27:20.205747Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-12T12:27:20.205871Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] The application data is transferred to the client. Number of messages 2, size 12 bytes
2025-12-12T12:27:20.208906Z :DEBUG: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:20.209081Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:20.209128Z :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-12T12:27:20.209140Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:20.209390Z :NOTICE: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] 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-12T12:27:20.209583Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:20.209597Z :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-12T12:27:20.209606Z :INFO: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:20.209617Z :NOTICE: [local] [local] [e418283-912bebd3-9a16541d-8134f6bb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
