2025-11-11T14:16:51.467508Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Starting read session
2025-11-11T14:16:51.467552Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:51.467929Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.467941Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.467947Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:51.474603Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Successfully connected. Initializing session
2025-11-11T14:16:51.475737Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Server session id: test_3_session_consumer_1_15_9720591004752209333_v1
2025-11-11T14:16:51.475797Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.477344Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:51.478028Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:51.478075Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-11-11T14:16:51.478101Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:16:51.478111Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:16:51.478213Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:16:51.478311Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:51.481519Z :DEBUG: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:51.481637Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:51.481685Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:5:6
2025-11-11T14:16:51.481696Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:51.481942Z :NOTICE: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] 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.485261Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:51.485272Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:5:6
2025-11-11T14:16:51.485281Z :INFO: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:51.485293Z :NOTICE: [local] [local] [3a2ae1c9-dee56e25-64a0bc4d-3125ed1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:25.442347Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Starting read session
2025-11-11T14:18:25.442397Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:25.442836Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.443710Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.443722Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:25.448175Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] Successfully connected. Initializing session
2025-11-11T14:18:25.456251Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] Server session id: test_filters_non_optional_field_consumer_1_17_15153221010042502589_v1
2025-11-11T14:18:25.457231Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:25.458536Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [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:26.449678Z :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-11-11T14:18:26.456030Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1007 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:29.786919Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:29.787032Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-11-11T14:18:29.787095Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-11-11T14:18:29.787210Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] Commit offsets [7, 8). Partition stream id: 1
2025-11-11T14:18:29.787318Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:29.790881Z :DEBUG: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:29.804676Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:29.804720Z :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-11-11T14:18:29.804733Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4362 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:29.805062Z :NOTICE: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] 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:29.811844Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:29.811865Z :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-11-11T14:18:29.811903Z :INFO: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4369 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:29.811925Z :NOTICE: [local] [local] [b2ea95f2-b2bab01c-9b0a83db-cb64eafb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:53.433937Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Starting read session
2025-11-11T14:17:53.433982Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:53.434336Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:53.434348Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:53.434353Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:53.439706Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] Successfully connected. Initializing session
2025-11-11T14:17:53.440580Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] Server session id: test_filters_optional_field_consumer_1_17_5077112726416401547_v1
2025-11-11T14:17:53.440632Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:53.445593Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [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:54.437157Z :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:8
2025-11-11T14:17:54.437195Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:56.684099Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:56.684167Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-11-11T14:17:56.684216Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-11-11T14:17:56.684295Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] Commit offsets [8, 9). Partition stream id: 1
2025-11-11T14:17:56.684407Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:56.687511Z :DEBUG: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:56.687657Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:56.687685Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:8:9
2025-11-11T14:17:56.687695Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3253 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:56.690499Z :NOTICE: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] 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:56.697554Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:56.697573Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:8:9
2025-11-11T14:17:56.697598Z :INFO: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3263 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:56.697614Z :NOTICE: [local] [local] [5bedc71c-f9412243-3c42bae1-e24aec43] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:16.907636Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Starting read session
2025-11-11T14:16:16.907713Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:16.908364Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:16.908380Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:16.908387Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:16.918409Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] Successfully connected. Initializing session
2025-11-11T14:16:16.919484Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] Server session id: test_start_new_query_consumer_1_10_6955468864032558185_v1
2025-11-11T14:16:16.919590Z :DEBUG: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:16.921901Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-11-11T14:16:17.905218Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:17.905293Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:4
2025-11-11T14:16:17.905308Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Counters: { Errors: 0 CurrentSessionLifetimeMs: 997 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:17.905903Z :NOTICE: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] 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:17.906007Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:17.906018Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:4
2025-11-11T14:16:17.906026Z :INFO: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Counters: { Errors: 0 CurrentSessionLifetimeMs: 998 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:17.906035Z :NOTICE: [local] [local] [38f18caf-a6b034b6-e441db2e-70972526] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
