2025-11-11T14:16:05.222720Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Starting read session
2025-11-11T14:16:05.222759Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Starting session to cluster null (localhost:62972)
2025-11-11T14:16:05.223182Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.223193Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.223199Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:05.235104Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Successfully connected. Initializing session
2025-11-11T14:16:05.241658Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Server session id: select_hop_8mb_consumer_1_2_3429000481694360929_v1
2025-11-11T14:16:05.241740Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.253662Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "select_hop_8mb_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:06.225745Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:select_hop_8mb_output:0:1:0:0
2025-11-11T14:16:06.225780Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:17.637810Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.637914Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:17.639858Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:17.642258Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:17.642397Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.648444Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.648551Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:17.648648Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:16:17.650069Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:17.650122Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:16:17.651896Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:17.656375Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:16:17.659416Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (3-3)
2025-11-11T14:16:17.659647Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.659694Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-11-11T14:16:17.659835Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:16:17.662460Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.662570Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-11-11T14:16:17.663410Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-11-11T14:16:17.665629Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [1, 4). Partition stream id: 1
2025-11-11T14:16:17.665742Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 3, size 2700072 bytes
2025-11-11T14:16:17.667917Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.667983Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-11-11T14:16:17.668080Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-11-11T14:16:17.668095Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-11-11T14:16:17.668201Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-11-11T14:16:17.669015Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-11-11T14:16:17.670744Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [4, 5). Partition stream id: 1
2025-11-11T14:16:17.670827Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.673039Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [5, 6). Partition stream id: 1
2025-11-11T14:16:17.673097Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.676878Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [6, 7). Partition stream id: 1
2025-11-11T14:16:17.676891Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.678896Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 3 }
2025-11-11T14:16:17.680324Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [7, 8). Partition stream id: 1
2025-11-11T14:16:17.680398Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.684424Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 4 }
2025-11-11T14:16:17.705260Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.705344Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-11-11T14:16:17.705358Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 5 }
2025-11-11T14:16:17.705485Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-11-11T14:16:17.705509Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-11-11T14:16:17.705625Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (9-9)
2025-11-11T14:16:17.708176Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [8, 9). Partition stream id: 1
2025-11-11T14:16:17.708188Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.709853Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:17.709909Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-11-11T14:16:17.710031Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (10-10)
2025-11-11T14:16:17.710045Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-11-11T14:16:17.710144Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (11-11)
2025-11-11T14:16:17.711330Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [9, 10). Partition stream id: 1
2025-11-11T14:16:17.711412Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.713017Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [10, 11). Partition stream id: 1
2025-11-11T14:16:17.713024Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.715642Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Commit offsets [11, 12). Partition stream id: 1
2025-11-11T14:16:17.715725Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] The application data is transferred to the client. Number of messages 1, size 900024 bytes
2025-11-11T14:16:17.716656Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 6 }
2025-11-11T14:16:17.719144Z :DEBUG: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 7 }
Closing session. Got 12 messages
2025-11-11T14:16:17.719217Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:17.719232Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:select_hop_8mb_output:0:1:11:12
2025-11-11T14:16:17.719252Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12496 BytesRead: 10800288 MessagesRead: 12 BytesReadCompressed: 10800288 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:17.719456Z :NOTICE: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:17.719617Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:17.719627Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:select_hop_8mb_output:0:1:11:12
2025-11-11T14:16:17.719647Z :INFO: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12496 BytesRead: 10800288 MessagesRead: 12 BytesReadCompressed: 10800288 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:17.719659Z :NOTICE: [local] [local] [940e085d-f596e2b1-25fab2b1-aae11a6f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:17.950174Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Starting read session
2025-11-11T14:17:17.950207Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Starting session to cluster null (localhost:31990)
2025-11-11T14:17:17.950589Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.950604Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.950610Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:17.958290Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Successfully connected. Initializing session
2025-11-11T14:17:17.959850Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Server session id: cpu_quota_consumer_1_3_9931663079066939607_v1
2025-11-11T14:17:17.959970Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.963174Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "cpu_quota_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:17.964619Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.964685Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:17.964942Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:17.965893Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:17.965940Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] The application data is transferred to the client. Number of messages 1, size 300000 bytes
2025-11-11T14:17:17.966094Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.966139Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-11-11T14:17:17.966405Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:17.966865Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:17:17.968088Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:17.968117Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Commit offsets [1, 3). Partition stream id: 1
2025-11-11T14:17:17.968231Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] The application data is transferred to the client. Number of messages 2, size 600000 bytes
2025-11-11T14:17:17.968939Z :DEBUG: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-11-11T14:17:17.969000Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:17.969026Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:cpu_quota_output:0:1:2:3
2025-11-11T14:17:17.969036Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] 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:17.969278Z :NOTICE: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] 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:17.969391Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:17.969399Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:cpu_quota_output:0:1:2:3
2025-11-11T14:17:17.969407Z :INFO: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 19 BytesRead: 900000 MessagesRead: 3 BytesReadCompressed: 900000 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:17.969430Z :NOTICE: [local] [local] [4c6d0959-1cee89be-da83ff40-81307d7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:25.969201Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Starting read session
2025-11-11T14:17:25.969268Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Starting session to cluster null (localhost:12894)
2025-11-11T14:17:25.969778Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.969796Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.969802Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:25.975860Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] Successfully connected. Initializing session
2025-11-11T14:17:25.997994Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] Server session id: disposition_fresh_consumer_1_4_6155627905999063751_v1
2025-11-11T14:17:25.998083Z :DEBUG: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:25.999353Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_fresh_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:26.970729Z :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:17:26.970770Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:17:55.968660Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:55.968693Z :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:17:55.968704Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:55.969068Z :NOTICE: [local] [local] [db953858-eb543666-bd4301e2-eddffada] 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:55.969132Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:55.969140Z :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:17:55.969146Z :INFO: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:55.969154Z :NOTICE: [local] [local] [db953858-eb543666-bd4301e2-eddffada] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:51.239950Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Starting read session
2025-11-11T14:15:51.239989Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Starting session to cluster null (localhost:4996)
2025-11-11T14:15:51.240317Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:51.240331Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:51.240337Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:51.245512Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Successfully connected. Initializing session
2025-11-11T14:15:51.246393Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Server session id: disposition_oldest_consumer_1_2_5311954409094980035_v1
2025-11-11T14:15:51.246470Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:51.247948Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_oldest_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:51.248782Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:51.248826Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:15:51.248873Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:51.248885Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:51.248982Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:51.249021Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:15:51.251941Z :DEBUG: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:15:51.252115Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:51.252162Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:1:2
2025-11-11T14:15:51.252182Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:51.252398Z :NOTICE: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] 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:51.255721Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:51.255744Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:1:2
2025-11-11T14:15:51.255753Z :INFO: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:51.255767Z :NOTICE: [local] [local] [2afe84ce-b2fe17bc-e501de40-1d987d74] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:41.375418Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Starting read session
2025-11-11T14:15:41.375453Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Starting session to cluster null (localhost:15674)
2025-11-11T14:15:41.375877Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.375891Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.375895Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:41.381005Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Successfully connected. Initializing session
2025-11-11T14:15:41.382133Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Server session id: no_pq_bill_consumer_1_3_15626157962423519448_v1
2025-11-11T14:15:41.382205Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.384741Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "no_pq_bill_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:41.410598Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.410681Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:15:41.410699Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:15:41.411555Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:41.413272Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:41.413324Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:15:41.413340Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:15:41.413483Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-11-11T14:15:41.415259Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (3-3)
2025-11-11T14:15:41.415309Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-11-11T14:15:41.415320Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-11-11T14:15:41.415441Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (4-4)
2025-11-11T14:15:41.416019Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:41.416038Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.416641Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (5-5)
2025-11-11T14:15:41.416675Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-6)
2025-11-11T14:15:41.416814Z :DEBUG: [local] Take Data. Partition 0. Read: {4, 0} (6-6)
2025-11-11T14:15:41.418487Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:15:41.418502Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.420862Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:15:41.420876Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.421991Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [6, 7). Partition stream id: 1
2025-11-11T14:15:41.422175Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 1, size 1048576 bytes
2025-11-11T14:15:41.430447Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.430542Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-7)
2025-11-11T14:15:41.430546Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (8-8)
2025-11-11T14:15:41.432172Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:15:41.433072Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-11-11T14:15:41.434781Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (8-8)
2025-11-11T14:15:41.434837Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (9-9)
2025-11-11T14:15:41.434975Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (9-9)
2025-11-11T14:15:41.435002Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (10-10)
2025-11-11T14:15:41.435864Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (10-10)
2025-11-11T14:15:41.435900Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (11-11)
2025-11-11T14:15:41.435918Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (12-12)
2025-11-11T14:15:41.436739Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (11-11)
2025-11-11T14:15:41.437515Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [7, 9). Partition stream id: 1
2025-11-11T14:15:41.437533Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.437737Z :DEBUG: [local] Take Data. Partition 0. Read: {4, 0} (12-12)
2025-11-11T14:15:41.437766Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (13-13)
2025-11-11T14:15:41.437781Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (14-14)
2025-11-11T14:15:41.437893Z :DEBUG: [local] Take Data. Partition 0. Read: {5, 0} (13-13)
2025-11-11T14:15:41.438692Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [9, 10). Partition stream id: 1
2025-11-11T14:15:41.438704Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 1, size 1048576 bytes
2025-11-11T14:15:41.438820Z :DEBUG: [local] Take Data. Partition 0. Read: {6, 0} (14-14)
2025-11-11T14:15:41.439861Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [10, 11). Partition stream id: 1
2025-11-11T14:15:41.439872Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 1, size 1048576 bytes
2025-11-11T14:15:41.442350Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [11, 13). Partition stream id: 1
2025-11-11T14:15:41.442364Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.444730Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Commit offsets [13, 15). Partition stream id: 1
2025-11-11T14:15:41.444913Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] The application data is transferred to the client. Number of messages 2, size 2097152 bytes
2025-11-11T14:15:41.446598Z :DEBUG: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 15 messages
2025-11-11T14:15:41.446699Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:41.446744Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:no_pq_bill_output:0:1:14:15
2025-11-11T14:15:41.446766Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 71 BytesRead: 15728640 MessagesRead: 15 BytesReadCompressed: 15728640 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:41.447037Z :NOTICE: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] 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:41.447220Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:41.447236Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:no_pq_bill_output:0:1:14:15
2025-11-11T14:15:41.447251Z :INFO: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 71 BytesRead: 15728640 MessagesRead: 15 BytesReadCompressed: 15728640 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:41.447261Z :NOTICE: [local] [local] [66cb40ea-a2b2952a-fef7bf44-87c9904e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:40.129962Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Starting read session
2025-11-11T14:15:40.130012Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Starting session to cluster null (localhost:24577)
2025-11-11T14:15:40.130512Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.130525Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.130532Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:40.136581Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Successfully connected. Initializing session
2025-11-11T14:15:40.138086Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Server session id: pq_read_schema_meta_True_consumer_1_2_14444967900767965809_v1
2025-11-11T14:15:40.138163Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.139552Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_read_schema_meta_True_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:40.140482Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.140552Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:15:40.140614Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:40.140625Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:40.140726Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:40.140808Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] The application data is transferred to the client. Number of messages 2, size 86 bytes
2025-11-11T14:15:40.143874Z :DEBUG: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:15:40.145551Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:40.145597Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_read_schema_meta_True_output:0:1:1:2
2025-11-11T14:15:40.145610Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 86 MessagesRead: 2 BytesReadCompressed: 86 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:40.145887Z :NOTICE: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] 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:40.146054Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:40.146069Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_read_schema_meta_True_output:0:1:1:2
2025-11-11T14:15:40.146080Z :INFO: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 86 MessagesRead: 2 BytesReadCompressed: 86 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:40.146092Z :NOTICE: [local] [local] [2ff04ba-359b9408-939df6e-84b38005] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:02.185440Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Starting read session
2025-11-11T14:17:02.185473Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Starting session to cluster null (localhost:5942)
2025-11-11T14:17:02.185821Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:02.185832Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:02.185836Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:02.191048Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Successfully connected. Initializing session
2025-11-11T14:17:02.193115Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Server session id: pq_test_pq_read_write_False_consumer_1_2_1039301323507868628_v1
2025-11-11T14:17:02.193197Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:02.194530Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_False_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:02.195426Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:02.195491Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-7)
2025-11-11T14:17:02.195545Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:02.195558Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:17:02.195567Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-11T14:17:02.195572Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-11-11T14:17:02.195591Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-11-11T14:17:02.195597Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (5-5)
2025-11-11T14:17:02.195601Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 5} (6-6)
2025-11-11T14:17:02.195606Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 6} (7-7)
2025-11-11T14:17:02.195898Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Commit offsets [0, 8). Partition stream id: 1
2025-11-11T14:17:02.195996Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] The application data is transferred to the client. Number of messages 8, size 163 bytes
2025-11-11T14:17:02.198822Z :DEBUG: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 8 messages
2025-11-11T14:17:02.198975Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:02.199020Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_False_output:0:1:7:8
2025-11-11T14:17:02.199029Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:02.199242Z :NOTICE: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] 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:02.202473Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:02.202484Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_False_output:0:1:7:8
2025-11-11T14:17:02.202506Z :INFO: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:02.202517Z :NOTICE: [local] [local] [5b7a098b-e6942ed0-997284cd-5f466c6f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:53.396562Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Starting read session
2025-11-11T14:15:53.396603Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Starting session to cluster null (localhost:6240)
2025-11-11T14:15:53.397065Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.397081Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.397087Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:53.403380Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Successfully connected. Initializing session
2025-11-11T14:15:53.404386Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Server session id: delete_read_rules_0_consumer_1_2_1252066770253988198_v1
2025-11-11T14:15:53.404482Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.406021Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "delete_read_rules_0_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:53.686713Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.686798Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:15:53.686850Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:53.686965Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:15:53.687125Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] The application data is transferred to the client. Number of messages 1, size 2 bytes
2025-11-11T14:15:53.687313Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.687381Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-6)
2025-11-11T14:15:53.687399Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:15:53.687406Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:15:53.687411Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (3-3)
2025-11-11T14:15:53.687414Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (4-4)
2025-11-11T14:15:53.687419Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 4} (5-5)
2025-11-11T14:15:53.687424Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 5} (6-6)
2025-11-11T14:15:53.687475Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Commit offsets [1, 7). Partition stream id: 1
2025-11-11T14:15:53.687565Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] The application data is transferred to the client. Number of messages 6, size 12 bytes
2025-11-11T14:15:53.689279Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:15:53.689361Z :DEBUG: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 7 messages
2025-11-11T14:15:53.689461Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:53.689515Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:delete_read_rules_0_output:0:1:6:7
2025-11-11T14:15:53.689535Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 292 BytesRead: 14 MessagesRead: 7 BytesReadCompressed: 14 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:53.689818Z :NOTICE: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] 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:53.689928Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:53.689939Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:delete_read_rules_0_output:0:1:6:7
2025-11-11T14:15:53.689949Z :INFO: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 293 BytesRead: 14 MessagesRead: 7 BytesReadCompressed: 14 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:53.689957Z :NOTICE: [local] [local] [7626cac5-4568759-b4c228ce-c2c9a0d2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:15.749842Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Starting read session
2025-11-11T14:17:15.749887Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Starting session to cluster null (localhost:21280)
2025-11-11T14:17:15.750319Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:15.750333Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:15.750339Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:15.755615Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Successfully connected. Initializing session
2025-11-11T14:17:15.756585Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Server session id: program_state_recovery_consumer_1_2_10519033681871166820_v1
2025-11-11T14:17:15.756665Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:15.757935Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "program_state_recovery_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:15.952461Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:15.952545Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:15.952594Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:15.952752Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:15.952943Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] The application data is transferred to the client. Number of messages 1, size 14 bytes
2025-11-11T14:17:15.956366Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:15.956454Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-11-11T14:17:15.957825Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:15.957912Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:15.957923Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:17:15.958014Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Commit offsets [1, 3). Partition stream id: 1
2025-11-11T14:17:15.958126Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] The application data is transferred to the client. Number of messages 2, size 28 bytes
2025-11-11T14:17:15.965520Z :DEBUG: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-11-11T14:17:15.965687Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:15.965754Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:program_state_recovery_output:0:1:2:3
2025-11-11T14:17:15.965765Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 215 BytesRead: 42 MessagesRead: 3 BytesReadCompressed: 42 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:15.966033Z :NOTICE: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] 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:15.966144Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:15.966154Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:program_state_recovery_output:0:1:2:3
2025-11-11T14:17:15.966161Z :INFO: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 216 BytesRead: 42 MessagesRead: 3 BytesReadCompressed: 42 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:15.966170Z :NOTICE: [local] [local] [c082b819-fb0f6bb7-fb23778f-6c05d75d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:55.754041Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Starting read session
2025-11-11T14:15:55.754080Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Starting session to cluster null (localhost:18945)
2025-11-11T14:15:55.754709Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:55.754723Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:55.754729Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:55.759576Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Successfully connected. Initializing session
2025-11-11T14:15:55.760964Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Server session id: recovery_consumer_1_3_7165239003145735168_v1
2025-11-11T14:15:55.761069Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:55.762435Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "recovery_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:55.763300Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "recovery_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:15:55.763613Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:55.763671Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-9)
2025-11-11T14:15:55.763715Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:55.763737Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:55.763746Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (2-2)
2025-11-11T14:15:55.763752Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (3-3)
2025-11-11T14:15:55.763765Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (4-4)
2025-11-11T14:15:55.763772Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 3} (5-5)
2025-11-11T14:15:55.763777Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 4} (6-6)
2025-11-11T14:15:55.763783Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 5} (7-7)
2025-11-11T14:15:55.763792Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 6} (8-8)
2025-11-11T14:15:55.763797Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 7} (9-9)
2025-11-11T14:15:55.763938Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Commit offsets [0, 10). Partition stream id: 1
2025-11-11T14:15:55.763981Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] The application data is transferred to the client. Number of messages 10, size 11 bytes
2025-11-11T14:15:55.767052Z :DEBUG: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:15:55.767338Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:55.767382Z :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:9:10
2025-11-11T14:15:55.767393Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 11 MessagesRead: 10 BytesReadCompressed: 11 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:55.767649Z :NOTICE: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] 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:55.771048Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:55.771066Z :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:9:10
2025-11-11T14:15:55.771076Z :INFO: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 11 MessagesRead: 10 BytesReadCompressed: 11 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:55.771089Z :NOTICE: [local] [local] [8b57d896-1ad083c1-d13eef75-cb8dfed9] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:10.105265Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Starting read session
2025-11-11T14:17:10.105335Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Starting session to cluster null (localhost:18359)
2025-11-11T14:17:10.105914Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:10.105931Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:10.105937Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:10.111022Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Successfully connected. Initializing session
2025-11-11T14:17:10.112125Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Server session id: test_time_order_recoverer[v1-kikimr0]_v1_consumer_1_2_6021396708678551936_v1
2025-11-11T14:17:10.112166Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:10.113724Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_time_order_recoverer[v1-kikimr0]_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:11.106693Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:0:0
2025-11-11T14:17:11.106724Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:26.289757Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:26.289845Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:26.289890Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:26.290402Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:26.290444Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-11-11T14:17:26.290467Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:26.290480Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:17:26.290773Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:26.290879Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] The application data is transferred to the client. Number of messages 1, size 23 bytes
2025-11-11T14:17:26.290916Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Commit offsets [1, 3). Partition stream id: 1
2025-11-11T14:17:26.291344Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] The application data is transferred to the client. Number of messages 2, size 46 bytes
2025-11-11T14:17:26.293369Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:26.293469Z :DEBUG: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-11-11T14:17:26.293550Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:26.293581Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:2:3
2025-11-11T14:17:26.293603Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16188 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:26.293828Z :NOTICE: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] 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:26.293996Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:26.294013Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_time_order_recoverer[v1-kikimr0]_v1_output:0:1:2:3
2025-11-11T14:17:26.294025Z :INFO: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16188 BytesRead: 69 MessagesRead: 3 BytesReadCompressed: 69 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:26.294037Z :NOTICE: [local] [local] [9de7970c-dc4f960c-64a8a37b-3b93955a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:14.790667Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Starting read session
2025-11-11T14:17:14.790725Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Starting session to cluster null (localhost:4827)
2025-11-11T14:17:14.791174Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.791188Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.791195Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:14.795959Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Successfully connected. Initializing session
2025-11-11T14:17:14.797151Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Server session id: restart_2_consumer_1_2_7969345525489891969_v1
2025-11-11T14:17:14.797247Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.798744Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_2_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:14.799481Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.799548Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:14.799588Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:14.799678Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:14.799765Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-11-11T14:17:14.802762Z :DEBUG: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:14.802902Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:14.802944Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_2_output:0:1:0:1
2025-11-11T14:17:14.802954Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:14.803193Z :NOTICE: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] 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:14.806568Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:14.806598Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:restart_2_output:0:1:0:1
2025-11-11T14:17:14.806610Z :INFO: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:14.806625Z :NOTICE: [local] [local] [9c693bc-509ab03e-a5982734-9323fe8c] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:12.193369Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Starting read session
2025-11-11T14:16:12.193407Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:12.193804Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.193815Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.193822Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:12.240422Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Successfully connected. Initializing session
2025-11-11T14:16:12.241645Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Server session id: test_2_connection_consumer_1_1_751909328279438548_v1
2025-11-11T14:16:12.241703Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.244183Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_2_connection_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:12.244312Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_2_connection_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:12.765714Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.769503Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:12.769557Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:12.771178Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:12.771286Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:12.777695Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.779792Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-11-11T14:16:12.780045Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.781685Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-6)
2025-11-11T14:16:12.781725Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:12.781737Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-11-11T14:16:12.781744Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (3-3)
2025-11-11T14:16:12.781750Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (4-4)
2025-11-11T14:16:12.781757Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (5-5)
2025-11-11T14:16:12.781763Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (6-6)
2025-11-11T14:16:12.781787Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (7-19)
2025-11-11T14:16:12.781794Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (7-7)
2025-11-11T14:16:12.781799Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (8-8)
2025-11-11T14:16:12.781805Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (9-9)
2025-11-11T14:16:12.781811Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (10-10)
2025-11-11T14:16:12.781819Z :DEBUG: [local] Take Data. Partition 0. Read: {4, 0} (11-11)
2025-11-11T14:16:12.781825Z :DEBUG: [local] Take Data. Partition 0. Read: {5, 0} (12-12)
2025-11-11T14:16:12.781850Z :DEBUG: [local] Take Data. Partition 0. Read: {6, 0} (13-13)
2025-11-11T14:16:12.781856Z :DEBUG: [local] Take Data. Partition 0. Read: {6, 1} (14-14)
2025-11-11T14:16:12.781866Z :DEBUG: [local] Take Data. Partition 0. Read: {7, 0} (15-15)
2025-11-11T14:16:12.781872Z :DEBUG: [local] Take Data. Partition 0. Read: {8, 0} (16-16)
2025-11-11T14:16:12.781876Z :DEBUG: [local] Take Data. Partition 0. Read: {8, 1} (17-17)
2025-11-11T14:16:12.781881Z :DEBUG: [local] Take Data. Partition 0. Read: {9, 0} (18-18)
2025-11-11T14:16:12.781886Z :DEBUG: [local] Take Data. Partition 0. Read: {9, 1} (19-19)
2025-11-11T14:16:12.785500Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [1, 7). Partition stream id: 1
2025-11-11T14:16:12.785599Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 6, size 18 bytes
2025-11-11T14:16:12.785667Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [7, 20). Partition stream id: 1
2025-11-11T14:16:12.785675Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 13, size 39 bytes
2025-11-11T14:16:12.793961Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-11-11T14:16:12.801130Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 2 partition_cookie: 3 }
2025-11-11T14:16:13.197781Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_2_connection_output:1:2:0:0 null:test_2_connection_output:0:1:19:20
2025-11-11T14:16:13.197822Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1004 BytesRead: 60 MessagesRead: 20 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:14.719835Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.719988Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-0)
2025-11-11T14:16:14.720006Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-11-11T14:16:14.722184Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.722267Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (1-1)
2025-11-11T14:16:14.722280Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (1-1)
2025-11-11T14:16:14.723958Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [0, 1). Partition stream id: 2
2025-11-11T14:16:14.724050Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.724075Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [1, 2). Partition stream id: 2
2025-11-11T14:16:14.724082Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.724858Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.725088Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-7)
2025-11-11T14:16:14.725103Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (2-2)
2025-11-11T14:16:14.725109Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (3-3)
2025-11-11T14:16:14.725115Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (4-4)
2025-11-11T14:16:14.725131Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (5-5)
2025-11-11T14:16:14.725137Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 0} (6-6)
2025-11-11T14:16:14.725142Z :DEBUG: [local] Take Data. Partition 1. Read: {5, 0} (7-7)
2025-11-11T14:16:14.726074Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.729571Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (8-8)
2025-11-11T14:16:14.729598Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (8-8)
2025-11-11T14:16:14.729635Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [2, 8). Partition stream id: 2
2025-11-11T14:16:14.729675Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 6, size 18 bytes
2025-11-11T14:16:14.729706Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [8, 9). Partition stream id: 2
2025-11-11T14:16:14.729711Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.730083Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:14.730174Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-11-11T14:16:14.730225Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.730300Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (9-9)
2025-11-11T14:16:14.730322Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (9-9)
2025-11-11T14:16:14.730639Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 3 }
2025-11-11T14:16:14.731324Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 4 }
2025-11-11T14:16:14.733599Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [9, 10). Partition stream id: 2
2025-11-11T14:16:14.733658Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.737546Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 5 }
2025-11-11T14:16:15.507361Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.507432Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (10-10)
2025-11-11T14:16:15.507471Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (10-10)
2025-11-11T14:16:15.509480Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [10, 11). Partition stream id: 2
2025-11-11T14:16:15.509558Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:15.509746Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.509781Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (11-19)
2025-11-11T14:16:15.509794Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (11-11)
2025-11-11T14:16:15.509801Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 1} (12-12)
2025-11-11T14:16:15.509808Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 2} (13-13)
2025-11-11T14:16:15.509814Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 3} (14-14)
2025-11-11T14:16:15.509833Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 4} (15-15)
2025-11-11T14:16:15.509839Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 5} (16-16)
2025-11-11T14:16:15.509844Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 6} (17-17)
2025-11-11T14:16:15.509849Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 7} (18-18)
2025-11-11T14:16:15.509865Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 8} (19-19)
2025-11-11T14:16:15.509944Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Commit offsets [11, 20). Partition stream id: 2
2025-11-11T14:16:15.510029Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] The application data is transferred to the client. Number of messages 9, size 27 bytes
2025-11-11T14:16:15.517718Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 6 }
2025-11-11T14:16:15.518117Z :DEBUG: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 7 }
Closing session. Got 40 messages
2025-11-11T14:16:15.518301Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:15.518330Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_2_connection_output:1:2:19:20 null:test_2_connection_output:0:1:19:20
2025-11-11T14:16:15.518341Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3324 BytesRead: 120 MessagesRead: 40 BytesReadCompressed: 120 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:15.521512Z :NOTICE: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:15.521813Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:15.521826Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_2_connection_output:1:2:19:20 null:test_2_connection_output:0:1:19:20
2025-11-11T14:16:15.521834Z :INFO: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3328 BytesRead: 120 MessagesRead: 40 BytesReadCompressed: 120 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:15.521844Z :NOTICE: [local] [local] [9c48b140-f5033781-450a2d1a-17e1d44e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:10.279953Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Starting read session
2025-11-11T14:16:10.280003Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Starting session to cluster null (localhost:10455)
2025-11-11T14:16:10.280664Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:10.280679Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:10.280685Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:10.298805Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Successfully connected. Initializing session
2025-11-11T14:16:10.299917Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Server session id: test_filter_missing_fields_consumer_1_1_5624113920317622531_v1
2025-11-11T14:16:10.299996Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:10.304662Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filter_missing_fields_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:11.285490Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:0:0
2025-11-11T14:16:11.285518Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1005 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:14.907672Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.909493Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:14.909557Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:14.909644Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:14.909789Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.913681Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:14.913732Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:14.913755Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:14.913793Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:14.913835Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:14.916877Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:14.925603Z :DEBUG: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:14.925780Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:14.925809Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:1:2
2025-11-11T14:16:14.925826Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4645 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:14.926375Z :NOTICE: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] 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:14.931543Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:14.931558Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_missing_fields_output:0:1:1:2
2025-11-11T14:16:14.931578Z :INFO: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4651 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:14.931590Z :NOTICE: [local] [local] [a47b120e-c2dca847-4da83231-9c8eac83] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:14.683489Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Starting read session
2025-11-11T14:17:14.683542Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Starting session to cluster null (localhost:19692)
2025-11-11T14:17:14.683992Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.684007Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.684013Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:14.688982Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Successfully connected. Initializing session
2025-11-11T14:17:14.690164Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Server session id: test_filter_with_mr_consumer_1_1_15779138534594762942_v1
2025-11-11T14:17:14.690242Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:14.691773Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filter_with_mr_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:15.684649Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_with_mr_output:0:1:0:0
2025-11-11T14:17:15.684689Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:18.491463Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:18.491580Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:18.491628Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:18.491741Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:18.491897Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-11-11T14:17:18.495034Z :DEBUG: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:18.495178Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:18.495204Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_with_mr_output:0:1:0:1
2025-11-11T14:17:18.495214Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3811 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:18.495456Z :NOTICE: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] 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.495556Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:18.495569Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filter_with_mr_output:0:1:0:1
2025-11-11T14:17:18.495587Z :INFO: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3812 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:18.495595Z :NOTICE: [local] [local] [5c8666e3-9b47ef93-7613f957-9723a255] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:53.699400Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Starting read session
2025-11-11T14:16:53.699429Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Starting session to cluster null (localhost:11255)
2025-11-11T14:16:53.699755Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:53.699765Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:53.699769Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:53.703098Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Successfully connected. Initializing session
2025-11-11T14:16:53.704199Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Server session id: test_filters_optional_field_consumer_1_1_7947415475065604648_v1
2025-11-11T14:16:53.704258Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:53.707689Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:54.700629Z :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:0
2025-11-11T14:16:54.700660Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:58.351509Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:58.351583Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:58.351629Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:58.351734Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:58.351830Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:58.354170Z :DEBUG: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:58.354302Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:58.354326Z :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:16:58.354334Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4654 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:58.354679Z :NOTICE: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] 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:58.354756Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:58.354764Z :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:16:58.354780Z :INFO: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4655 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:58.354788Z :NOTICE: [local] [local] [a5819d79-4f68bcbd-4de1b768-8fb3672f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:05.953007Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Starting read session
2025-11-11T14:17:05.953063Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Starting session to cluster null (localhost:14682)
2025-11-11T14:17:05.953698Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.953723Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.953730Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:05.958514Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Successfully connected. Initializing session
2025-11-11T14:17:05.959727Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Server session id: test_huge_consumer_1_1_5288704700679584998_v1
2025-11-11T14:17:05.959825Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.961356Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_huge_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:06.953724Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_huge_output:0:1:0:0
2025-11-11T14:17:06.953765Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:09.561752Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:09.561850Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:09.561906Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:09.562053Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:09.562230Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] The application data is transferred to the client. Number of messages 1, size 21 bytes
2025-11-11T14:17:09.562382Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:09.562466Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-3)
2025-11-11T14:17:09.562499Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:09.562509Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:17:09.562517Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (3-3)
2025-11-11T14:17:09.562579Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Commit offsets [1, 4). Partition stream id: 1
2025-11-11T14:17:09.562661Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] The application data is transferred to the client. Number of messages 3, size 73 bytes
2025-11-11T14:17:09.564384Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:09.564462Z :DEBUG: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 4 messages
2025-11-11T14:17:09.564552Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:09.564574Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_huge_output:0:1:3:4
2025-11-11T14:17:09.564601Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3611 BytesRead: 94 MessagesRead: 4 BytesReadCompressed: 94 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:09.564843Z :NOTICE: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] 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:09.564991Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:09.565003Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_huge_output:0:1:3:4
2025-11-11T14:17:09.565013Z :INFO: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3612 BytesRead: 94 MessagesRead: 4 BytesReadCompressed: 94 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:09.565023Z :NOTICE: [local] [local] [df6bbc2a-707081f6-6f5c9fbe-d1ccba2d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:43.204440Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Starting read session
2025-11-11T14:15:43.204483Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Starting session to cluster null (localhost:30228)
2025-11-11T14:15:43.204855Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:43.204868Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:43.204873Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:43.210091Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Successfully connected. Initializing session
2025-11-11T14:15:43.211184Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Server session id: test_json_errors_consumer_1_1_5282378672208439257_v1
2025-11-11T14:15:43.211268Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:43.212879Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_json_errors_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:44.205669Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_json_errors_output:0:1:0:0
2025-11-11T14:15:44.205704Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:46.592310Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:46.592375Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:15:46.592417Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:46.592529Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:15:46.592627Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] The application data is transferred to the client. Number of messages 1, size 6 bytes
2025-11-11T14:15:46.592725Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:46.592772Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:15:46.592809Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:15:46.592840Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:15:46.592901Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] The application data is transferred to the client. Number of messages 1, size 6 bytes
2025-11-11T14:15:46.594794Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:15:46.594870Z :DEBUG: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:15:46.594944Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:46.594965Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_json_errors_output:0:1:1:2
2025-11-11T14:15:46.594975Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3390 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:46.595164Z :NOTICE: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] 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:46.598442Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:46.598454Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_json_errors_output:0:1:1:2
2025-11-11T14:15:46.598462Z :INFO: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3394 BytesRead: 12 MessagesRead: 2 BytesReadCompressed: 12 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:46.598473Z :NOTICE: [local] [local] [d842b164-7304202e-a95cd6d4-7d7653f2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:53.790477Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Starting read session
2025-11-11T14:15:53.790520Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Starting session to cluster null (localhost:11957)
2025-11-11T14:15:53.790913Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.790926Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.790933Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:53.795434Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Successfully connected. Initializing session
2025-11-11T14:15:53.796505Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Server session id: test_many_partitions_consumer_1_1_4735033324542319310_v1
2025-11-11T14:15:53.796617Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:53.797898Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_many_partitions_output". Partition: 2. Read offset: (NULL)
2025-11-11T14:15:53.798085Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_many_partitions_output". Partition: 3. Read offset: (NULL)
2025-11-11T14:15:53.798248Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_many_partitions_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:53.798319Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_many_partitions_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:15:54.791699Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_many_partitions_output:1:4:0:0 null:test_many_partitions_output:0:3:0:0 null:test_many_partitions_output:3:2:0:0 null:test_many_partitions_output:2:1:0:0
2025-11-11T14:15:54.791739Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:57.490852Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.493326Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.493481Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (0-0)
2025-11-11T14:15:57.493526Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (0-0)
2025-11-11T14:15:57.493548Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (1-9)
2025-11-11T14:15:57.493556Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (1-1)
2025-11-11T14:15:57.493564Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 1} (2-2)
2025-11-11T14:15:57.493571Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 2} (3-3)
2025-11-11T14:15:57.493578Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 3} (4-4)
2025-11-11T14:15:57.493587Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 4} (5-5)
2025-11-11T14:15:57.493592Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 5} (6-6)
2025-11-11T14:15:57.493604Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 6} (7-7)
2025-11-11T14:15:57.493610Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 7} (8-8)
2025-11-11T14:15:57.493629Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 8} (9-9)
2025-11-11T14:15:57.493637Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:15:57.493644Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:57.493701Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:15:57.493792Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:15:57.493845Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [1, 10). Partition stream id: 1
2025-11-11T14:15:57.493854Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 9, size 27 bytes
2025-11-11T14:15:57.493871Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [0, 1). Partition stream id: 3
2025-11-11T14:15:57.493879Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:15:57.494677Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.497506Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (10-16)
2025-11-11T14:15:57.497544Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (10-10)
2025-11-11T14:15:57.497553Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 0} (11-11)
2025-11-11T14:15:57.497560Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 1} (12-12)
2025-11-11T14:15:57.497566Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 2} (13-13)
2025-11-11T14:15:57.497574Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 3} (14-14)
2025-11-11T14:15:57.497578Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 4} (15-15)
2025-11-11T14:15:57.497582Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 5} (16-16)
2025-11-11T14:15:57.497643Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.497702Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [10, 17). Partition stream id: 1
2025-11-11T14:15:57.497711Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 7, size 21 bytes
2025-11-11T14:15:57.499960Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (17-17)
2025-11-11T14:15:57.500647Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-11-11T14:15:57.500675Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (17-17)
2025-11-11T14:15:57.500693Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-9)
2025-11-11T14:15:57.500696Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-11-11T14:15:57.500706Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:15:57.500711Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:15:57.500715Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (3-3)
2025-11-11T14:15:57.500718Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (4-4)
2025-11-11T14:15:57.500728Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 4} (5-5)
2025-11-11T14:15:57.500731Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 5} (6-6)
2025-11-11T14:15:57.500735Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 6} (7-7)
2025-11-11T14:15:57.500738Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 7} (8-8)
2025-11-11T14:15:57.500744Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 8} (9-9)
2025-11-11T14:15:57.500791Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.500813Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-11-11T14:15:57.500826Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [17, 18). Partition stream id: 1
2025-11-11T14:15:57.500894Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:15:57.500926Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [1, 10). Partition stream id: 3
2025-11-11T14:15:57.500931Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 9, size 27 bytes
2025-11-11T14:15:57.500827Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (18-20)
2025-11-11T14:15:57.501491Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (18-18)
2025-11-11T14:15:57.501501Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 1} (19-19)
2025-11-11T14:15:57.501506Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 2} (20-20)
2025-11-11T14:15:57.501558Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [18, 21). Partition stream id: 1
2025-11-11T14:15:57.501670Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-11-11T14:15:57.503870Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 3 }
2025-11-11T14:15:57.509243Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.509285Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (21-22)
2025-11-11T14:15:57.509304Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (21-21)
2025-11-11T14:15:57.509311Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 0} (22-22)
2025-11-11T14:15:57.509346Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [21, 23). Partition stream id: 1
2025-11-11T14:15:57.509406Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:15:57.509657Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 4 }
2025-11-11T14:15:57.509705Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 }
2025-11-11T14:15:57.513539Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:57.513912Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (23-29)
2025-11-11T14:15:57.513942Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (23-23)
2025-11-11T14:15:57.513949Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 1} (24-24)
2025-11-11T14:15:57.513955Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 2} (25-25)
2025-11-11T14:15:57.513960Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 3} (26-26)
2025-11-11T14:15:57.513968Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 4} (27-27)
2025-11-11T14:15:57.513973Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 5} (28-28)
2025-11-11T14:15:57.513978Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 6} (29-29)
2025-11-11T14:15:57.514040Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Commit offsets [23, 30). Partition stream id: 1
2025-11-11T14:15:57.514118Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] The application data is transferred to the client. Number of messages 7, size 21 bytes
2025-11-11T14:15:57.514931Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 5 }
2025-11-11T14:15:57.514977Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 6 }
2025-11-11T14:15:57.515422Z :DEBUG: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] [null] Committed response: cookies { assign_id: 2 partition_cookie: 7 }
Closing session. Got 40 messages
2025-11-11T14:15:57.515517Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:57.515546Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_many_partitions_output:1:4:0:0 null:test_many_partitions_output:0:3:9:10 null:test_many_partitions_output:3:2:0:0 null:test_many_partitions_output:2:1:29:30
2025-11-11T14:15:57.515557Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3725 BytesRead: 120 MessagesRead: 40 BytesReadCompressed: 120 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:57.516231Z :NOTICE: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] 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:57.517637Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:57.517656Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_many_partitions_output:1:4:0:0 null:test_many_partitions_output:0:3:9:10 null:test_many_partitions_output:3:2:0:0 null:test_many_partitions_output:2:1:29:30
2025-11-11T14:15:57.517678Z :INFO: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3727 BytesRead: 120 MessagesRead: 40 BytesReadCompressed: 120 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:57.517689Z :NOTICE: [local] [local] [15007b1d-f5b92722-7d16daf4-dbf51ef0] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:01.916839Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Starting read session
2025-11-11T14:17:01.917223Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Starting session to cluster null (localhost:20405)
2025-11-11T14:17:01.917706Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.917723Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.917729Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:01.922586Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Successfully connected. Initializing session
2025-11-11T14:17:01.923699Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Server session id: test_nested_types_consumer_1_1_3481749372243883169_v1
2025-11-11T14:17:01.923807Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.925924Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_nested_types_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:02.918732Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_output:0:1:0:0
2025-11-11T14:17:02.918771Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:06.709614Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:06.709699Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:06.709746Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:06.709903Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:06.710043Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] The application data is transferred to the client. Number of messages 1, size 76 bytes
2025-11-11T14:17:06.713008Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:06.713067Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-11-11T14:17:06.713101Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:06.713109Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:17:06.713157Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Commit offsets [1, 3). Partition stream id: 1
2025-11-11T14:17:06.713230Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] The application data is transferred to the client. Number of messages 2, size 108 bytes
2025-11-11T14:17:06.715473Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:06.715545Z :DEBUG: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-11-11T14:17:06.715618Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:06.715642Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_output:0:1:2:3
2025-11-11T14:17:06.715653Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4798 BytesRead: 184 MessagesRead: 3 BytesReadCompressed: 184 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:06.715929Z :NOTICE: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] 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:06.716079Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:06.716091Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_nested_types_output:0:1:2:3
2025-11-11T14:17:06.716100Z :INFO: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4799 BytesRead: 184 MessagesRead: 3 BytesReadCompressed: 184 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:06.716109Z :NOTICE: [local] [local] [668c0371-2e351763-3c857261-4ffd68ee] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:55.609410Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Starting read session
2025-11-11T14:16:55.609467Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Starting session to cluster null (localhost:22745)
2025-11-11T14:16:55.609915Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:55.609928Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:55.609934Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:55.614421Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Successfully connected. Initializing session
2025-11-11T14:16:55.615545Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Server session id: test_read_raw_format_with_row_dispatcher_consumer_1_1_18443193458892533782_v1
2025-11-11T14:16:55.615632Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:55.617553Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [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:16:56.610624Z :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:0
2025-11-11T14:16:56.610659Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:59.990369Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:59.990458Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:59.990525Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:59.990644Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:59.990757Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-11-11T14:16:59.990853Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:59.990905Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:59.990950Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:59.991032Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:59.991187Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] The application data is transferred to the client. Number of messages 1, size 15 bytes
2025-11-11T14:16:59.992763Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:59.992842Z :DEBUG: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:59.992917Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:59.992943Z :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:1:2
2025-11-11T14:16:59.992954Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4383 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:59.993209Z :NOTICE: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] 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:59.993336Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:59.993368Z :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:1:2
2025-11-11T14:16:59.993376Z :INFO: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4383 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:59.993385Z :NOTICE: [local] [local] [c0f033a2-a5eda313-18560084-9631527a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:00.607491Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Starting read session
2025-11-11T14:16:00.607526Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Starting session to cluster null (localhost:30441)
2025-11-11T14:16:00.608023Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:00.608037Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:00.608043Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:00.614555Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Successfully connected. Initializing session
2025-11-11T14:16:00.615792Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Server session id: test_scheme_error_consumer_1_2_10142929575908660406_v1
2025-11-11T14:16:00.615848Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:00.617254Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_scheme_error_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:01.608739Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_scheme_error_output:0:1:0:0
2025-11-11T14:16:01.608770Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:04.242336Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:04.242461Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:04.242492Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:04.243049Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:04.243106Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:04.248159Z :DEBUG: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:04.248561Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:04.248582Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_scheme_error_output:0:1:0:1
2025-11-11T14:16:04.248590Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3641 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:04.249006Z :NOTICE: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] 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:04.249429Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:04.249440Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_scheme_error_output:0:1:0:1
2025-11-11T14:16:04.249447Z :INFO: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3641 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:04.249465Z :NOTICE: [local] [local] [19b771bc-de183c1e-60baa203-65e36707] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:47.688633Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Starting read session
2025-11-11T14:15:47.688702Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Starting session to cluster null (localhost:1768)
2025-11-11T14:15:47.689245Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:47.689261Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:47.689268Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:47.694795Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Successfully connected. Initializing session
2025-11-11T14:15:47.695672Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Server session id: test_simple_not_null_consumer_1_1_1372357314435343826_v1
2025-11-11T14:15:47.695747Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:47.696926Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_simple_not_null_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:48.689705Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_not_null_output:0:1:0:0
2025-11-11T14:15:48.689740Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:52.144159Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:52.144232Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:15:52.144277Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:52.144426Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:15:52.144597Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:15:52.144724Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:52.144930Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-2)
2025-11-11T14:15:52.144976Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:15:52.144987Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (2-2)
2025-11-11T14:15:52.145054Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Commit offsets [1, 3). Partition stream id: 1
2025-11-11T14:15:52.145156Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:15:52.147632Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:15:52.147727Z :DEBUG: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 3 messages
2025-11-11T14:15:52.147850Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:52.147882Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_not_null_output:0:1:2:3
2025-11-11T14:15:52.147894Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4459 BytesRead: 9 MessagesRead: 3 BytesReadCompressed: 9 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:52.148168Z :NOTICE: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] 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:52.148293Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:52.148302Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_simple_not_null_output:0:1:2:3
2025-11-11T14:15:52.148310Z :INFO: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4459 BytesRead: 9 MessagesRead: 3 BytesReadCompressed: 9 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:52.148320Z :NOTICE: [local] [local] [d655133b-dbf72780-a75f4de1-581b7391] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:07.064317Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Starting read session
2025-11-11T14:16:07.064356Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:07.064769Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.064783Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.064788Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:07.077938Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Successfully connected. Initializing session
2025-11-11T14:16:07.089350Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Server session id: test_start_new_query_consumer_1_1_14008650260918862934_v1
2025-11-11T14:16:07.089452Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:07.097711Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:08.066441Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:0:0
2025-11-11T14:16:08.066472Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:11.045776Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.049643Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:11.049691Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:11.050377Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:11.050541Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:11.052051Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.053446Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:16:11.053494Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:16:11.055494Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:16:11.055598Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:16:11.059385Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:11.060916Z :DEBUG: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:16:11.061092Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:11.061122Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:1:2
2025-11-11T14:16:11.061136Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3996 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:11.061493Z :NOTICE: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] 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.061924Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:11.061936Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output1:0:1:1:2
2025-11-11T14:16:11.061945Z :INFO: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3997 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:11.061955Z :NOTICE: [local] [local] [3a1d665b-2b94126f-6c145864-84f2e48e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:01.614060Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Starting read session
2025-11-11T14:17:01.614105Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Starting session to cluster null (localhost:1893)
2025-11-11T14:17:01.614528Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.614540Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.614544Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:01.620592Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Successfully connected. Initializing session
2025-11-11T14:17:01.621965Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Server session id: test_stop_start_consumer_1_1_3926329371814533765_v1
2025-11-11T14:17:01.622040Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:01.623109Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:02.614767Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:0:0
2025-11-11T14:17:02.614821Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:05.259848Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.259921Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:05.259966Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:05.260053Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:05.260167Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:05.260436Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:05.260493Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:17:05.260526Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:05.260566Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:17:05.260630Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:05.262701Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:17:05.263143Z :DEBUG: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:17:05.263252Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:05.263276Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:1:2
2025-11-11T14:17:05.263287Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3649 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:05.263517Z :NOTICE: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] 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.263642Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:05.263653Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_output:0:1:1:2
2025-11-11T14:17:05.263661Z :INFO: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3649 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:05.263671Z :NOTICE: [local] [local] [cfc39bf2-28fd828d-ccc1c9ee-f5f635c2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:36.373621Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Starting read session
2025-11-11T14:16:36.373669Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Starting session to cluster null (localhost:7770)
2025-11-11T14:16:36.374126Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:36.374139Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:36.374145Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:36.379950Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] Successfully connected. Initializing session
2025-11-11T14:16:36.381122Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_3_10010374741413738507_v1
2025-11-11T14:16:36.381214Z :DEBUG: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:36.382431Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:36.382622Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:37.374687Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:0:2:0:0 null:test_idle_watermarks_no_shared_output:1:1:0:0
2025-11-11T14:16:37.374738Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:17:06.373049Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:06.373088Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:0:2:0:0 null:test_idle_watermarks_no_shared_output:1:1:0:0
2025-11-11T14:17:06.373112Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:06.373658Z :NOTICE: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] 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:06.373775Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:06.373795Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:0:2:0:0 null:test_idle_watermarks_no_shared_output:1:1:0:0
2025-11-11T14:17:06.373803Z :INFO: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:06.373812Z :NOTICE: [local] [local] [f011b3d8-ff13a18d-4f825b1c-73b63d5f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:40.068570Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Starting read session
2025-11-11T14:15:40.068618Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Starting session to cluster null (localhost:25220)
2025-11-11T14:15:40.069001Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.069013Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.069019Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:40.074241Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] Successfully connected. Initializing session
2025-11-11T14:15:40.075954Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] Server session id: test_idle_watermarks_shared_consumer_1_1_11966020596015318185_v1
2025-11-11T14:15:40.076051Z :DEBUG: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:40.079236Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:40.079484Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_shared_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:15:41.069657Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_shared_output:1:2:0:0 null:test_idle_watermarks_shared_output:0:1:0:0
2025-11-11T14:15:41.069710Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:16:10.069523Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:10.069570Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_shared_output:1:2:0:0 null:test_idle_watermarks_shared_output:0:1:0:0
2025-11-11T14:16:10.069582Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:10.074527Z :NOTICE: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] 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:10.074660Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:10.074673Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_shared_output:1:2:0:0 null:test_idle_watermarks_shared_output:0:1:0:0
2025-11-11T14:16:10.074682Z :INFO: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30006 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:10.074691Z :NOTICE: [local] [local] [623d1093-84df8e80-e18f2f71-afef605f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:41.394456Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Starting read session
2025-11-11T14:15:41.394500Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Starting session to cluster null (localhost:26454)
2025-11-11T14:15:41.394964Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.394980Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.394986Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:41.402033Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] Successfully connected. Initializing session
2025-11-11T14:15:41.403131Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] Server session id: test_watermarks_shared_consumer_1_1_2311240737609321802_v1
2025-11-11T14:15:41.403233Z :DEBUG: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:41.404687Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:42.395662Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_shared_output:0:1:0:0
2025-11-11T14:15:42.395702Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:16:11.395871Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:11.395905Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_shared_output:0:1:0:0
2025-11-11T14:16:11.395914Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:11.396434Z :NOTICE: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] 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.396524Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:11.396534Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_shared_output:0:1:0:0
2025-11-11T14:16:11.396541Z :INFO: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:11.396559Z :NOTICE: [local] [local] [7990a855-bbfe5db2-7fcc42a1-eb4bbc7b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:01.223621Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Starting read session
2025-11-11T14:16:01.223660Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Starting session to cluster null (localhost:23791)
2025-11-11T14:16:01.224313Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:01.224325Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:01.224330Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:01.230410Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Successfully connected. Initializing session
2025-11-11T14:16:01.233835Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Server session id: pq_test_match_recognize_sink_v1_consumer_1_2_11025022560658481095_v1
2025-11-11T14:16:01.233913Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:01.240186Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_match_recognize_sink_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:01.241332Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:01.241394Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-2)
2025-11-11T14:16:01.241434Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:01.241449Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:01.241457Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-11T14:16:01.241526Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Commit offsets [0, 3). Partition stream id: 1
2025-11-11T14:16:01.241606Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] The application data is transferred to the client. Number of messages 3, size 717 bytes
2025-11-11T14:16:01.257276Z :DEBUG: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 3 messages
2025-11-11T14:16:01.257433Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:01.257479Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_match_recognize_sink_v1_output:0:1:2:3
2025-11-11T14:16:01.257488Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 33 BytesRead: 717 MessagesRead: 3 BytesReadCompressed: 717 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:01.257692Z :NOTICE: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] 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:01.257875Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:01.257885Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_match_recognize_sink_v1_output:0:1:2:3
2025-11-11T14:16:01.257893Z :INFO: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 34 BytesRead: 717 MessagesRead: 3 BytesReadCompressed: 717 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:01.257927Z :NOTICE: [local] [local] [3af8aff4-e3e490c7-a1b1326-f3a159f7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:02.836210Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Starting read session
2025-11-11T14:16:02.836251Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Starting session to cluster null (localhost:16564)
2025-11-11T14:16:02.836631Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.836643Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.836650Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:02.843812Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Successfully connected. Initializing session
2025-11-11T14:16:02.850045Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Server session id: pq_yq_streaming_v1_consumer_1_2_6467505568668836746_v1
2025-11-11T14:16:02.850137Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:02.855163Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_yq_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:03.045710Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:03.049485Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:03.049537Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:03.053616Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:03.053748Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] The application data is transferred to the client. Number of messages 1, size 38 bytes
2025-11-11T14:16:03.059594Z :DEBUG: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:03.059754Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:03.059790Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_streaming_v1_output:0:1:0:1
2025-11-11T14:16:03.059800Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 223 BytesRead: 38 MessagesRead: 1 BytesReadCompressed: 38 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:03.059953Z :NOTICE: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] 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:03.060325Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:03.060331Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_streaming_v1_output:0:1:0:1
2025-11-11T14:16:03.060340Z :INFO: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 224 BytesRead: 38 MessagesRead: 1 BytesReadCompressed: 38 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:03.060348Z :NOTICE: [local] [local] [e943c204-c32dc6d8-634c156-9fd5201f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:15:39.495823Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Starting read session
2025-11-11T14:15:39.495868Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Starting session to cluster null (localhost:28311)
2025-11-11T14:15:39.496311Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:39.496324Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:39.496330Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:15:39.501783Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Successfully connected. Initializing session
2025-11-11T14:15:39.502963Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Server session id: pq_yq_read_from_binding_v1_consumer_1_2_453640333931825671_v1
2025-11-11T14:15:39.503069Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:39.506449Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_yq_read_from_binding_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:15:39.507431Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:15:39.507492Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:15:39.507535Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:15:39.507559Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:15:39.507681Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:15:39.507780Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:15:39.511002Z :DEBUG: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:15:39.511159Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Closing read session. Close timeout: 5.000000s
2025-11-11T14:15:39.511219Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_v1_output:0:1:1:2
2025-11-11T14:15:39.511232Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:15:39.511525Z :NOTICE: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] 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:39.511673Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Closing read session. Close timeout: 0.000000s
2025-11-11T14:15:39.511685Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_yq_read_from_binding_v1_output:0:1:1:2
2025-11-11T14:15:39.511693Z :INFO: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:15:39.511701Z :NOTICE: [local] [local] [a74a2890-beb99bd2-9606f197-fc835b48] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
