2025-11-11T14:19:39.823332Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Starting read session
2025-11-11T14:19:39.825035Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Starting session to cluster null (localhost:12894)
2025-11-11T14:19:39.825639Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:39.826006Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:39.826016Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:19:39.833591Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Successfully connected. Initializing session
2025-11-11T14:19:39.840294Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Server session id: disposition_from_time_consumer_1_14_2133396204325158193_v1
2025-11-11T14:19:39.842615Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:39.847305Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:19:39.854619Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:39.854707Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-11-11T14:19:39.854763Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:19:39.854789Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:19:39.854930Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:19:39.855091Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:19:39.858738Z :DEBUG: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:19:39.859929Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Closing read session. Close timeout: 5.000000s
2025-11-11T14:19:39.859989Z :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-11-11T14:19:39.860003Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Counters: { Errors: 0 CurrentSessionLifetimeMs: 36 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:19:39.860277Z :NOTICE: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] 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:39.860408Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Closing read session. Close timeout: 0.000000s
2025-11-11T14:19:39.860423Z :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-11-11T14:19:39.860432Z :INFO: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Counters: { Errors: 0 CurrentSessionLifetimeMs: 37 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:39.860442Z :NOTICE: [local] [local] [b1ff82b8-d725869f-3078370-9bad1723] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:31.259096Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Starting read session
2025-11-11T14:17:31.259147Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Starting session to cluster null (localhost:4996)
2025-11-11T14:17:31.259609Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.259626Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.259632Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:31.269086Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Successfully connected. Initializing session
2025-11-11T14:17:31.270276Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Server session id: disposition_time_ago_consumer_1_12_12009839041799424570_v1
2025-11-11T14:17:31.270363Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.271621Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:31.272370Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.272431Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-5)
2025-11-11T14:17:31.272476Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:17:31.272490Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:17:31.272584Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Commit offsets [4, 6). Partition stream id: 1
2025-11-11T14:17:31.272651Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:17:31.274602Z :DEBUG: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:17:31.274736Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:31.274780Z :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-11-11T14:17:31.274789Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Counters: { Errors: 0 CurrentSessionLifetimeMs: 15 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:31.276114Z :NOTICE: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] 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:31.276226Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:31.276237Z :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-11-11T14:17:31.276244Z :INFO: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:31.276253Z :NOTICE: [local] [local] [9e5d3ac5-10c198d0-d9f69ac8-359a7d89] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:45.220378Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Starting read session
2025-11-11T14:16:45.220442Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:45.220859Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.220870Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.220875Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:45.233981Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Successfully connected. Initializing session
2025-11-11T14:16:45.235261Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Server session id: test_3_session_consumer_1_11_18146742558187476105_v1
2025-11-11T14:16:45.235378Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.237824Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session2". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:45.242588Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:45.242647Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:16:45.242699Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:45.242709Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:16:45.242788Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:16:45.242899Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:45.250337Z :DEBUG: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:45.250526Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:45.250582Z :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-11-11T14:16:45.250594Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:45.250851Z :NOTICE: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] 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:45.251160Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:45.251172Z :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-11-11T14:16:45.251198Z :INFO: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Counters: { Errors: 0 CurrentSessionLifetimeMs: 30 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:45.251210Z :NOTICE: [local] [local] [eb42ef72-3c2df761-baa20c3d-7ec4a6ce] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:04.436000Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Starting read session
2025-11-11T14:18:04.436420Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Starting session to cluster null (localhost:19692)
2025-11-11T14:18:04.436890Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:04.436902Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:04.436909Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:04.457837Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] Successfully connected. Initializing session
2025-11-11T14:18:04.466205Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] Server session id: test_filters_non_optional_field_consumer_1_11_6235411596002002283_v1
2025-11-11T14:18:04.475379Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:04.475594Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [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:18:05.441544Z :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:4
2025-11-11T14:18:05.441585Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1005 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:08.847925Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:08.854998Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-4)
2025-11-11T14:18:08.861455Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:18:08.901995Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] Commit offsets [4, 5). Partition stream id: 1
2025-11-11T14:18:08.902214Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:08.909109Z :DEBUG: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:18:08.910222Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:08.910255Z :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:4:5
2025-11-11T14:18:08.910266Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4474 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:08.917484Z :NOTICE: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] 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:08.925775Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:08.925796Z :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:4:5
2025-11-11T14:18:08.925821Z :INFO: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4489 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:08.925838Z :NOTICE: [local] [local] [8d2ffc55-dc07fe19-c4b99c24-3080bc45] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:31.216711Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Starting read session
2025-11-11T14:17:31.216763Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:31.217165Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.217181Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.217187Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:31.223234Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] Successfully connected. Initializing session
2025-11-11T14:17:31.224505Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] Server session id: test_filters_optional_field_consumer_1_11_8125041432377507599_v1
2025-11-11T14:17:31.224585Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:31.226146Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [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:32.217713Z :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:5
2025-11-11T14:17:32.217750Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:34.624114Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:34.625464Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (5-5)
2025-11-11T14:17:34.625511Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-11-11T14:17:34.629535Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] Commit offsets [5, 6). Partition stream id: 1
2025-11-11T14:17:34.629660Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:34.633466Z :DEBUG: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:34.633853Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:34.633872Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:5:6
2025-11-11T14:17:34.633880Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3417 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:34.634105Z :NOTICE: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] 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:34.637529Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:34.637546Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:5:6
2025-11-11T14:17:34.637565Z :INFO: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3420 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:34.637578Z :NOTICE: [local] [local] [da436823-cf6273b4-e123648b-40ef9188] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:18:05.853634Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Starting read session
2025-11-11T14:18:05.853687Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Starting session to cluster null (localhost:22745)
2025-11-11T14:18:05.854202Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:05.854218Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:05.854225Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:18:05.861811Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Successfully connected. Initializing session
2025-11-11T14:18:05.863292Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Server session id: test_restart_compute_node_consumer_1_16_5990421407687787899_v1
2025-11-11T14:18:05.863405Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:05.870443Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:18:05.889963Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:18:05.889987Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-11-11T14:18:05.893753Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-11-11T14:18:06.857558Z :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:2:3:0:12 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:0:12
2025-11-11T14:18:06.873991Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:10.140456Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:10.163066Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:10.163353Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (12-12)
2025-11-11T14:18:10.163413Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (12-12)
2025-11-11T14:18:10.163440Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (13-13)
2025-11-11T14:18:10.163449Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (13-13)
2025-11-11T14:18:10.163552Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [12, 13). Partition stream id: 1
2025-11-11T14:18:10.163896Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:10.172482Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (12-12)
2025-11-11T14:18:10.172515Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (14-14)
2025-11-11T14:18:10.172598Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:10.172623Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (14-14)
2025-11-11T14:18:10.172696Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:18:10.172729Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (12-12)
2025-11-11T14:18:10.172756Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (13-15)
2025-11-11T14:18:10.172758Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (15-15)
2025-11-11T14:18:10.172770Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [13, 14). Partition stream id: 1
2025-11-11T14:18:10.172764Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (13-13)
2025-11-11T14:18:10.172799Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 0} (14-14)
2025-11-11T14:18:10.172806Z :DEBUG: [local] Take Data. Partition 2. Read: {2, 0} (15-15)
2025-11-11T14:18:10.172834Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (15-15)
2025-11-11T14:18:10.172855Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:10.172882Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [14, 15). Partition stream id: 1
2025-11-11T14:18:10.172889Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:10.172905Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [12, 13). Partition stream id: 3
2025-11-11T14:18:10.172910Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:10.172943Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [13, 16). Partition stream id: 3
2025-11-11T14:18:10.172949Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 3, size 9 bytes
2025-11-11T14:18:10.172967Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Commit offsets [15, 16). Partition stream id: 1
2025-11-11T14:18:10.172973Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:18:10.182461Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-11-11T14:18:10.182634Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Committed response: cookies { assign_id: 4 partition_cookie: 2 } cookies { assign_id: 4 partition_cookie: 3 } cookies { assign_id: 4 partition_cookie: 4 }
2025-11-11T14:18:10.182670Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
2025-11-11T14:18:10.183321Z :DEBUG: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] [null] Committed response: cookies { assign_id: 2 partition_cookie: 2 }
Closing session. Got 8 messages
2025-11-11T14:18:10.183438Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Closing read session. Close timeout: 5.000000s
2025-11-11T14:18:10.183473Z :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:2:3:15:16 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:15:16
2025-11-11T14:18:10.183485Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4329 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:18:10.183774Z :NOTICE: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] 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:10.183935Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Closing read session. Close timeout: 0.000000s
2025-11-11T14:18:10.183952Z :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:2:3:15:16 null:test_restart_compute_node_output:1:2:0:0 null:test_restart_compute_node_output:0:1:15:16
2025-11-11T14:18:10.183963Z :INFO: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4330 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:18:10.183974Z :NOTICE: [local] [local] [6e766743-56f5977c-542e0f65-388c91aa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:15.440418Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Starting read session
2025-11-11T14:16:15.440470Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:15.441013Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.441029Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.441036Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:15.446913Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Successfully connected. Initializing session
2025-11-11T14:16:15.449112Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Server session id: test_start_new_query_consumer_1_7_11048081650409232730_v1
2025-11-11T14:16:15.449179Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.450489Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_test_pq_read_write_output2". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:15.451384Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:15.453721Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-3)
2025-11-11T14:16:15.453763Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:16:15.453777Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (3-3)
2025-11-11T14:16:15.453862Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Commit offsets [2, 4). Partition stream id: 1
2025-11-11T14:16:15.453956Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] The application data is transferred to the client. Number of messages 2, size 6 bytes
2025-11-11T14:16:15.463228Z :DEBUG: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:15.463450Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:15.463502Z :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-11-11T14:16:15.463514Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Counters: { Errors: 0 CurrentSessionLifetimeMs: 23 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:15.463721Z :NOTICE: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:15.467148Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:15.467160Z :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-11-11T14:16:15.467167Z :INFO: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Counters: { Errors: 0 CurrentSessionLifetimeMs: 26 BytesRead: 6 MessagesRead: 2 BytesReadCompressed: 6 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:15.467176Z :NOTICE: [local] [local] [68585b45-bfaf62d2-f513ed1-d7fd8e64] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
