2025-12-12T12:33:16.525135Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Starting read session
2025-12-12T12:33:16.525184Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Starting session to cluster null (localhost:64299)
2025-12-12T12:33:16.525654Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:16.525669Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:16.525675Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:33:16.535777Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Successfully connected. Initializing session
2025-12-12T12:33:16.543468Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Server session id: disposition_from_time_consumer_1_13_12050477045242977998_v1
2025-12-12T12:33:16.543589Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:16.543727Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:33:16.545931Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:33:16.546127Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-12T12:33:16.546194Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:33:16.546205Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T12:33:16.546318Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T12:33:16.546438Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:33:16.550851Z :DEBUG: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:33:16.552308Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Closing read session. Close timeout: 5.000000s
2025-12-12T12:33:16.552363Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:5:6
2025-12-12T12:33:16.552384Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 27 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:33:16.552667Z :NOTICE: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] 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-12T12:33:16.552796Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Closing read session. Close timeout: 0.000000s
2025-12-12T12:33:16.552806Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_from_time_output:0:1:5:6
2025-12-12T12:33:16.552813Z :INFO: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 27 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:33:16.552822Z :NOTICE: [local] [local] [548929cf-99c9e8f-cdbdb631-165eed97] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:05.835754Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Starting read session
2025-12-12T12:28:05.835811Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Starting session to cluster null (localhost:12669)
2025-12-12T12:28:05.836249Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:05.836263Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:05.836269Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:05.841480Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Successfully connected. Initializing session
2025-12-12T12:28:05.842535Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Server session id: disposition_time_ago_consumer_1_12_4941971227233746417_v1
2025-12-12T12:28:05.842617Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:05.843915Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:05.844646Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:05.844709Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-12-12T12:28:05.845202Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:28:05.845215Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-12-12T12:28:05.845300Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Commit offsets [4, 6). Partition stream id: 1
2025-12-12T12:28:05.845388Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-12-12T12:28:05.848419Z :DEBUG: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:05.848555Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:05.848592Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:5:6
2025-12-12T12:28:05.848602Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:05.848969Z :NOTICE: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] 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-12T12:28:05.849081Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:05.849105Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:disposition_time_ago_output:0:1:5:6
2025-12-12T12:28:05.849113Z :INFO: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:05.849121Z :NOTICE: [local] [local] [c7485914-6ea73f1a-8defd085-34292da] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:21.491190Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Starting read session
2025-12-12T12:28:21.491230Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Starting session to cluster null (localhost:12106)
2025-12-12T12:28:21.491696Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.491712Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.491718Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:21.497984Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Successfully connected. Initializing session
2025-12-12T12:28:21.499427Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Server session id: test_3_session_consumer_1_11_13731496033534121779_v1
2025-12-12T12:28:21.499523Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.503865Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:21.504659Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:21.504785Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-12T12:28:21.504820Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:28:21.504831Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:28:21.504959Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-12T12:28:21.505059Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:21.508908Z :DEBUG: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:28:21.509085Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:21.509116Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:3:4
2025-12-12T12:28:21.509124Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:21.509341Z :NOTICE: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] 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-12T12:28:21.509491Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:21.509503Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_3_session2:0:1:3:4
2025-12-12T12:28:21.509523Z :INFO: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Counters: { Errors: 0 CurrentSessionLifetimeMs: 18 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:21.509537Z :NOTICE: [local] [local] [c8f408d0-85ece88c-35778398-fcd39654] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:35:55.213556Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Starting read session
2025-12-12T12:35:55.213591Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Starting session to cluster null (localhost:63390)
2025-12-12T12:35:55.214069Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:55.214081Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:55.214086Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:35:55.220714Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Successfully connected. Initializing session
2025-12-12T12:35:55.227146Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Server session id: test_filters_non_optional_field_consumer_1_11_3084123846750703529_v1
2025-12-12T12:35:55.227266Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:55.231743Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:35:56.214336Z :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:5
2025-12-12T12:35:56.221912Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:58.804967Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:35:58.805043Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-12-12T12:35:58.805077Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-12-12T12:35:58.807145Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Commit offsets [5, 6). Partition stream id: 1
2025-12-12T12:35:58.807332Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:35:58.814882Z :DEBUG: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-12-12T12:35:58.818585Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Closing read session. Close timeout: 5.000000s
2025-12-12T12:35:58.818615Z :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:5:6
2025-12-12T12:35:58.818628Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3605 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:35:58.819054Z :NOTICE: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] 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-12T12:35:58.822401Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Closing read session. Close timeout: 0.000000s
2025-12-12T12:35:58.822419Z :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:5:6
2025-12-12T12:35:58.822439Z :INFO: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3608 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:35:58.822454Z :NOTICE: [local] [local] [64d03a2c-fc05f541-2b34e272-f8f91370] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:50.153841Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Starting read session
2025-12-12T12:28:50.153890Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Starting session to cluster null (localhost:8973)
2025-12-12T12:28:50.154361Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:50.154375Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:50.154381Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:28:50.166696Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Successfully connected. Initializing session
2025-12-12T12:28:50.168384Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Server session id: test_restart_compute_node_consumer_1_23_4466924643432503504_v1
2025-12-12T12:28:50.168475Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:50.172185Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-12-12T12:28:50.172601Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-12-12T12:28:50.173052Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-12-12T12:28:50.173066Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:51.155291Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:0:12 null:test_restart_compute_node_output:1:2:0:6 null:test_restart_compute_node_output:2:1:0:6
2025-12-12T12:28:51.155344Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:54.795918Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:54.799078Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (6-6)
2025-12-12T12:28:54.799143Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (6-6)
2025-12-12T12:28:54.799259Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [6, 7). Partition stream id: 1
2025-12-12T12:28:54.799431Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:54.799597Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:54.799707Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (12-12)
2025-12-12T12:28:54.799745Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (12-12)
2025-12-12T12:28:54.799764Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-6)
2025-12-12T12:28:54.799773Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (6-6)
2025-12-12T12:28:54.799804Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [12, 13). Partition stream id: 3
2025-12-12T12:28:54.799900Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:54.799937Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [6, 7). Partition stream id: 2
2025-12-12T12:28:54.799974Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:54.803330Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:28:54.803406Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (7-7)
2025-12-12T12:28:54.803440Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (7-7)
2025-12-12T12:28:54.803461Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (7-7)
2025-12-12T12:28:54.803479Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (7-7)
2025-12-12T12:28:54.803489Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 3 (13-15)
2025-12-12T12:28:54.803498Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 0} (13-13)
2025-12-12T12:28:54.803504Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 1} (14-14)
2025-12-12T12:28:54.803511Z :DEBUG: [local] Take Data. Partition 3. Read: {0, 2} (15-15)
2025-12-12T12:28:54.803539Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [7, 8). Partition stream id: 1
2025-12-12T12:28:54.803639Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:54.803666Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [7, 8). Partition stream id: 2
2025-12-12T12:28:54.803673Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-12-12T12:28:54.803691Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Commit offsets [13, 16). Partition stream id: 3
2025-12-12T12:28:54.803697Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-12-12T12:28:54.807875Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
2025-12-12T12:28:54.808004Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-12-12T12:28:54.810718Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 3 partition_cookie: 1 }
2025-12-12T12:28:54.816274Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 3 partition_cookie: 2 }
2025-12-12T12:28:54.816402Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
2025-12-12T12:28:54.816427Z :DEBUG: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] [null] Committed response: cookies { assign_id: 1 partition_cookie: 2 }
Closing session. Got 8 messages
2025-12-12T12:28:54.816485Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Closing read session. Close timeout: 5.000000s
2025-12-12T12:28:54.816521Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:15:16 null:test_restart_compute_node_output:1:2:7:8 null:test_restart_compute_node_output:2:1:7:8
2025-12-12T12:28:54.816532Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4662 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:28:54.816738Z :NOTICE: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] 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-12T12:28:54.819204Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:54.819229Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:0:4:0:0 null:test_restart_compute_node_output:3:3:15:16 null:test_restart_compute_node_output:1:2:7:8 null:test_restart_compute_node_output:2:1:7:8
2025-12-12T12:28:54.819250Z :INFO: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4665 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:54.819268Z :NOTICE: [local] [local] [4bc8eeef-453dedd9-bfe92a49-d4ef3139] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:20.086154Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Starting read session
2025-12-12T12:27:20.087024Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Starting session to cluster null (localhost:8603)
2025-12-12T12:27:20.087724Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.087747Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.087757Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Reconnecting session to cluster null in 0.000000s
2025-12-12T12:27:20.092754Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Successfully connected. Initializing session
2025-12-12T12:27:20.096328Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Server session id: test_start_new_query_consumer_1_8_6401492263885150543_v1
2025-12-12T12:27:20.096408Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.098119Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:20.099144Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-12-12T12:27:20.099222Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-12-12T12:27:20.099272Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:27:20.099296Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-12-12T12:27:20.099404Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Commit offsets [2, 4). Partition stream id: 1
2025-12-12T12:27:20.099522Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-12-12T12:27:20.102411Z :DEBUG: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-12-12T12:27:20.102582Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Closing read session. Close timeout: 5.000000s
2025-12-12T12:27:20.102626Z :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:3:4
2025-12-12T12:27:20.102639Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-12-12T12:27:20.102903Z :NOTICE: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] 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-12T12:27:20.103048Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:20.103059Z :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:3:4
2025-12-12T12:27:20.103086Z :INFO: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 16 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:20.103097Z :NOTICE: [local] [local] [b50b1429-f3222bca-aa9d552-ece0ede1] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
