2025-11-11T14:19:32.877696Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Starting read session
2025-11-11T14:19:32.877749Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Starting session to cluster null (localhost:12894)
2025-11-11T14:19:32.878235Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:32.878252Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:32.878258Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:19:32.883613Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Successfully connected. Initializing session
2025-11-11T14:19:32.900279Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Server session id: disposition_from_time_consumer_1_12_7197770220379337773_v1
2025-11-11T14:19:32.900378Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:32.902524Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:19:32.919181Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:32.919265Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:19:32.919314Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:19:32.919323Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:19:32.919917Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:19:32.919938Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:19:32.923722Z :DEBUG: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:19:32.942209Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Closing read session. Close timeout: 5.000000s
2025-11-11T14:19:32.942279Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:3:4
2025-11-11T14:19:32.942291Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 64 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:19:32.942533Z :NOTICE: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] 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:19:32.942826Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Closing read session. Close timeout: 0.000000s
2025-11-11T14:19:32.942838Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:3:4
2025-11-11T14:19:32.942846Z :INFO: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 65 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:32.942859Z :NOTICE: [local] [local] [5d04c947-51902700-dc6bf6f-9e9d1cff] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:01.465231Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Starting read session
2025-11-11T14:17:01.465391Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Starting session to cluster null (localhost:4996)
2025-11-11T14:17:01.465761Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.465773Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.465779Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:01.470805Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Successfully connected. Initializing session
2025-11-11T14:17:01.471693Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Server session id: disposition_time_ago_consumer_1_10_5823026176373906205_v1
2025-11-11T14:17:01.471758Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.473054Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:01.474090Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.474137Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:17:01.474163Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:01.474171Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:17:01.474261Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:17:01.474345Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:17:01.476745Z :DEBUG: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:17:01.476867Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:01.476904Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:3:4
2025-11-11T14:17:01.476912Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:01.477069Z :NOTICE: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] 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:01.477157Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:01.477165Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:3:4
2025-11-11T14:17:01.477171Z :INFO: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:01.477180Z :NOTICE: [local] [local] [7766471-634e9c40-778cf0f7-9db7ceef] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:44.097640Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Starting read session
2025-11-11T14:16:44.097673Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:44.098052Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:44.098062Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:44.098067Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:44.106202Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] Successfully connected. Initializing session
2025-11-11T14:16:44.107377Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] Server session id: test_3_session_consumer_1_10_14014725505410859210_v1
2025-11-11T14:16:44.107463Z :DEBUG: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:44.109860Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-11-11T14:16:45.097507Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:45.097566Z :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:45.097581Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:45.101577Z :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:45.101612Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:45.102426Z :NOTICE: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:45.109506Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:45.109524Z :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:45.109535Z :INFO: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1011 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:45.109548Z :NOTICE: [local] [local] [c45d205b-2e2ceb83-90dfc26a-3a030818] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:56.460052Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Starting read session
2025-11-11T14:17:56.460104Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Starting session to cluster null (localhost:19692)
2025-11-11T14:17:56.460589Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:56.460601Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:56.460607Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:56.471143Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] Successfully connected. Initializing session
2025-11-11T14:17:56.474718Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] Server session id: test_filters_non_optional_field_consumer_1_9_878813531640258920_v1
2025-11-11T14:17:56.474829Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:56.476447Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [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:17:57.460756Z :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:3
2025-11-11T14:17:57.460797Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:00.740046Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.741461Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:18:00.745808Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:18:00.746402Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] Commit offsets [3, 4). Partition stream id: 1
2025-11-11T14:18:00.746596Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.752220Z :DEBUG: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:00.759250Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:00.759285Z :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:3:4
2025-11-11T14:18:00.759297Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4299 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:00.761216Z :NOTICE: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] 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:00.785981Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:00.786005Z :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:3:4
2025-11-11T14:18:00.786028Z :INFO: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4325 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:00.786045Z :NOTICE: [local] [local] [92b2afbd-7d96d331-fc9b0c71-52e8a172] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:24.011714Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Starting read session
2025-11-11T14:17:24.011758Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:24.012183Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.012198Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.012204Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:24.016751Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] Successfully connected. Initializing session
2025-11-11T14:17:24.017661Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] Server session id: test_filters_optional_field_consumer_1_9_13342379051384565733_v1
2025-11-11T14:17:24.017714Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.019126Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [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:25.012678Z :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:4
2025-11-11T14:17:25.012724Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:27.632382Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:27.633463Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-11-11T14:17:27.633513Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:17:27.633616Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] Commit offsets [4, 5). Partition stream id: 1
2025-11-11T14:17:27.633718Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:27.636202Z :DEBUG: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:27.636336Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:27.636362Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:4:5
2025-11-11T14:17:27.636372Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3624 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:27.636584Z :NOTICE: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] 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:27.636775Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:27.636786Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:4:5
2025-11-11T14:17:27.636805Z :INFO: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3625 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:27.636815Z :NOTICE: [local] [local] [f11c2aa5-52a92e67-9d27b5c-3a2c195d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:38.054658Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Starting read session
2025-11-11T14:17:38.054699Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Starting session to cluster null (localhost:22745)
2025-11-11T14:17:38.055077Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.055089Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.055095Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:38.059729Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Successfully connected. Initializing session
2025-11-11T14:17:38.061344Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Server session id: test_restart_compute_node_consumer_1_11_17489222086240214731_v1
2025-11-11T14:17:38.061475Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.063173Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-11-11T14:17:38.063330Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:38.063439Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:38.063454Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-11-11T14:17:39.057512Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:2:4:0:8 null:test_restart_compute_node_output:1:3:0:0 null:test_restart_compute_node_output:0:2:0:8 null:test_restart_compute_node_output:3:1:0:0
2025-11-11T14:17:39.057552Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:00.345779Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.350893Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.352163Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.352831Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-11-11T14:18:00.352920Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.352958Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-11-11T14:18:00.352984Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-11-11T14:18:00.352992Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (9-9)
2025-11-11T14:18:00.352999Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (8-8)
2025-11-11T14:18:00.353006Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (8-8)
2025-11-11T14:18:00.353013Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-11-11T14:18:00.353036Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-11-11T14:18:00.353044Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-11-11T14:18:00.353051Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (11-11)
2025-11-11T14:18:00.353057Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (9-11)
2025-11-11T14:18:00.353064Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (9-9)
2025-11-11T14:18:00.353071Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 1} (10-10)
2025-11-11T14:18:00.353078Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 2} (11-11)
2025-11-11T14:18:00.353163Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [8, 9). Partition stream id: 2
2025-11-11T14:18:00.353271Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.353300Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [9, 10). Partition stream id: 2
2025-11-11T14:18:00.353346Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.353364Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [8, 9). Partition stream id: 4
2025-11-11T14:18:00.353434Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.353458Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [10, 11). Partition stream id: 2
2025-11-11T14:18:00.353464Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.353478Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [11, 12). Partition stream id: 2
2025-11-11T14:18:00.354403Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:00.356764Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-11-11T14:18:00.359618Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Commit offsets [9, 12). Partition stream id: 4
2025-11-11T14:18:00.359639Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-11-11T14:18:00.363124Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-11-11T14:18:00.363164Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 } cookies { assign_id: 4 partition_cookie: 3 } cookies { assign_id: 4 partition_cookie: 4 }
2025-11-11T14:18:00.370541Z :DEBUG: [local] [local] [36274306-32dcef75-24531396-8947d2ff] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
Closing session. Got 8 messages
2025-11-11T14:18:00.370679Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:00.370710Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:2:4:11:12 null:test_restart_compute_node_output:1:3:0:0 null:test_restart_compute_node_output:0:2:11:12 null:test_restart_compute_node_output:3:1:0:0
2025-11-11T14:18:00.370722Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22316 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:00.372302Z :NOTICE: [local] [local] [36274306-32dcef75-24531396-8947d2ff] 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:00.378036Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:00.378058Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:2:4:11:12 null:test_restart_compute_node_output:1:3:0:0 null:test_restart_compute_node_output:0:2:11:12 null:test_restart_compute_node_output:3:1:0:0
2025-11-11T14:18:00.378070Z :INFO: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22323 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:00.378085Z :NOTICE: [local] [local] [36274306-32dcef75-24531396-8947d2ff] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:15.275237Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Starting read session
2025-11-11T14:16:15.275284Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:15.275737Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.275749Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.275754Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:15.293968Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Successfully connected. Initializing session
2025-11-11T14:16:15.295743Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Server session id: test_start_new_query_consumer_1_6_10498291034570556250_v1
2025-11-11T14:16:15.295826Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.300649Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:15.303037Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.303104Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:16:15.303146Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:15.303157Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:16:15.303335Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:16:15.303426Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:16:15.306170Z :DEBUG: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:15.306376Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:15.306426Z :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:3:4
2025-11-11T14:16:15.306437Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 31 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:15.307251Z :NOTICE: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] 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:15.307932Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:15.307944Z :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:3:4
2025-11-11T14:16:15.307953Z :INFO: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 32 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:15.307967Z :NOTICE: [local] [local] [5fdf8d6d-fe27e3bc-8873462f-d63e1abb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
