2025-12-09T03:44:48.469443Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Starting read session
2025-12-09T03:44:48.469476Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Starting session to cluster null (localhost:29962)
2025-12-09T03:44:48.469824Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:48.469834Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:48.469839Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:48.474047Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Successfully connected. Initializing session
2025-12-09T03:44:48.475176Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Server session id: disposition_from_time_consumer_1_9_5838120010163185373_v1
2025-12-09T03:44:48.475261Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:48.476659Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:48.478626Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:48.478674Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:44:48.478711Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:44:48.478723Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:44:48.478804Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:44:48.478881Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:44:48.481888Z :DEBUG: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:48.481984Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:48.482031Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:1:2
2025-12-09T03:44:48.482037Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:48.482206Z :NOTICE: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] 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-12-09T03:44:48.482385Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:48.482405Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:1:2
2025-12-09T03:44:48.482415Z :INFO: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:48.482430Z :NOTICE: [local] [local] [adfb9365-93373676-d6fd61aa-80868308] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:09.619661Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Starting read session
2025-12-09T03:44:09.619713Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Starting session to cluster null (localhost:62047)
2025-12-09T03:44:09.620228Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:09.620242Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:09.620249Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:44:09.626667Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Successfully connected. Initializing session
2025-12-09T03:44:09.628994Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Server session id: disposition_time_ago_consumer_1_8_10489742880058267594_v1
2025-12-09T03:44:09.629075Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:09.631815Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:44:09.632904Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:44:09.632990Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:44:09.633032Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:44:09.633047Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:44:09.633167Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:44:09.633272Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-09T03:44:09.636323Z :DEBUG: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:44:09.637072Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Closing read session. Close timeout: 5.000000s
2025-12-09T03:44:09.637155Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:1:2
2025-12-09T03:44:09.637168Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:44:09.637389Z :NOTICE: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] 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-12-09T03:44:09.640681Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:09.640703Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:1:2
2025-12-09T03:44:09.640710Z :INFO: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Counters: { Errors: 0 CurrentSessionLifetimeMs: 21 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:09.640718Z :NOTICE: [local] [local] [c0c7d004-86ac9d55-d805fcf-6ba4b666] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:40.010464Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Starting read session
2025-12-09T03:43:40.010516Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Starting session to cluster null (localhost:8635)
2025-12-09T03:43:40.011034Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:40.011051Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:40.011057Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:40.016037Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Successfully connected. Initializing session
2025-12-09T03:43:40.016952Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Server session id: test_match_recognize[v1-kikimr0]_v1_consumer_1_11_70105759311822504_v1
2025-12-09T03:43:40.016989Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:40.018386Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_match_recognize[v1-kikimr0]_v1_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:41.011249Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:0
2025-12-09T03:43:41.011284Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:58.427135Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:58.427216Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:43:58.427306Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:58.427418Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:43:58.427463Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] The application data is transferred to the client. Number of messages 1, size 91 bytes
2025-12-09T03:43:58.429601Z :DEBUG: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:43:58.429718Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:58.429739Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:1
2025-12-09T03:43:58.429746Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18419 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:58.429957Z :NOTICE: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] 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-12-09T03:43:58.430113Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:58.430128Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_match_recognize[v1-kikimr0]_v1_output:0:1:0:1
2025-12-09T03:43:58.430148Z :INFO: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18419 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:58.430173Z :NOTICE: [local] [local] [66ccdb6c-73cdbea9-1f66c4d8-102849df] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:39.676824Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Starting read session
2025-12-09T03:42:39.676869Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Starting session to cluster null (localhost:6559)
2025-12-09T03:42:39.677302Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.677314Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.677321Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:39.683426Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Successfully connected. Initializing session
2025-12-09T03:42:39.685246Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Server session id: restart_2_consumer_1_11_14671746886266984921_v1
2025-12-09T03:42:39.685356Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.687164Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "restart_2_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:39.688240Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:39.688330Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-12-09T03:42:39.688370Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:39.688491Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Commit offsets [0, 1). Partition stream id: 1
2025-12-09T03:42:39.688617Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] The application data is transferred to the client. Number of messages 1, size 4 bytes
2025-12-09T03:42:39.691868Z :DEBUG: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:42:39.692058Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:39.692107Z :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-12-09T03:42:39.692119Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:39.692502Z :NOTICE: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] 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-12-09T03:42:39.692613Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:39.692622Z :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-12-09T03:42:39.692630Z :INFO: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 4 MessagesRead: 1 BytesReadCompressed: 4 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:39.692640Z :NOTICE: [local] [local] [29012ab0-4462f406-cfbbeabd-3ec8e378] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:36.890153Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Starting read session
2025-12-09T03:42:36.890203Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Starting session to cluster null (localhost:21106)
2025-12-09T03:42:36.890616Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.890629Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.890635Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:36.896227Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Successfully connected. Initializing session
2025-12-09T03:42:36.897501Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Server session id: test_3_session_consumer_1_9_5642810226338766433_v1
2025-12-09T03:42:36.897616Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.898922Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:36.899903Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:36.899957Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:42:36.899994Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:36.900005Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:42:36.900136Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:42:36.900253Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-09T03:42:36.902977Z :DEBUG: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:42:36.903140Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:36.903183Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:1:2
2025-12-09T03:42:36.903193Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:36.903424Z :NOTICE: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] 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-12-09T03:42:36.906710Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:36.906721Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session3:0:1:1:2
2025-12-09T03:42:36.906730Z :INFO: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:36.906748Z :NOTICE: [local] [local] [4652cf6f-7acc3987-4570ea4c-98604dee] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:49.606940Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Starting read session
2025-12-09T03:42:49.606988Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Starting session to cluster null (localhost:15610)
2025-12-09T03:42:49.607498Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:49.607511Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:49.607518Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:49.612656Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Successfully connected. Initializing session
2025-12-09T03:42:49.613728Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Server session id: test_filters_non_optional_field_consumer_1_7_7964071993263108042_v1
2025-12-09T03:42:49.613783Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:49.615209Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:50.608323Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:0:3
2025-12-09T03:42:50.608363Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:53.380656Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:53.380761Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-09T03:42:53.380811Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-09T03:42:53.380960Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-09T03:42:53.381084Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:53.388023Z :DEBUG: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-09T03:42:53.388202Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:53.388231Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:3:4
2025-12-09T03:42:53.388244Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3781 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:53.388506Z :NOTICE: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] 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-12-09T03:42:53.388747Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:53.388765Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_non_optional_field_output:0:1:3:4
2025-12-09T03:42:53.388794Z :INFO: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3781 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:53.388806Z :NOTICE: [local] [local] [ad4d8767-a03b5582-5e13283f-aaa98786] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:22.402078Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Starting read session
2025-12-09T03:42:22.402140Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Starting session to cluster null (localhost:5893)
2025-12-09T03:42:22.402706Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:22.402722Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:22.402728Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:42:22.411777Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Successfully connected. Initializing session
2025-12-09T03:42:22.413077Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Server session id: test_restart_compute_node_consumer_1_13_10081016479574981259_v1
2025-12-09T03:42:22.413201Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:22.414952Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:22.415247Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:42:22.415323Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-09T03:42:22.415334Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-09T03:42:23.403339Z :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:4 null:test_restart_compute_node_output:2:3:0:2 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:0:2
2025-12-09T03:42:23.403384Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:44.592660Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:44.592754Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (2-2)
2025-12-09T03:42:44.592800Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (2-2)
2025-12-09T03:42:44.592946Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [2, 3). Partition stream id: 3
2025-12-09T03:42:44.593094Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:44.593301Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:44.593369Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (3-3)
2025-12-09T03:42:44.593377Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-12-09T03:42:44.593412Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (3-3)
2025-12-09T03:42:44.593436Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:42:44.593439Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (4-4)
2025-12-09T03:42:44.593472Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (4-4)
2025-12-09T03:42:44.593472Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [3, 4). Partition stream id: 3
2025-12-09T03:42:44.593562Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:44.593590Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [2, 3). Partition stream id: 1
2025-12-09T03:42:44.593598Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:44.593625Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [4, 5). Partition stream id: 4
2025-12-09T03:42:44.593630Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:44.594213Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:44.596533Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-12-09T03:42:44.598070Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-09T03:42:44.598123Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-09T03:42:44.598246Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:42:44.598263Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [3, 4). Partition stream id: 1
2025-12-09T03:42:44.598281Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-09T03:42:44.598304Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (5-7)
2025-12-09T03:42:44.598332Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (5-5)
2025-12-09T03:42:44.598341Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (6-6)
2025-12-09T03:42:44.598350Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (7-7)
2025-12-09T03:42:44.598368Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-09T03:42:44.598403Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-12-09T03:42:44.598413Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Commit offsets [5, 8). Partition stream id: 4
2025-12-09T03:42:44.598483Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-09T03:42:44.598484Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-09T03:42:44.599865Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
2025-12-09T03:42:44.599941Z :DEBUG: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-09T03:42:44.600042Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Closing read session. Close timeout: 5.000000s
2025-12-09T03:42:44.600077Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:7:8 null:test_restart_compute_node_output:2:3:3:4 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:3:4
2025-12-09T03:42:44.600108Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22198 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:42:44.600341Z :NOTICE: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] 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-12-09T03:42:44.600467Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:44.600481Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:3:4:7:8 null:test_restart_compute_node_output:2:3:3:4 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:3:4
2025-12-09T03:42:44.600494Z :INFO: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22198 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:44.600504Z :NOTICE: [local] [local] [5299b67c-c6ce85ec-39c8d6ff-ab65fe28] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:09.683255Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Starting read session
2025-12-09T03:43:09.683303Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Starting session to cluster null (localhost:25706)
2025-12-09T03:43:09.683845Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:09.683860Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:09.683867Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:09.692225Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] Successfully connected. Initializing session
2025-12-09T03:43:09.695273Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] Server session id: test_start_new_query_consumer_1_5_7205195396387651027_v1
2025-12-09T03:43:09.695371Z :DEBUG: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:09.696840Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
Closing session. No data during 1.000000s
2025-12-09T03:43:10.682927Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:10.682976Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:2
2025-12-09T03:43:10.682988Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:10.683366Z :NOTICE: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] 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-12-09T03:43:10.683507Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:10.683519Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_test_pq_read_write_output2:0:1:0:2
2025-12-09T03:43:10.683528Z :INFO: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:10.683537Z :NOTICE: [local] [local] [804dd7d6-34c98766-25a0fe4b-721d29f6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:36.033114Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Starting read session
2025-12-09T03:43:36.033149Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Starting session to cluster null (localhost:4927)
2025-12-09T03:43:36.033562Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:36.033576Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:36.033582Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:36.039028Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Successfully connected. Initializing session
2025-12-09T03:43:36.039975Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Server session id: test_idle_watermarks_no_shared_consumer_1_8_5915690853591497747_v1
2025-12-09T03:43:36.040074Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:36.041098Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:36.041241Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_idle_watermarks_no_shared_output". Partition: 1. Read offset: (NULL)
2025-12-09T03:43:36.041859Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:36.041910Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:43:36.041949Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:36.041962Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:43:36.042089Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:43:36.042190Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-12-09T03:43:36.044645Z :DEBUG: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:43:36.044792Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:36.044825Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:1:2:0:0 null:test_idle_watermarks_no_shared_output:0:1:1:2
2025-12-09T03:43:36.044832Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:36.045027Z :NOTICE: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] 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-12-09T03:43:36.045135Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:36.045144Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_idle_watermarks_no_shared_output:1:2:0:0 null:test_idle_watermarks_no_shared_output:0:1:1:2
2025-12-09T03:43:36.045153Z :INFO: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:36.045168Z :NOTICE: [local] [local] [96b2f6e-3bf9cdcf-9f34ee84-c159c892] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:06.571769Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Starting read session
2025-12-09T03:43:06.571838Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Starting session to cluster null (localhost:21992)
2025-12-09T03:43:06.572314Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.572331Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.572337Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Reconnecting session to cluster null in 0.000000s
2025-12-09T03:43:06.577844Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Successfully connected. Initializing session
2025-12-09T03:43:06.582233Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Server session id: test_watermarks_no_shared_consumer_1_7_8024843569495292078_v1
2025-12-09T03:43:06.582327Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.582441Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:06.583773Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-09T03:43:06.583837Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-12-09T03:43:06.583886Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:43:06.583897Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:43:06.584093Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Commit offsets [0, 2). Partition stream id: 1
2025-12-09T03:43:06.584201Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-12-09T03:43:06.588911Z :DEBUG: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-09T03:43:06.590016Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Closing read session. Close timeout: 5.000000s
2025-12-09T03:43:06.590067Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:1:2
2025-12-09T03:43:06.590081Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-09T03:43:06.590373Z :NOTICE: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] 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-12-09T03:43:06.590537Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:06.590554Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_watermarks_no_shared_output:0:1:1:2
2025-12-09T03:43:06.590567Z :INFO: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:06.590584Z :NOTICE: [local] [local] [2e57bea2-54044daf-2b9fa374-52d9cb0b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
