2025-11-11T14:16:46.233731Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Starting read session
2025-11-11T14:16:46.233767Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:46.234103Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.234114Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.234118Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:46.239105Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Successfully connected. Initializing session
2025-11-11T14:16:46.239991Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Server session id: test_3_session_consumer_1_13_10381254580365972819_v1
2025-11-11T14:16:46.240092Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:46.241157Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:47.234682Z :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-11-11T14:16:47.234737Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.356883Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.356956Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:16:51.356997Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:51.357121Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:16:51.357210Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-11-11T14:16:51.357387Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.357462Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:16:51.357497Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:16:51.357526Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Commit offsets [3, 4). Partition stream id: 1
2025-11-11T14:16:51.357585Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-11-11T14:16:51.359605Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:51.359690Z :DEBUG: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:51.359771Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:51.359789Z :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-11-11T14:16:51.359798Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5126 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:51.359988Z :NOTICE: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] 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.363275Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:51.363285Z :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-11-11T14:16:51.363294Z :INFO: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5129 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.363305Z :NOTICE: [local] [local] [39916c09-ec183883-7d7b7f24-f8eff527] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:18.447978Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Starting read session
2025-11-11T14:18:18.448436Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:18.448921Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:18.448931Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:18.448937Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:18.470008Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] Successfully connected. Initializing session
2025-11-11T14:18:18.474497Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] Server session id: test_filters_non_optional_field_consumer_1_15_16690994179275665180_v1
2025-11-11T14:18:18.474994Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:18.476954Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [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:19.449710Z :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-11-11T14:18:19.449749Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:22.838732Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:22.838815Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-11-11T14:18:22.838863Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-11-11T14:18:22.838949Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] Commit offsets [6, 7). Partition stream id: 1
2025-11-11T14:18:22.839076Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:22.859992Z :DEBUG: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:22.861843Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:22.861876Z :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-11-11T14:18:22.861889Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4413 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:22.865753Z :NOTICE: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] 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:22.877561Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:22.877588Z :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-11-11T14:18:22.877638Z :INFO: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4429 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:22.877659Z :NOTICE: [local] [local] [ce324a84-325ffa6a-1ca9fcc1-402e3a67] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:45.158323Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Starting read session
2025-11-11T14:17:45.158384Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:45.159145Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:45.159162Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:45.159168Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:45.166847Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Successfully connected. Initializing session
2025-11-11T14:17:45.169846Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Server session id: test_filters_optional_field_consumer_1_15_17446796813106667743_v1
2025-11-11T14:17:45.169947Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:45.173882Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:46.159685Z :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:7
2025-11-11T14:17:46.159720Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:48.667198Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.667292Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-11-11T14:17:48.667355Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-11-11T14:17:48.667446Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Commit offsets [7, 8). Partition stream id: 1
2025-11-11T14:17:48.667601Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:48.671181Z :DEBUG: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:48.671367Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:48.671399Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:7:8
2025-11-11T14:17:48.671411Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3513 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:48.671731Z :NOTICE: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] 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:17:48.672067Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:48.672080Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:7:8
2025-11-11T14:17:48.672104Z :INFO: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3513 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:48.672118Z :NOTICE: [local] [local] [7b9d59d7-5a13a3ed-7daad049-e4b726a5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:15.787676Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Starting read session
2025-11-11T14:16:15.787844Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:15.788232Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.788248Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.788254Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:15.800893Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] Successfully connected. Initializing session
2025-11-11T14:16:15.802670Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] Server session id: test_start_new_query_consumer_1_9_14067869903507826206_v1
2025-11-11T14:16:15.802737Z :DEBUG: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.803972Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] [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-11-11T14:16:16.787951Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:16.788012Z :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-11-11T14:16:16.788039Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:16.788701Z :NOTICE: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] 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:16.788774Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:16.788784Z :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-11-11T14:16:16.788790Z :INFO: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:16.788798Z :NOTICE: [local] [local] [7151aabf-8df55f3d-bd459c7e-3c8ec25f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
