2025-11-11T14:16:25.810578Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Starting read session
2025-11-11T14:16:25.810618Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Starting session to cluster null (localhost:62972)
2025-11-11T14:16:25.811056Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.811068Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.811073Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:25.824583Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Successfully connected. Initializing session
2025-11-11T14:16:25.827561Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Server session id: continue_1_consumer_1_6_9277162886434107223_v1
2025-11-11T14:16:25.827653Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.830609Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "continue_1_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:25.830801Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "continue_1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:25.831737Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.831818Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-11-11T14:16:25.831862Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-11-11T14:16:25.831875Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-11-11T14:16:25.831951Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:25.832051Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:16:25.834262Z :DEBUG: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:25.834368Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:25.834412Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_1_output:0:2:0:0 null:continue_1_output:1:1:1:2
2025-11-11T14:16:25.834422Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 23 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:25.837279Z :NOTICE: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] 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:25.837494Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:25.837509Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_1_output:0:2:0:0 null:continue_1_output:1:1:1:2
2025-11-11T14:16:25.837518Z :INFO: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 26 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:25.837542Z :NOTICE: [local] [local] [f0f61d74-63ea4623-e196f9c-2746540b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:18.582930Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Starting read session
2025-11-11T14:17:18.582978Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Starting session to cluster null (localhost:31990)
2025-11-11T14:17:18.583495Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:18.583511Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:18.583517Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:18.590627Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Successfully connected. Initializing session
2025-11-11T14:17:18.591654Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Server session id: cpu_quota_consumer_1_4_1579100532897702665_v1
2025-11-11T14:17:18.591704Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:18.593087Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "cpu_quota_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:18.596460Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:18.596531Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-4)
2025-11-11T14:17:18.596818Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:17:18.597278Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (4-4)
2025-11-11T14:17:18.597305Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-11-11T14:17:18.597340Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (5-5)
2025-11-11T14:17:18.598509Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Commit offsets [3, 5). Partition stream id: 1
2025-11-11T14:17:18.598526Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] The application data is transferred to the client. Number of messages 2, size 600000 bytes
2025-11-11T14:17:18.598838Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Commit offsets [5, 6). Partition stream id: 1
2025-11-11T14:17:18.598942Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] The application data is transferred to the client. Number of messages 1, size 300000 bytes
2025-11-11T14:17:18.601611Z :DEBUG: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 3 messages
2025-11-11T14:17:18.601713Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:18.601741Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:cpu_quota_output:0:1:5:6
2025-11-11T14:17:18.601752Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 900000 MessagesRead: 3 BytesReadCompressed: 900000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:18.602018Z :NOTICE: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] 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:18.602127Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:18.602137Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:cpu_quota_output:0:1:5:6
2025-11-11T14:17:18.602155Z :INFO: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 19 BytesRead: 900000 MessagesRead: 3 BytesReadCompressed: 900000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:18.602164Z :NOTICE: [local] [local] [844093f7-85280f27-73d95c7c-ba4ad06a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:03.786576Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Starting read session
2025-11-11T14:18:03.792794Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Starting session to cluster null (localhost:12894)
2025-11-11T14:18:03.793446Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:03.794655Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:03.794666Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:03.801920Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] Successfully connected. Initializing session
2025-11-11T14:18:03.806781Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] Server session id: disposition_fresh_consumer_1_6_1216516296320360571_v1
2025-11-11T14:18:03.809706Z :DEBUG: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:03.810512Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_fresh_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:04.793752Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-11-11T14:18:04.796966Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1007 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:18:33.793538Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:33.793580Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-11-11T14:18:33.793594Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30007 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:33.797758Z :NOTICE: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] 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:33.797922Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:33.797940Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-11-11T14:18:33.797950Z :INFO: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30011 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:33.797973Z :NOTICE: [local] [local] [52c7d475-a95bb469-25ec0379-1d2c6a50] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:58.383495Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Starting read session
2025-11-11T14:15:58.383534Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Starting session to cluster null (localhost:4996)
2025-11-11T14:15:58.383910Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:58.383921Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:58.383926Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:58.389224Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Successfully connected. Initializing session
2025-11-11T14:15:58.390198Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Server session id: disposition_oldest_consumer_1_4_14772140097906052836_v1
2025-11-11T14:15:58.390256Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:58.394114Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_oldest_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:58.395554Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:58.395590Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-5)
2025-11-11T14:15:58.395619Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:15:58.395631Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:15:58.395637Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (4-4)
2025-11-11T14:15:58.395641Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (5-5)
2025-11-11T14:15:58.395734Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Commit offsets [2, 6). Partition stream id: 1
2025-11-11T14:15:58.395795Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] The application data is transferred to the client. Number of messages 4, size 4 bytes
2025-11-11T14:15:58.399113Z :DEBUG: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 4 messages
2025-11-11T14:15:58.399207Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:58.399730Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:5:6
2025-11-11T14:15:58.399738Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:58.399991Z :NOTICE: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] 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:15:58.400270Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:58.400277Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:5:6
2025-11-11T14:15:58.400283Z :INFO: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:58.400300Z :NOTICE: [local] [local] [fa8fa259-34bf30d7-3acf024d-fef5ee52] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:50.063874Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Starting read session
2025-11-11T14:15:50.063910Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Starting session to cluster null (localhost:24577)
2025-11-11T14:15:50.064292Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:50.064306Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:50.064312Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:50.069171Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Successfully connected. Initializing session
2025-11-11T14:15:50.070312Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Server session id: pq_read_schema_meta_False_consumer_1_4_15435249147137447988_v1
2025-11-11T14:15:50.070401Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:50.071601Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_read_schema_meta_False_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:50.072364Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:50.072426Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:15:50.072482Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:50.072505Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:50.072615Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:50.072698Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] The application data is transferred to the client. Number of messages 2, size 86 bytes
2025-11-11T14:15:50.075239Z :DEBUG: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:15:50.075370Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:50.075409Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_read_schema_meta_False_output:0:1:1:2
2025-11-11T14:15:50.075419Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 86 MessagesRead: 2 BytesReadCompressed: 86 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:50.075617Z :NOTICE: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] 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:15:50.075716Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:50.075725Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_read_schema_meta_False_output:0:1:1:2
2025-11-11T14:15:50.075732Z :INFO: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 86 MessagesRead: 2 BytesReadCompressed: 86 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:50.075741Z :NOTICE: [local] [local] [e65d5f5a-badabd33-c896369e-4b9079c8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:22.020691Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Starting read session
2025-11-11T14:17:22.020728Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Starting session to cluster null (localhost:5942)
2025-11-11T14:17:22.021160Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.021174Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.021178Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:22.026468Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Successfully connected. Initializing session
2025-11-11T14:17:22.027576Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Server session id: public_select_unlimited_consumer_1_5_13286366604966033426_v1
2025-11-11T14:17:22.027652Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.029152Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "public_select_unlimited_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:22.030166Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.030247Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-3)
2025-11-11T14:17:22.030298Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:22.030310Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:17:22.030317Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-11T14:17:22.030322Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-11-11T14:17:22.030440Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Commit offsets [0, 4). Partition stream id: 1
2025-11-11T14:17:22.030526Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] The application data is transferred to the client. Number of messages 4, size 4 bytes
2025-11-11T14:17:22.033148Z :DEBUG: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 4 messages
2025-11-11T14:17:22.033301Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:22.033343Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:public_select_unlimited_output:0:1:3:4
2025-11-11T14:17:22.033353Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:22.033569Z :NOTICE: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] 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:22.033668Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:22.033678Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:public_select_unlimited_output:0:1:3:4
2025-11-11T14:17:22.033686Z :INFO: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:22.033708Z :NOTICE: [local] [local] [8fddcee3-95823600-28db35d1-afc3e21e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:07.354066Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Starting read session
2025-11-11T14:16:07.354371Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Starting session to cluster null (localhost:6240)
2025-11-11T14:16:07.354965Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.354978Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.354985Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:07.362050Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Successfully connected. Initializing session
2025-11-11T14:16:07.363084Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Server session id: delete_read_rules_1_consumer_1_4_2010113872255754545_v1
2025-11-11T14:16:07.363167Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.364713Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "delete_read_rules_1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:07.365629Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.369506Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-6)
2025-11-11T14:16:07.369566Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:07.369578Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:07.369585Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-11-11T14:16:07.369591Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (3-3)
2025-11-11T14:16:07.369601Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 1} (4-4)
2025-11-11T14:16:07.369606Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 2} (5-5)
2025-11-11T14:16:07.369611Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 3} (6-6)
2025-11-11T14:16:07.371715Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Commit offsets [0, 7). Partition stream id: 1
2025-11-11T14:16:07.371879Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] The application data is transferred to the client. Number of messages 7, size 14 bytes
2025-11-11T14:16:07.375085Z :DEBUG: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 7 messages
2025-11-11T14:16:07.375309Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:07.375358Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:delete_read_rules_1_output:0:1:6:7
2025-11-11T14:16:07.375370Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Counters: { Errors: 0 CurrentSessionLifetimeMs: 21 BytesRead: 14 MessagesRead: 7 BytesReadCompressed: 14 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:07.375885Z :NOTICE: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] 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:07.376353Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:07.376365Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:delete_read_rules_1_output:0:1:6:7
2025-11-11T14:16:07.376385Z :INFO: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22 BytesRead: 14 MessagesRead: 7 BytesReadCompressed: 14 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:07.376397Z :NOTICE: [local] [local] [7b137706-b175b2aa-a7c399a6-68c1c7ad] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:02.760099Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Starting read session
2025-11-11T14:16:02.760138Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Starting session to cluster null (localhost:18945)
2025-11-11T14:16:02.760525Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.760537Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.760543Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:02.775239Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Successfully connected. Initializing session
2025-11-11T14:16:02.777914Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Server session id: recovery_consumer_1_6_10645224300783661895_v1
2025-11-11T14:16:02.777970Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.779890Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "recovery_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:02.780066Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "recovery_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:02.785268Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.785328Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-19)
2025-11-11T14:16:02.785368Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-11-11T14:16:02.785381Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (11-11)
2025-11-11T14:16:02.785388Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (12-12)
2025-11-11T14:16:02.785393Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (13-13)
2025-11-11T14:16:02.785440Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (14-14)
2025-11-11T14:16:02.785452Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (15-15)
2025-11-11T14:16:02.785457Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (16-16)
2025-11-11T14:16:02.785463Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (17-17)
2025-11-11T14:16:02.785471Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 3} (18-18)
2025-11-11T14:16:02.785476Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 4} (19-19)
2025-11-11T14:16:02.785602Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Commit offsets [10, 20). Partition stream id: 1
2025-11-11T14:16:02.785690Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] The application data is transferred to the client. Number of messages 10, size 20 bytes
2025-11-11T14:16:02.789492Z :DEBUG: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:16:02.789618Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:02.789671Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:recovery_output:1:2:0:0 null:recovery_output:0:1:19:20
2025-11-11T14:16:02.789681Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:02.789875Z :NOTICE: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] 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:02.790227Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:02.790238Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:recovery_output:1:2:0:0 null:recovery_output:0:1:19:20
2025-11-11T14:16:02.790245Z :INFO: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:02.790254Z :NOTICE: [local] [local] [c143c9df-932ae5ec-66834f55-5f4811ed] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:40.288973Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Starting read session
2025-11-11T14:17:40.289028Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Starting session to cluster null (localhost:18359)
2025-11-11T14:17:40.289512Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.289527Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.289533Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:40.294974Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Successfully connected. Initializing session
2025-11-11T14:17:40.296472Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Server session id: pq_kikimr_streaming_v1_consumer_1_6_12149633827131349922_v1
2025-11-11T14:17:40.296543Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.300272Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:40.300419Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:40.301557Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.301619Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-9)
2025-11-11T14:17:40.301641Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-11-11T14:17:40.301651Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-11-11T14:17:40.301658Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (2-2)
2025-11-11T14:17:40.301663Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 1} (3-3)
2025-11-11T14:17:40.301671Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 2} (4-4)
2025-11-11T14:17:40.301677Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 3} (5-5)
2025-11-11T14:17:40.301682Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 4} (6-6)
2025-11-11T14:17:40.301686Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 5} (7-7)
2025-11-11T14:17:40.301695Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 6} (8-8)
2025-11-11T14:17:40.301700Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (9-9)
2025-11-11T14:17:40.301809Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Commit offsets [0, 10). Partition stream id: 2
2025-11-11T14:17:40.301900Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] The application data is transferred to the client. Number of messages 10, size 11 bytes
2025-11-11T14:17:40.306117Z :DEBUG: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:17:40.306269Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:40.306326Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:9:10 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-11-11T14:17:40.306339Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 11 MessagesRead: 10 BytesReadCompressed: 11 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:40.309954Z :NOTICE: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] 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:40.312097Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:40.312113Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:9:10 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-11-11T14:17:40.312123Z :INFO: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Counters: { Errors: 0 CurrentSessionLifetimeMs: 23 BytesRead: 11 MessagesRead: 10 BytesReadCompressed: 11 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:40.312134Z :NOTICE: [local] [local] [ee58b2c8-993fe87a-ea4b4186-d9de8c13] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:22.518598Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Starting read session
2025-11-11T14:17:22.518629Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Starting session to cluster null (localhost:4827)
2025-11-11T14:17:22.519001Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.519013Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.519018Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:22.523616Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Successfully connected. Initializing session
2025-11-11T14:17:22.524792Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Server session id: restart_1_consumer_1_5_280005864391989429_v1
2025-11-11T14:17:22.524868Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.526320Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:22.526996Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:22.527066Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:22.527100Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:22.527184Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:22.527272Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-11-11T14:17:22.530136Z :DEBUG: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:22.530269Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:22.530312Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_1_output:0:1:0:1
2025-11-11T14:17:22.530335Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:22.530539Z :NOTICE: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] 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:22.533538Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:22.533549Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_1_output:0:1:0:1
2025-11-11T14:17:22.533565Z :INFO: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:22.533577Z :NOTICE: [local] [local] [e05956cb-405c6fa7-2cfe784e-91f576fa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:37.251133Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Starting read session
2025-11-11T14:16:37.251196Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:37.251748Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:37.251764Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:37.251771Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:37.257269Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Successfully connected. Initializing session
2025-11-11T14:16:37.258484Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Server session id: test_3_session_consumer_1_6_14062380393592440290_v1
2025-11-11T14:16:37.258616Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:37.259920Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session1". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:38.252698Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:0:0
2025-11-11T14:16:38.252729Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:41.393682Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.394121Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.394199Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:41.394242Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:41.394280Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:41.394289Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:41.394365Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:41.394484Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-11-11T14:16:41.394517Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:41.394561Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] The application data is transferred to the client. Number of messages 1, size 12 bytes
2025-11-11T14:16:41.397004Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:41.397104Z :DEBUG: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:41.397189Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:41.397215Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:1:2
2025-11-11T14:16:41.397638Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4146 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:41.397919Z :NOTICE: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] 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:41.398061Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:41.398075Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session1:0:1:1:2
2025-11-11T14:16:41.398085Z :INFO: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4146 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:41.398096Z :NOTICE: [local] [local] [46206b1d-220c16e9-928c76a-4eef3680] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:32.231009Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Starting read session
2025-11-11T14:16:32.231069Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Starting session to cluster null (localhost:10455)
2025-11-11T14:16:32.231525Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.231539Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.231546Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:32.236301Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Successfully connected. Initializing session
2025-11-11T14:16:32.237888Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Server session id: test_filter_use_unsupported_predicate_consumer_1_3_15953360912986039827_v1
2025-11-11T14:16:32.237954Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.239256Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filter_use_unsupported_predicate_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:33.231705Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_use_unsupported_predicate_output:0:1:0:0
2025-11-11T14:16:33.231752Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:35.960080Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:35.961482Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:35.961540Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:35.961660Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:35.961767Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:35.964279Z :DEBUG: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:35.964389Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:35.964412Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_use_unsupported_predicate_output:0:1:0:1
2025-11-11T14:16:35.964425Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3733 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:35.965498Z :NOTICE: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] 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:35.965630Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:35.965644Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_use_unsupported_predicate_output:0:1:0:1
2025-11-11T14:16:35.965666Z :INFO: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3734 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:35.965677Z :NOTICE: [local] [local] [645628df-29fb0188-89f55d94-c19cb7eb] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:33.806172Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Starting read session
2025-11-11T14:17:33.806207Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Starting session to cluster null (localhost:19692)
2025-11-11T14:17:33.806722Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.806735Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.806742Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:33.812192Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] Successfully connected. Initializing session
2025-11-11T14:17:33.816045Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] Server session id: test_filters_non_optional_field_consumer_1_3_12486055078488121644_v1
2025-11-11T14:17:33.816477Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.817702Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [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:34.809724Z :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:0
2025-11-11T14:17:34.809779Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:38.245773Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:38.245870Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:38.245923Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:38.246033Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:38.246111Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:38.248883Z :DEBUG: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:38.249041Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:38.249066Z :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:1
2025-11-11T14:17:38.249093Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4442 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:38.249517Z :NOTICE: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] 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:38.249651Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:38.249664Z :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:1
2025-11-11T14:17:38.249685Z :INFO: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4443 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:38.249696Z :NOTICE: [local] [local] [d0161d73-9c22cc69-1e4d9522-25ed6e52] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:01.034485Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Starting read session
2025-11-11T14:17:01.034528Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:01.034968Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.034983Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.034990Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:01.039338Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] Successfully connected. Initializing session
2025-11-11T14:17:01.040680Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] Server session id: test_filters_optional_field_consumer_1_3_843707461298706135_v1
2025-11-11T14:17:01.040748Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.042243Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [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:02.035719Z :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:1
2025-11-11T14:17:02.035763Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:05.645349Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.645456Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:17:05.645517Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:05.645668Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:17:05.645840Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:05.648739Z :DEBUG: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:05.648906Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:05.648946Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:1:2
2025-11-11T14:17:05.648958Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4614 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:05.649300Z :NOTICE: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] 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:05.649459Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:05.649474Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:1:2
2025-11-11T14:17:05.649495Z :INFO: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4615 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:05.649505Z :NOTICE: [local] [local] [ab9fa3b5-9362a825-5cbd2732-98b2895d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:22.737187Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Starting read session
2025-11-11T14:16:22.737223Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Starting session to cluster null (localhost:11957)
2025-11-11T14:16:22.737765Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:22.737788Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:22.737795Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:22.742373Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Successfully connected. Initializing session
2025-11-11T14:16:22.743524Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Server session id: test_metadatafields_consumer_1_6_13140549069553785463_v1
2025-11-11T14:16:22.743593Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:22.753827Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_metadatafields_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:23.738724Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_metadatafields_output:0:1:0:0
2025-11-11T14:16:23.738763Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:27.040570Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:27.041526Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:27.041569Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:27.041659Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:27.041755Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] The application data is transferred to the client. Number of messages 1, size 13 bytes
2025-11-11T14:16:27.044781Z :DEBUG: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:27.045448Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:27.045471Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_metadatafields_output:0:1:0:1
2025-11-11T14:16:27.045502Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4308 BytesRead: 13 MessagesRead: 1 BytesReadCompressed: 13 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:27.045734Z :NOTICE: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] 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:27.049592Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:27.049607Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_metadatafields_output:0:1:0:1
2025-11-11T14:16:27.049631Z :INFO: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4312 BytesRead: 13 MessagesRead: 1 BytesReadCompressed: 13 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:27.049645Z :NOTICE: [local] [local] [1ebb1dc7-fd8012e5-8baa5a47-e26de6fd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:21.803638Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Starting read session
2025-11-11T14:17:21.803679Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Starting session to cluster null (localhost:20405)
2025-11-11T14:17:21.804160Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:21.804176Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:21.804182Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:21.809373Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Successfully connected. Initializing session
2025-11-11T14:17:21.810521Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Server session id: test_nested_types_without_predicate_consumer_1_3_11492782469717058473_v1
2025-11-11T14:17:21.810597Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:21.812210Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_nested_types_without_predicate_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:22.804707Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_without_predicate_output:0:1:0:0
2025-11-11T14:17:22.804762Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:25.480506Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.480596Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:25.480647Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:25.480988Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.481017Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:25.481041Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:17:25.481148Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-11-11T14:17:25.481158Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:25.481194Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:17:25.481269Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-11-11T14:17:25.483840Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:25.484045Z :DEBUG: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:17:25.484135Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:25.484180Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_without_predicate_output:0:1:1:2
2025-11-11T14:17:25.484196Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3680 BytesRead: 32 MessagesRead: 2 BytesReadCompressed: 32 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:25.484417Z :NOTICE: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] 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:25.484517Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:25.484527Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_without_predicate_output:0:1:1:2
2025-11-11T14:17:25.484535Z :INFO: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3680 BytesRead: 32 MessagesRead: 2 BytesReadCompressed: 32 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:25.484545Z :NOTICE: [local] [local] [3aaf442d-20c3c160-981c29dd-2f5207ef] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:01.988405Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Starting read session
2025-11-11T14:17:01.988445Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Starting session to cluster null (localhost:22745)
2025-11-11T14:17:01.989014Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.989030Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.989036Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:01.994017Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Successfully connected. Initializing session
2025-11-11T14:17:01.995070Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Server session id: test_read_raw_format_with_row_dispatcher_consumer_1_3_8337281099191459156_v1
2025-11-11T14:17:01.995120Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.996516Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_read_raw_format_with_row_dispatcher_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:02.989619Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:0:2
2025-11-11T14:17:02.989642Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:07.184714Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:07.185138Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:17:07.185178Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:07.185277Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:17:07.185406Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:07.185484Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:17:07.185552Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-11-11T14:17:07.185731Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:17:07.185763Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Commit offsets [3, 4). Partition stream id: 1
2025-11-11T14:17:07.185836Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-11-11T14:17:07.188348Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:07.188453Z :DEBUG: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:17:07.188555Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:07.188584Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:3:4
2025-11-11T14:17:07.188596Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5200 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:07.188855Z :NOTICE: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] 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:07.188957Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:07.188967Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_read_raw_format_with_row_dispatcher_output:0:1:3:4
2025-11-11T14:17:07.188973Z :INFO: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5200 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:07.188980Z :NOTICE: [local] [local] [84a8c51e-6c713b52-ae11d137-f55ae2a9] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:28.958550Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Starting read session
2025-11-11T14:16:28.958603Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Starting session to cluster null (localhost:30441)
2025-11-11T14:16:28.959188Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:28.959203Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:28.959209Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:28.963627Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Successfully connected. Initializing session
2025-11-11T14:16:28.964587Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Server session id: test_sensors_consumer_1_4_8064147096488500664_v1
2025-11-11T14:16:28.964672Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:28.965837Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_sensors_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:29.959725Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_sensors_output:0:1:0:0
2025-11-11T14:16:29.959757Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:34.645465Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:34.645590Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:34.645655Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:34.645795Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:34.645905Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:34.648350Z :DEBUG: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:34.648478Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:34.648502Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_sensors_output:0:1:0:1
2025-11-11T14:16:34.648520Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5689 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:34.648726Z :NOTICE: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] 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:34.648853Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:34.648864Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_sensors_output:0:1:0:1
2025-11-11T14:16:34.648876Z :INFO: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5690 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:34.648897Z :NOTICE: [local] [local] [a71096bb-f4f7fb21-1e4776d4-83c34267] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:12.682553Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Starting read session
2025-11-11T14:16:12.682587Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Starting session to cluster null (localhost:1768)
2025-11-11T14:16:12.683001Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.683011Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.683016Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:12.691910Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Successfully connected. Initializing session
2025-11-11T14:16:12.693595Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Server session id: test_simple_optional_consumer_1_3_11588660915300564555_v1
2025-11-11T14:16:12.693670Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.695229Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_simple_optional_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:13.683651Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_optional_output:0:1:0:0
2025-11-11T14:16:13.683679Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:16.918977Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:16.919567Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:16.919645Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:16.919682Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:16.919705Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:16.919713Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:16.919778Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:16.919861Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:16.919897Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:16.919903Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:16.922928Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:16.923863Z :DEBUG: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:16.923935Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:16.923957Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_optional_output:0:1:1:2
2025-11-11T14:16:16.923965Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4241 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:16.925486Z :NOTICE: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] 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.925607Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:16.925617Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_optional_output:0:1:1:2
2025-11-11T14:16:16.925625Z :INFO: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4243 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:16.925633Z :NOTICE: [local] [local] [8720406d-845b6e6c-ba4577ed-66a0dccf] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:11.200003Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Starting read session
2025-11-11T14:16:11.200044Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:11.200463Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.200473Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.200480Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:11.269405Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Successfully connected. Initializing session
2025-11-11T14:16:11.270984Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Server session id: test_start_new_query_consumer_1_3_6449839789043000031_v1
2025-11-11T14:16:11.271068Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.272600Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:11.273530Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.273664Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:11.273705Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:11.273717Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:11.273821Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:11.273900Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:16:11.277868Z :DEBUG: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:11.278005Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:11.278056Z :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:1:2
2025-11-11T14:16:11.278066Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Counters: { Errors: 0 CurrentSessionLifetimeMs: 78 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:11.278297Z :NOTICE: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] 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:11.281607Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:11.281620Z :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:1:2
2025-11-11T14:16:11.281629Z :INFO: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Counters: { Errors: 0 CurrentSessionLifetimeMs: 81 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:11.281641Z :NOTICE: [local] [local] [9e2b7671-4e5c302e-50f2033e-b8cb5626] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:25.484058Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Starting read session
2025-11-11T14:17:25.484102Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Starting session to cluster null (localhost:1893)
2025-11-11T14:17:25.484564Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.484577Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.484583Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:25.489852Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Successfully connected. Initializing session
2025-11-11T14:17:25.490923Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Server session id: test_stop_start_consumer_1_4_17233250748572836358_v1
2025-11-11T14:17:25.491020Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.492445Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:26.484717Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:0:2
2025-11-11T14:17:26.484756Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:29.845621Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:29.845700Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:17:29.845749Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:29.845901Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:17:29.846053Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:29.846384Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:29.846449Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-5)
2025-11-11T14:17:29.846487Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:17:29.846501Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (4-4)
2025-11-11T14:17:29.846510Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (5-5)
2025-11-11T14:17:29.846569Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Commit offsets [3, 6). Partition stream id: 1
2025-11-11T14:17:29.846651Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-11-11T14:17:29.849110Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:29.849240Z :DEBUG: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 4 messages
2025-11-11T14:17:29.849347Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:29.849376Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:5:6
2025-11-11T14:17:29.849398Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4365 BytesRead: 12 MessagesRead: 4 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:29.849858Z :NOTICE: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] 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:29.849999Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:29.850012Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:5:6
2025-11-11T14:17:29.850022Z :INFO: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4365 BytesRead: 12 MessagesRead: 4 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:29.850034Z :NOTICE: [local] [local] [2bce6246-32cfc709-fe001bb9-26e1cc0e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:08.477271Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Starting read session
2025-11-11T14:17:08.477335Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Starting session to cluster null (localhost:7770)
2025-11-11T14:17:08.477741Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:08.477753Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:08.477757Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:08.482273Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Successfully connected. Initializing session
2025-11-11T14:17:08.483461Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_4_4084004152585816940_v1
2025-11-11T14:17:08.483526Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:08.484905Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:08.485060Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:08.485699Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:08.485763Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:17:08.485804Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:08.485813Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:17:08.485927Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:17:08.486013Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-11-11T14:17:08.488761Z :DEBUG: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:17:08.488918Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:08.488976Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:1:2:0:0 null:test_idle_watermarks_no_shared_output:0:1:1:2
2025-11-11T14:17:08.488987Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:08.489210Z :NOTICE: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] 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:08.489339Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:08.489350Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:1:2:0:0 null:test_idle_watermarks_no_shared_output:0:1:1:2
2025-11-11T14:17:08.489367Z :INFO: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:08.489375Z :NOTICE: [local] [local] [a58d99e8-1b9083f9-435d2086-28af0efe] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:12.427301Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Starting read session
2025-11-11T14:16:12.427346Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Starting session to cluster null (localhost:25220)
2025-11-11T14:16:12.427829Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.427849Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.427855Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:12.512794Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Successfully connected. Initializing session
2025-11-11T14:16:12.525441Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Server session id: test_idle_watermarks_shared_consumer_1_4_1601242195568805183_v1
2025-11-11T14:16:12.525521Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.532804Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_shared_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:12.532928Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:12.537502Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.537617Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-11-11T14:16:12.537643Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-11-11T14:16:12.537652Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-11-11T14:16:12.537721Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:12.537792Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-11-11T14:16:12.547255Z :DEBUG: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:12.547376Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:12.547421Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_shared_output:0:2:0:0 null:test_idle_watermarks_shared_output:1:1:1:2
2025-11-11T14:16:12.547433Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 120 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:12.548222Z :NOTICE: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] 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:12.548306Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:12.548316Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_shared_output:0:2:0:0 null:test_idle_watermarks_shared_output:1:1:1:2
2025-11-11T14:16:12.548324Z :INFO: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Counters: { Errors: 0 CurrentSessionLifetimeMs: 121 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:12.548343Z :NOTICE: [local] [local] [bdd0001d-167f71b1-8d145a90-e3f5afc3] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:13.583335Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Starting read session
2025-11-11T14:16:13.583376Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Starting session to cluster null (localhost:26454)
2025-11-11T14:16:13.584154Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:13.584166Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:13.584174Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:13.592146Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Successfully connected. Initializing session
2025-11-11T14:16:13.594536Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Server session id: test_watermarks_shared_consumer_1_3_13783991307931826449_v1
2025-11-11T14:16:13.594597Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:13.596633Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:13.597450Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:13.597575Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:13.597601Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:13.597614Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:13.597745Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:13.597848Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-11-11T14:16:13.607542Z :DEBUG: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:13.607758Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:13.607806Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_shared_output:0:1:1:2
2025-11-11T14:16:13.607818Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Counters: { Errors: 0 CurrentSessionLifetimeMs: 24 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:13.608139Z :NOTICE: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] 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:13.608251Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:13.608259Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_shared_output:0:1:1:2
2025-11-11T14:16:13.608266Z :INFO: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Counters: { Errors: 0 CurrentSessionLifetimeMs: 24 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:13.608275Z :NOTICE: [local] [local] [7a9d199b-53062522-3179fcfc-e44ef861] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:18.550196Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Starting read session
2025-11-11T14:16:18.550249Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Starting session to cluster null (localhost:23791)
2025-11-11T14:16:18.550734Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.550750Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.550757Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:18.555495Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Successfully connected. Initializing session
2025-11-11T14:16:18.556574Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Server session id: pq_test_state_load_mode_v1_consumer_1_4_13302533065922571215_v1
2025-11-11T14:16:18.556657Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.557989Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_state_load_mode_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:18.558820Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.558882Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:18.558927Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:18.559032Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:18.559125Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] The application data is transferred to the client. Number of messages 1, size 38 bytes
2025-11-11T14:16:18.562094Z :DEBUG: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:18.562231Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:18.562280Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_state_load_mode_v1_output:0:1:0:1
2025-11-11T14:16:18.562291Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 38 MessagesRead: 1 BytesReadCompressed: 38 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:18.562529Z :NOTICE: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] 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:18.562660Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:18.562667Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_state_load_mode_v1_output:0:1:0:1
2025-11-11T14:16:18.562673Z :INFO: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 38 MessagesRead: 1 BytesReadCompressed: 38 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:18.562683Z :NOTICE: [local] [local] [7cad5018-6e9f5c1e-1d23d4f2-b51ee89f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:18.287634Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Starting read session
2025-11-11T14:16:18.287675Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Starting session to cluster null (localhost:16564)
2025-11-11T14:16:18.288126Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.288139Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.288145Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:18.293721Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Successfully connected. Initializing session
2025-11-11T14:16:18.294746Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Server session id: pq_yq_read_from_binding_dt_format_settings_v1_consumer_1_4_11078526298500379012_v1
2025-11-11T14:16:18.294797Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.297566Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_yq_read_from_binding_dt_format_settings_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:18.298839Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:18.298906Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:18.298947Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:18.298956Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:18.299064Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:18.299174Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] The application data is transferred to the client. Number of messages 2, size 46 bytes
2025-11-11T14:16:18.302109Z :DEBUG: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:18.302585Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:18.302626Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_dt_format_settings_v1_output:0:1:1:2
2025-11-11T14:16:18.302636Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 46 MessagesRead: 2 BytesReadCompressed: 46 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:18.302865Z :NOTICE: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] 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:18.303046Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:18.303055Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_dt_format_settings_v1_output:0:1:1:2
2025-11-11T14:16:18.303063Z :INFO: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 46 MessagesRead: 2 BytesReadCompressed: 46 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:18.303085Z :NOTICE: [local] [local] [531ee88b-1254134b-763e1dab-a716f061] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:48.481573Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Starting read session
2025-11-11T14:15:48.481625Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Starting session to cluster null (localhost:28311)
2025-11-11T14:15:48.482016Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:48.482027Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:48.482031Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:48.488406Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Successfully connected. Initializing session
2025-11-11T14:15:48.490645Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Server session id: pq_yq_read_from_binding_date_time_v1_consumer_1_4_10600113115422696725_v1
2025-11-11T14:15:48.490748Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:48.492200Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_yq_read_from_binding_date_time_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:48.494398Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:48.494456Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:15:48.494481Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:48.494492Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:48.494581Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:48.494640Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] The application data is transferred to the client. Number of messages 2, size 46 bytes
2025-11-11T14:15:48.499798Z :DEBUG: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:15:48.499921Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:48.499972Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_date_time_v1_output:0:1:1:2
2025-11-11T14:15:48.499983Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 46 MessagesRead: 2 BytesReadCompressed: 46 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:48.500181Z :NOTICE: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] 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:15:48.500721Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:48.500731Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_date_time_v1_output:0:1:1:2
2025-11-11T14:15:48.500739Z :INFO: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 19 BytesRead: 46 MessagesRead: 2 BytesReadCompressed: 46 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:48.500751Z :NOTICE: [local] [local] [8e010186-78f16d51-afca5f55-b8ce480c] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
