2025-11-11T14:16:31.095504Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Starting read session
2025-11-11T14:16:31.095558Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Starting session to cluster null (localhost:62972)
2025-11-11T14:16:31.096479Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.096501Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.096509Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:31.102106Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Successfully connected. Initializing session
2025-11-11T14:16:31.103192Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Server session id: continue_2_consumer_1_9_4288957531477216868_v1
2025-11-11T14:16:31.103276Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.104431Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "continue_2_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:31.104659Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "continue_2_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:31.105511Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.105562Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-11-11T14:16:31.105591Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-11-11T14:16:31.105600Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-11-11T14:16:31.105706Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:31.105799Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:16:31.106116Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.106163Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:31.106202Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:31.106215Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:31.106283Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Commit offsets [0, 2). Partition stream id: 2
2025-11-11T14:16:31.106374Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:16:31.108501Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:16:31.113938Z :DEBUG: [local] [local] [424d3248-681852e9-dafba78b-190803d7] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 4 messages
2025-11-11T14:16:31.114083Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:31.114129Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_2_output:0:2:1:2 null:continue_2_output:1:1:1:2
2025-11-11T14:16:31.114142Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:31.114368Z :NOTICE: [local] [local] [424d3248-681852e9-dafba78b-190803d7] 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:31.114493Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:31.114509Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:continue_2_output:0:2:1:2 null:continue_2_output:1:1:1:2
2025-11-11T14:16:31.114519Z :INFO: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 19 BytesRead: 4 MessagesRead: 4 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:31.114529Z :NOTICE: [local] [local] [424d3248-681852e9-dafba78b-190803d7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:40.539306Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Starting read session
2025-11-11T14:18:40.543294Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Starting session to cluster null (localhost:12894)
2025-11-11T14:18:40.543920Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:40.543938Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:40.543945Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:40.552444Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] Successfully connected. Initializing session
2025-11-11T14:18:40.559020Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] Server session id: disposition_fresh_consumer_1_8_3637994238321068483_v1
2025-11-11T14:18:40.559118Z :DEBUG: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:40.561760Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_fresh_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:41.544713Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_fresh_output:0:1:0:0
2025-11-11T14:18:41.544756Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1005 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Closing session. No data during 30.000000s
2025-11-11T14:19:10.538734Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Closing read session. Close timeout: 5.000000s
2025-11-11T14:19:10.538771Z :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:19:10.538783Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:19:10.539274Z :NOTICE: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:19:10.541868Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Closing read session. Close timeout: 0.000000s
2025-11-11T14:19:10.541890Z :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:19:10.541900Z :INFO: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:10.541911Z :NOTICE: [local] [local] [cccc1d12-231d99b6-aae5b252-119268b2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:05.343131Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Starting read session
2025-11-11T14:16:05.343173Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Starting session to cluster null (localhost:4996)
2025-11-11T14:16:05.345821Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.345841Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.345848Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:05.351065Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Successfully connected. Initializing session
2025-11-11T14:16:05.358264Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Server session id: disposition_oldest_consumer_1_6_11910331128875297686_v1
2025-11-11T14:16:05.358327Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.362087Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_oldest_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:05.366148Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:05.366218Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (6-11)
2025-11-11T14:16:05.366271Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-11-11T14:16:05.366280Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (7-7)
2025-11-11T14:16:05.366284Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (8-8)
2025-11-11T14:16:05.366288Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (9-9)
2025-11-11T14:16:05.366296Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (10-10)
2025-11-11T14:16:05.366301Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (11-11)
2025-11-11T14:16:05.366404Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Commit offsets [6, 12). Partition stream id: 1
2025-11-11T14:16:05.366477Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] The application data is transferred to the client. Number of messages 6, size 6 bytes
2025-11-11T14:16:05.371359Z :DEBUG: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 6 messages
2025-11-11T14:16:05.371495Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:05.371542Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:11:12
2025-11-11T14:16:05.371552Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 28 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:05.371725Z :NOTICE: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] 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:05.371850Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:05.371859Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_oldest_output:0:1:11:12
2025-11-11T14:16:05.371867Z :INFO: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 28 BytesRead: 6 MessagesRead: 6 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:05.371890Z :NOTICE: [local] [local] [304a820-fbd9638f-b5068887-32d4063d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:04.857451Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Starting read session
2025-11-11T14:16:04.857494Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Starting session to cluster null (localhost:24577)
2025-11-11T14:16:04.857919Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:04.857930Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:04.857935Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:04.863488Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Successfully connected. Initializing session
2025-11-11T14:16:04.865472Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Server session id: pq_test_pq_read_write_True_consumer_1_6_15290397896962520230_v1
2025-11-11T14:16:04.865539Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:04.867262Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_True_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:04.868048Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:04.868097Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-7)
2025-11-11T14:16:04.868132Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:04.868139Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:04.868145Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-11T14:16:04.868150Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-11-11T14:16:04.868157Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-11-11T14:16:04.868162Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (5-5)
2025-11-11T14:16:04.868166Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 5} (6-6)
2025-11-11T14:16:04.868172Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 6} (7-7)
2025-11-11T14:16:04.868249Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Commit offsets [0, 8). Partition stream id: 1
2025-11-11T14:16:04.868309Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] The application data is transferred to the client. Number of messages 8, size 163 bytes
2025-11-11T14:16:04.871016Z :DEBUG: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 8 messages
2025-11-11T14:16:04.871127Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:04.871158Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_True_output:0:1:7:8
2025-11-11T14:16:04.871167Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:04.871312Z :NOTICE: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] 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.871480Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:04.871491Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_True_output:0:1:7:8
2025-11-11T14:16:04.871511Z :INFO: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 163 MessagesRead: 8 BytesReadCompressed: 163 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:04.871522Z :NOTICE: [local] [local] [7880d60b-27dab7d2-294172e7-21617863] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:09.447071Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Starting read session
2025-11-11T14:16:09.447107Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Starting session to cluster null (localhost:18945)
2025-11-11T14:16:09.447545Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:09.447555Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:09.447560Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:09.453379Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Successfully connected. Initializing session
2025-11-11T14:16:09.455406Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Server session id: recovery_consumer_1_9_16983379977601187717_v1
2025-11-11T14:16:09.455507Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:09.458642Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "recovery_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:09.458779Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "recovery_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:16:09.459510Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:09.459581Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (20-29)
2025-11-11T14:16:09.459617Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (20-20)
2025-11-11T14:16:09.459627Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (21-21)
2025-11-11T14:16:09.459633Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (22-22)
2025-11-11T14:16:09.459639Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (23-23)
2025-11-11T14:16:09.459647Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (24-24)
2025-11-11T14:16:09.459652Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 3} (25-25)
2025-11-11T14:16:09.459657Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 4} (26-26)
2025-11-11T14:16:09.459662Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 5} (27-27)
2025-11-11T14:16:09.459672Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 6} (28-28)
2025-11-11T14:16:09.459678Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 7} (29-29)
2025-11-11T14:16:09.459925Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Commit offsets [20, 30). Partition stream id: 1
2025-11-11T14:16:09.460038Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] The application data is transferred to the client. Number of messages 10, size 20 bytes
2025-11-11T14:16:09.463654Z :DEBUG: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:16:09.463839Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:09.463890Z :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:29:30
2025-11-11T14:16:09.463901Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:09.465462Z :NOTICE: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] 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:09.465707Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:09.465717Z :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:29:30
2025-11-11T14:16:09.465724Z :INFO: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:09.465734Z :NOTICE: [local] [local] [f2f77cfb-6326c670-8b7a6fa9-255f4b38] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:44.346668Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Starting read session
2025-11-11T14:17:44.353921Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Starting session to cluster null (localhost:18359)
2025-11-11T14:17:44.354637Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:44.356390Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:44.357628Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:44.365618Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Successfully connected. Initializing session
2025-11-11T14:17:44.366560Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Server session id: pq_kikimr_streaming_v1_consumer_1_9_19708483044196995_v1
2025-11-11T14:17:44.366644Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:44.368314Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:44.368522Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:44.369324Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:44.369389Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (10-19)
2025-11-11T14:17:44.369448Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (10-10)
2025-11-11T14:17:44.369463Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (11-11)
2025-11-11T14:17:44.369472Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (12-12)
2025-11-11T14:17:44.369478Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 1} (13-13)
2025-11-11T14:17:44.369498Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 2} (14-14)
2025-11-11T14:17:44.369504Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (15-15)
2025-11-11T14:17:44.369510Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 0} (16-16)
2025-11-11T14:17:44.369516Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 1} (17-17)
2025-11-11T14:17:44.369527Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 2} (18-18)
2025-11-11T14:17:44.369532Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 3} (19-19)
2025-11-11T14:17:44.369681Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Commit offsets [10, 20). Partition stream id: 2
2025-11-11T14:17:44.370701Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] The application data is transferred to the client. Number of messages 10, size 20 bytes
2025-11-11T14:17:44.379324Z :DEBUG: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:17:44.379509Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:44.379561Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:19:20 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-11-11T14:17:44.379578Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 32 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:44.380389Z :NOTICE: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] 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:44.383773Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:44.383788Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:1:2:19:20 null:pq_kikimr_streaming_v1_output:0:1:0:0
2025-11-11T14:17:44.383798Z :INFO: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 37 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:44.383824Z :NOTICE: [local] [local] [1126024b-75f28934-3f95a0c4-d789b37d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:41.463906Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Starting read session
2025-11-11T14:16:41.463963Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:41.464387Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.464399Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.464405Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:41.469654Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Successfully connected. Initializing session
2025-11-11T14:16:41.470787Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Server session id: test_3_session_consumer_1_8_131570363655580386_v1
2025-11-11T14:16:41.470868Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.472146Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:41.472828Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.472889Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:41.472928Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:41.472940Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:41.473053Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:41.473120Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:41.475759Z :DEBUG: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:41.475890Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:41.475927Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:1:2
2025-11-11T14:16:41.475936Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:41.476156Z :NOTICE: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:41.477547Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:41.477559Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:1:2
2025-11-11T14:16:41.477569Z :INFO: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:41.477581Z :NOTICE: [local] [local] [d450e50b-42bc084d-33bae7f7-17b62cc4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:40.271171Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Starting read session
2025-11-11T14:17:40.271215Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Starting session to cluster null (localhost:19692)
2025-11-11T14:17:40.271642Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.271656Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.271663Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:40.276979Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Successfully connected. Initializing session
2025-11-11T14:17:40.278189Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Server session id: test_filters_non_optional_field_consumer_1_5_12747753681470576271_v1
2025-11-11T14:17:40.278275Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:40.280137Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:41.272735Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:0:1
2025-11-11T14:17:41.272775Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:44.713081Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:44.713177Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:17:44.713226Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:44.713362Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:17:44.713497Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:44.716906Z :DEBUG: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:44.717048Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:44.717076Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:1:2
2025-11-11T14:17:44.717087Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4445 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:44.717372Z :NOTICE: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] 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:44.717587Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:44.717597Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:1:2
2025-11-11T14:17:44.717619Z :INFO: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4446 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:44.717630Z :NOTICE: [local] [local] [f6c07bf6-483c0841-89d51d46-d1b82810] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:09.073217Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Starting read session
2025-11-11T14:17:09.073266Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:09.073754Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:09.073768Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:09.073775Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:09.078634Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Successfully connected. Initializing session
2025-11-11T14:17:09.079696Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Server session id: test_filters_optional_field_consumer_1_5_15301935745538775917_v1
2025-11-11T14:17:09.079743Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:09.081138Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:10.074704Z :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:2
2025-11-11T14:17:10.074746Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:12.649446Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:12.653468Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:17:12.653529Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:12.653697Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:17:12.653838Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:12.656553Z :DEBUG: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:12.656708Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:12.656796Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:2:3
2025-11-11T14:17:12.656808Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3583 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:12.657035Z :NOTICE: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] 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:12.657178Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:12.657194Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:2:3
2025-11-11T14:17:12.657227Z :INFO: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3584 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:12.657238Z :NOTICE: [local] [local] [12f69c7a-d844e411-8918de59-e74d58d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:24.651779Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Starting read session
2025-11-11T14:17:24.651815Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Starting session to cluster null (localhost:22745)
2025-11-11T14:17:24.652164Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.652176Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.652182Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:24.657496Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Successfully connected. Initializing session
2025-11-11T14:17:24.661079Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Server session id: test_restart_compute_node_consumer_1_5_413195967095501797_v1
2025-11-11T14:17:24.661144Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:24.662570Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-11-11T14:17:24.662738Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:24.662787Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:24.662952Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-11-11T14:17:25.652674Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:0:0 null:test_restart_compute_node_output:0:3:0:0 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:2:1:0:0
2025-11-11T14:17:25.652709Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:28.053085Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.053195Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:17:28.053277Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:17:28.053393Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [0, 1). Partition stream id: 3
2025-11-11T14:17:28.053548Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:28.054324Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.054406Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:17:28.054437Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:17:28.054495Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [1, 2). Partition stream id: 3
2025-11-11T14:17:28.054579Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:28.055206Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.055254Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:17:28.055293Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:28.055337Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [2, 3). Partition stream id: 3
2025-11-11T14:17:28.055388Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:28.055737Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.055868Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:17:28.055887Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:17:28.055942Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [3, 4). Partition stream id: 3
2025-11-11T14:17:28.056035Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:28.057685Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-11-11T14:17:28.057848Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.057897Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 } cookies { assign_id: 4 partition_cookie: 3 }
2025-11-11T14:17:28.057898Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (0-0)
2025-11-11T14:17:28.057931Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (0-0)
2025-11-11T14:17:28.057972Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:17:28.057994Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:28.058103Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Committed response: cookies { assign_id: 4 partition_cookie: 4 }
2025-11-11T14:17:28.058402Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:28.058449Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (1-3)
2025-11-11T14:17:28.058464Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (1-1)
2025-11-11T14:17:28.058471Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 1} (2-2)
2025-11-11T14:17:28.058479Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 2} (3-3)
2025-11-11T14:17:28.058508Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Commit offsets [1, 4). Partition stream id: 1
2025-11-11T14:17:28.058582Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-11-11T14:17:28.058987Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-11-11T14:17:28.060088Z :DEBUG: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
Closing session. Got 8 messages
2025-11-11T14:17:28.060256Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:28.060292Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:0:0 null:test_restart_compute_node_output:0:3:3:4 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:2:1:3:4
2025-11-11T14:17:28.060315Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3408 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:28.060608Z :NOTICE: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] 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:28.060753Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:28.060768Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:0:0 null:test_restart_compute_node_output:0:3:3:4 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:2:1:3:4
2025-11-11T14:17:28.060778Z :INFO: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3409 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:28.060789Z :NOTICE: [local] [local] [fae5feed-afefc01a-c37c2807-fe6ecaf] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:11.555439Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Starting read session
2025-11-11T14:16:11.555472Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:11.556038Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.556055Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.556060Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:11.563481Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] Successfully connected. Initializing session
2025-11-11T14:16:11.574317Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] Server session id: test_start_new_query_consumer_1_4_16742232647766325497_v1
2025-11-11T14:16:11.574432Z :DEBUG: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:11.575791Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output1". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-11-11T14:16:12.557617Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:12.557667Z :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:2
2025-11-11T14:16:12.557694Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:12.557929Z :NOTICE: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:12.558016Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:12.558026Z :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:2
2025-11-11T14:16:12.558034Z :INFO: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:12.558043Z :NOTICE: [local] [local] [71d00604-58e8b83c-a5a86df7-358ea02f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:00.469830Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Starting read session
2025-11-11T14:18:00.469875Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Starting session to cluster null (localhost:1893)
2025-11-11T14:18:00.470332Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.470345Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.470352Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:00.481058Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Successfully connected. Initializing session
2025-11-11T14:18:00.490482Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Server session id: test_stop_start_with_filter_consumer_1_7_6328693940893109323_v1
2025-11-11T14:18:00.491975Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:00.493893Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_stop_start_with_filter_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:01.473520Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:0:0
2025-11-11T14:18:01.473559Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:05.783023Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:05.786429Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:18:05.786485Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:18:05.786974Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:05.789498Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (1-1)
2025-11-11T14:18:05.809623Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (1-1)
2025-11-11T14:18:05.809526Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:18:05.825641Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:05.830896Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-11-11T14:18:05.847777Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Commit offsets [1, 2). Partition stream id: 1
2025-11-11T14:18:05.847934Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:05.850750Z :DEBUG: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 2 messages
2025-11-11T14:18:05.854270Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:05.854302Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:1:2
2025-11-11T14:18:05.854324Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5384 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:05.857490Z :NOTICE: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:18:05.895309Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:05.895329Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_stop_start_with_filter_output:0:1:1:2
2025-11-11T14:18:05.895339Z :INFO: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5425 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:05.895356Z :NOTICE: [local] [local] [4d958700-fe2ef68-a50fe12f-82fce38a] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:25.683098Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Starting read session
2025-11-11T14:16:25.683132Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Starting session to cluster null (localhost:25220)
2025-11-11T14:16:25.683535Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.683552Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.683557Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:25.687957Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] Successfully connected. Initializing session
2025-11-11T14:16:25.689210Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] Server session id: test_watermarks_no_shared_consumer_1_6_13414892900374727520_v1
2025-11-11T14:16:25.689274Z :DEBUG: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:25.690755Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:26.683764Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-11-11T14:16:26.683804Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 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:55.682576Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:55.682611Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-11-11T14:16:55.682627Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 29999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:55.682919Z :NOTICE: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] 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:55.683064Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:55.683075Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:0:0
2025-11-11T14:16:55.683082Z :INFO: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:55.683091Z :NOTICE: [local] [local] [6978721f-e1d96a06-dab08194-e2a0c8bc] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:26.250537Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Starting read session
2025-11-11T14:16:26.250583Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Starting session to cluster null (localhost:23791)
2025-11-11T14:16:26.251264Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:26.251277Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:26.251286Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:26.259410Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Successfully connected. Initializing session
2025-11-11T14:16:26.266694Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Server session id: test_state_load_mode2_consumer_1_6_10282651406179934792_v1
2025-11-11T14:16:26.266794Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:26.268396Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_state_load_mode2_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:26.274519Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:26.274586Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:26.274641Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:26.274786Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:26.274926Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] The application data is transferred to the client. Number of messages 1, size 16 bytes
2025-11-11T14:16:26.277759Z :DEBUG: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:26.277892Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:26.278640Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_state_load_mode2_output:0:1:0:1
2025-11-11T14:16:26.278665Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Counters: { Errors: 0 CurrentSessionLifetimeMs: 27 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:26.281470Z :NOTICE: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] 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:26.285599Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:26.285616Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_state_load_mode2_output:0:1:0:1
2025-11-11T14:16:26.285626Z :INFO: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Counters: { Errors: 0 CurrentSessionLifetimeMs: 35 BytesRead: 16 MessagesRead: 1 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:26.285639Z :NOTICE: [local] [local] [568e088b-811c7a4f-3f64a4d3-55995531] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
