2025-12-12T12:28:22.672497Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Starting read session
2025-12-12T12:28:22.672545Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:22.673114Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:22.673128Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:22.673133Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:22.679962Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Successfully connected. Initializing session
2025-12-12T12:28:22.680942Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Server session id: test_3_session_consumer_1_13_16104903950573958765_v1
2025-12-12T12:28:22.681016Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:22.685665Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:23.675103Z :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-12T12:28:23.675152Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:27.955827Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:27.959047Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-12T12:28:27.959138Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:28:27.959299Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-12T12:28:27.959475Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-12-12T12:28:27.963042Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:27.965454Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:27.965556Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-12T12:28:27.965608Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-12T12:28:27.965695Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-12T12:28:27.965807Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-12-12T12:28:27.968698Z :DEBUG: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-12-12T12:28:27.968833Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:27.968861Z :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-12T12:28:27.968875Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5296 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:27.971125Z :NOTICE: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] 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:27.975108Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:27.975130Z :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-12T12:28:27.975145Z :INFO: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5302 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:27.975164Z :NOTICE: [local] [local] [5a5b0030-f02e0a45-80b9848a-ae4225d3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:36:10.884097Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Starting read session
2025-12-12T12:36:10.885630Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Starting session to cluster null (localhost:63390)
2025-12-12T12:36:10.886257Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:10.886271Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:10.886277Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:36:10.893390Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] Successfully connected. Initializing session
2025-12-12T12:36:10.894933Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] Server session id: test_filters_non_optional_field_consumer_1_15_10722179523607033697_v1
2025-12-12T12:36:10.895057Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:10.898036Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [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:11.886265Z :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-12T12:36:11.886309Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:14.195303Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:36:14.199505Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-12-12T12:36:14.199598Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-12-12T12:36:14.199732Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] Commit offsets [7, 8). Partition stream id: 1
2025-12-12T12:36:14.199909Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:36:14.202670Z :DEBUG: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:36:14.209392Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Closing read session. Close timeout: 5.000000s
2025-12-12T12:36:14.209429Z :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-12T12:36:14.209442Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3325 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:36:14.209784Z :NOTICE: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] 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:14.209926Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Closing read session. Close timeout: 0.000000s
2025-12-12T12:36:14.209939Z :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-12T12:36:14.209962Z :INFO: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3325 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:36:14.209972Z :NOTICE: [local] [local] [cb5ee0d6-424730a-8d2e0170-8ebbe140] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:20.356654Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Starting read session
2025-12-12T12:27:20.356717Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:20.357336Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.357354Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.357361Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:20.366125Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] Successfully connected. Initializing session
2025-12-12T12:27:20.367367Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] Server session id: test_start_new_query_consumer_1_10_3489242624389008295_v1
2025-12-12T12:27:20.367480Z :DEBUG: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.374963Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] [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-12T12:27:21.355963Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:21.356017Z :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-12T12:27:21.356029Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] 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:21.356668Z :NOTICE: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] 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:21.356799Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:21.356812Z :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-12T12:27:21.356822Z :INFO: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:21.356831Z :NOTICE: [local] [local] [9a0e8282-e78a3700-1bdbcb67-50fea2ea] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
