2025-11-11T14:16:51.570639Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Starting read session
2025-11-11T14:16:51.570676Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:51.571006Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.571018Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.571022Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:51.575667Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Successfully connected. Initializing session
2025-11-11T14:16:51.577264Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Server session id: test_3_session_consumer_1_16_7434813316495807898_v1
2025-11-11T14:16:51.578298Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.579568Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:51.580326Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.580399Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-11-11T14:16:51.580454Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:16:51.580463Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:16:51.580603Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:16:51.580698Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:51.583283Z :DEBUG: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:51.583415Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:51.583491Z :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-11-11T14:16:51.583504Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:51.583728Z :NOTICE: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] 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-11-11T14:16:51.587032Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:51.587045Z :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-11-11T14:16:51.587055Z :INFO: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.587066Z :NOTICE: [local] [local] [34b4cf4d-8b05e2f8-1fc7270-3978b730] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:33.380098Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Starting read session
2025-11-11T14:18:33.388164Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:33.388722Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:33.388736Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:33.388742Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:33.394217Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Successfully connected. Initializing session
2025-11-11T14:18:33.396203Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Server session id: test_filters_non_optional_field_consumer_1_19_5012341825594696808_v1
2025-11-11T14:18:33.396270Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:33.397357Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:34.391064Z :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:8
2025-11-11T14:18:34.391095Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1010 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:37.768391Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:37.768493Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-11-11T14:18:37.768548Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-11-11T14:18:37.768697Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Commit offsets [8, 9). Partition stream id: 1
2025-11-11T14:18:37.768820Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:37.775301Z :DEBUG: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:37.775469Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:37.775499Z :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:8:9
2025-11-11T14:18:37.775511Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4395 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:37.775795Z :NOTICE: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] 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-11-11T14:18:37.776002Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:37.776014Z :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:8:9
2025-11-11T14:18:37.776048Z :INFO: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4395 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:37.776061Z :NOTICE: [local] [local] [bc7e9320-89ba0fb5-646488db-908196e1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:01.409366Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Starting read session
2025-11-11T14:18:01.409437Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Starting session to cluster null (localhost:11255)
2025-11-11T14:18:01.410444Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:01.410470Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:01.410477Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:01.418456Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Successfully connected. Initializing session
2025-11-11T14:18:01.419759Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Server session id: test_filters_optional_field_consumer_1_19_12881041367525201569_v1
2025-11-11T14:18:01.419876Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:01.426756Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:02.414206Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:0:9
2025-11-11T14:18:02.414255Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1004 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:04.799819Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:04.799883Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-11-11T14:18:04.799907Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (9-9)
2025-11-11T14:18:04.801635Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Commit offsets [9, 10). Partition stream id: 1
2025-11-11T14:18:04.801759Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:04.805678Z :DEBUG: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:04.806714Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:04.806736Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:9:10
2025-11-11T14:18:04.806745Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3397 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:04.808039Z :NOTICE: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] 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-11-11T14:18:04.808253Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:04.808264Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:9:10
2025-11-11T14:18:04.808281Z :INFO: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3398 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:04.808290Z :NOTICE: [local] [local] [b5b5cf-b843731a-68670047-c85ccad3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:18.016695Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Starting read session
2025-11-11T14:16:18.016747Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:18.017317Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.017334Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.017341Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:18.029385Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] Successfully connected. Initializing session
2025-11-11T14:16:18.033557Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] Server session id: test_start_new_query_consumer_1_11_8639007720542312615_v1
2025-11-11T14:16:18.033711Z :DEBUG: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.043133Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] [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-11-11T14:16:19.015579Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:19.015648Z :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-11-11T14:16:19.015662Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Counters: { Errors: 0 CurrentSessionLifetimeMs: 998 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:19.016004Z :NOTICE: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] 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-11-11T14:16:19.019355Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:19.019374Z :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-11-11T14:16:19.019385Z :INFO: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:19.019399Z :NOTICE: [local] [local] [61bcebda-661f8e9a-b4463227-cd63de58] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
