2025-12-12T12:28:28.220801Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Starting read session
2025-12-12T12:28:28.220840Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:28.221211Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.221221Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.221225Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:28.227498Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Successfully connected. Initializing session
2025-12-12T12:28:28.228983Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Server session id: test_3_session_consumer_1_16_11641894930201828495_v1
2025-12-12T12:28:28.229072Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.230558Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:28.231446Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:28.231557Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-12T12:28:28.231594Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:28:28.231603Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T12:28:28.231721Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T12:28:28.231814Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:28.234671Z :DEBUG: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:28.234806Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:28.234856Z :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-12T12:28:28.234868Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:28.235216Z :NOTICE: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] 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:28.235327Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:28.235337Z :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-12T12:28:28.235344Z :INFO: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:28.235353Z :NOTICE: [local] [local] [cd346f34-407bbc8d-c26c2d81-cd667123] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:36:24.759346Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Starting read session
2025-12-12T12:36:24.759946Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Starting session to cluster null (localhost:63390)
2025-12-12T12:36:24.760444Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:24.761056Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:24.761068Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:36:24.768551Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] Successfully connected. Initializing session
2025-12-12T12:36:24.771022Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] Server session id: test_filters_non_optional_field_consumer_1_19_10380307328216860321_v1
2025-12-12T12:36:24.772057Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:24.772914Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [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:25.761297Z :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-12T12:36:25.761334Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:28.410794Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:28.411144Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-12-12T12:36:28.411196Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (9-9)
2025-12-12T12:36:28.411307Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] Commit offsets [9, 10). Partition stream id: 1
2025-12-12T12:36:28.411413Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:36:28.413932Z :DEBUG: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:36:28.414120Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Closing read session. Close timeout: 5.000000s
2025-12-12T12:36:28.414152Z :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-12T12:36:28.414163Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3654 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:36:28.414482Z :NOTICE: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] 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:28.414579Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Closing read session. Close timeout: 0.000000s
2025-12-12T12:36:28.414590Z :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-12T12:36:28.414609Z :INFO: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3655 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:28.414618Z :NOTICE: [local] [local] [f56c8abc-bd437687-1065356-50f848fd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:22.581406Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Starting read session
2025-12-12T12:27:22.581459Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:22.581994Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:22.582024Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:22.582031Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:22.592715Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] Successfully connected. Initializing session
2025-12-12T12:27:22.598219Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] Server session id: test_start_new_query_consumer_1_12_1024386901878195949_v1
2025-12-12T12:27:22.598371Z :DEBUG: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:22.603177Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] [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-12T12:27:23.580867Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:23.580958Z :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-12T12:27:23.580975Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:23.583281Z :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-12T12:27:23.583355Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:23.587088Z :NOTICE: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] 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:23.587688Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:23.587704Z :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-12T12:27:23.587717Z :INFO: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1006 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:23.587730Z :NOTICE: [local] [local] [2abd6e4e-8661c1aa-10ef61da-c73befce] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
