2025-11-11T14:19:25.446369Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Starting read session
2025-11-11T14:19:25.461830Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Starting session to cluster null (localhost:12894)
2025-11-11T14:19:25.462451Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:25.462464Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:25.462471Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:19:25.473270Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Successfully connected. Initializing session
2025-11-11T14:19:25.478457Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Server session id: disposition_from_time_consumer_1_10_3577783732997750035_v1
2025-11-11T14:19:25.485628Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:25.489473Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_from_time_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:19:25.497801Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:19:25.497973Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:19:25.498009Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:19:25.498020Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:19:25.498547Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:19:25.498638Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:19:25.511238Z :DEBUG: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:19:25.539017Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Closing read session. Close timeout: 5.000000s
2025-11-11T14:19:25.539087Z :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-11-11T14:19:25.539102Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 92 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:19:25.545914Z :NOTICE: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] 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:25.546798Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Closing read session. Close timeout: 0.000000s
2025-11-11T14:19:25.546812Z :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-11-11T14:19:25.546822Z :INFO: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Counters: { Errors: 0 CurrentSessionLifetimeMs: 100 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:19:25.546832Z :NOTICE: [local] [local] [897f2254-97354d50-42dbc27a-c2a36da6] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:31.413627Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Starting read session
2025-11-11T14:16:31.413671Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Starting session to cluster null (localhost:4996)
2025-11-11T14:16:31.414105Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.414119Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.414124Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:31.420133Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Successfully connected. Initializing session
2025-11-11T14:16:31.421363Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Server session id: disposition_time_ago_consumer_1_8_14678650576492194195_v1
2025-11-11T14:16:31.421476Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.422543Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "disposition_time_ago_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:31.423245Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:31.423309Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:31.423371Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:31.423384Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:31.423502Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:31.423564Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] The application data is transferred to the client. Number of messages 2, size 2 bytes
2025-11-11T14:16:31.426021Z :DEBUG: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:31.426151Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:31.426207Z :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-11-11T14:16:31.426217Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:31.426445Z :NOTICE: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:31.426651Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:31.426661Z :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-11-11T14:16:31.426694Z :INFO: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Counters: { Errors: 0 CurrentSessionLifetimeMs: 13 BytesRead: 2 MessagesRead: 2 BytesReadCompressed: 2 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:31.426704Z :NOTICE: [local] [local] [4fb4905f-9d791973-914db7ad-f1fca405] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:32.171257Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Starting read session
2025-11-11T14:16:32.171301Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Starting session to cluster null (localhost:18945)
2025-11-11T14:16:32.171663Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.171673Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.171677Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:32.176578Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Successfully connected. Initializing session
2025-11-11T14:16:32.177800Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Server session id: test_match_recognize[v1-kikimr0]_v1_consumer_1_11_1159722342892794636_v1
2025-11-11T14:16:32.177910Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:32.179517Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_match_recognize[v1-kikimr0]_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:33.172693Z :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-11-11T14:16:33.172721Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:49.941453Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:49.941551Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-0)
2025-11-11T14:16:49.941602Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:49.941717Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Commit offsets [0, 1). Partition stream id: 1
2025-11-11T14:16:49.941890Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] The application data is transferred to the client. Number of messages 1, size 91 bytes
2025-11-11T14:16:49.945472Z :DEBUG: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:16:49.945609Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:49.945643Z :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-11-11T14:16:49.945653Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17774 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:49.945885Z :NOTICE: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] 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:49.946747Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:49.946757Z :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-11-11T14:16:49.946778Z :INFO: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17775 BytesRead: 91 MessagesRead: 1 BytesReadCompressed: 91 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:49.946789Z :NOTICE: [local] [local] [c0bb01ff-df33e9d7-7f487e60-7c532787] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:48.522233Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Starting read session
2025-11-11T14:17:48.528302Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Starting session to cluster null (localhost:18359)
2025-11-11T14:17:48.528687Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.528697Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.528702Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:48.534463Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Successfully connected. Initializing session
2025-11-11T14:17:48.535538Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Server session id: pq_kikimr_streaming_v1_consumer_1_12_8764941547392579533_v1
2025-11-11T14:17:48.535608Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.539474Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:48.539624Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "pq_kikimr_streaming_v1_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:48.541100Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.541208Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (20-29)
2025-11-11T14:17:48.541249Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (20-20)
2025-11-11T14:17:48.541259Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (21-21)
2025-11-11T14:17:48.541266Z :DEBUG: [local] Take Data. Partition 1. Read: {2, 0} (22-22)
2025-11-11T14:17:48.541271Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 0} (23-23)
2025-11-11T14:17:48.541279Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 1} (24-24)
2025-11-11T14:17:48.541284Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 2} (25-25)
2025-11-11T14:17:48.541290Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 3} (26-26)
2025-11-11T14:17:48.541295Z :DEBUG: [local] Take Data. Partition 1. Read: {3, 4} (27-27)
2025-11-11T14:17:48.541308Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 0} (28-28)
2025-11-11T14:17:48.541314Z :DEBUG: [local] Take Data. Partition 1. Read: {4, 1} (29-29)
2025-11-11T14:17:48.541452Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Commit offsets [20, 30). Partition stream id: 1
2025-11-11T14:17:48.541550Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] The application data is transferred to the client. Number of messages 10, size 20 bytes
2025-11-11T14:17:48.544228Z :DEBUG: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 10 messages
2025-11-11T14:17:48.544375Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:48.544420Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:0:2:0:0 null:pq_kikimr_streaming_v1_output:1:1:29:30
2025-11-11T14:17:48.544430Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:48.544648Z :NOTICE: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] 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:48.544836Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:48.544846Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:pq_kikimr_streaming_v1_output:0:2:0:0 null:pq_kikimr_streaming_v1_output:1:1:29:30
2025-11-11T14:17:48.544853Z :INFO: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 22 BytesRead: 20 MessagesRead: 10 BytesReadCompressed: 20 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:48.544861Z :NOTICE: [local] [local] [1f69f271-1a2f8f9e-dbaafe2e-483c53e2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:41.565094Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Starting read session
2025-11-11T14:16:41.565146Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Starting session to cluster null (localhost:1315)
2025-11-11T14:16:41.565619Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.565636Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.565641Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:41.570939Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Successfully connected. Initializing session
2025-11-11T14:16:41.571889Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Server session id: test_3_session_consumer_1_9_5075027445259806865_v1
2025-11-11T14:16:41.571937Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.573497Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_3_session3". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:41.574269Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:41.574322Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:41.574358Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:41.574367Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:41.574454Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:41.574531Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-11-11T14:16:41.576890Z :DEBUG: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:41.577001Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:41.577041Z :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-11-11T14:16:41.577059Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:41.577240Z :NOTICE: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-11T14:16:41.577344Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:41.577353Z :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-11-11T14:16:41.577361Z :INFO: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:41.577368Z :NOTICE: [local] [local] [772635a9-5a621221-bfee345e-9d90961f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:48.235896Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Starting read session
2025-11-11T14:17:48.235942Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Starting session to cluster null (localhost:19692)
2025-11-11T14:17:48.236393Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.236407Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.236413Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:48.358000Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Successfully connected. Initializing session
2025-11-11T14:17:48.362525Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Server session id: test_filters_non_optional_field_consumer_1_7_10861178084899533712_v1
2025-11-11T14:17:48.362654Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:48.363979Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_filters_non_optional_field_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:49.241559Z :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:2
2025-11-11T14:17:49.241598Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1005 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:52.811768Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:52.811854Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (2-2)
2025-11-11T14:17:52.811898Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-11-11T14:17:52.812010Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Commit offsets [2, 3). Partition stream id: 1
2025-11-11T14:17:52.812130Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:52.816340Z :DEBUG: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:52.816499Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:52.816533Z :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:2:3
2025-11-11T14:17:52.816544Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4580 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:52.817476Z :NOTICE: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] 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:52.821519Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:52.821536Z :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:2:3
2025-11-11T14:17:52.821559Z :INFO: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 4585 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:52.821574Z :NOTICE: [local] [local] [4f3a5254-1b74bddc-7a346b16-b3e14d3f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:17.164976Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Starting read session
2025-11-11T14:17:17.165011Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Starting session to cluster null (localhost:11255)
2025-11-11T14:17:17.165431Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.165444Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.165448Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:17.170584Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] Successfully connected. Initializing session
2025-11-11T14:17:17.171558Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] Server session id: test_filters_optional_field_consumer_1_7_4676973411917453032_v1
2025-11-11T14:17:17.171610Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:17.172775Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [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:18.165620Z :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:3
2025-11-11T14:17:18.165649Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:20.602112Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:20.602180Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (3-3)
2025-11-11T14:17:20.602217Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-11-11T14:17:20.602338Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] Commit offsets [3, 4). Partition stream id: 1
2025-11-11T14:17:20.602435Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] The application data is transferred to the client. Number of messages 1, size 3 bytes
2025-11-11T14:17:20.605056Z :DEBUG: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 1 messages
2025-11-11T14:17:20.605197Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:20.605223Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:3:4
2025-11-11T14:17:20.605233Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3440 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:20.605500Z :NOTICE: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] 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:20.605604Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:20.605613Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_filters_optional_field_output:0:1:3:4
2025-11-11T14:17:20.605631Z :INFO: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Counters: { Errors: 0 CurrentSessionLifetimeMs: 3440 BytesRead: 3 MessagesRead: 1 BytesReadCompressed: 3 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:20.605651Z :NOTICE: [local] [local] [c65f60a3-543dcb80-aaec6065-bd941161] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:33.519421Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Starting read session
2025-11-11T14:17:33.519472Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Starting session to cluster null (localhost:22745)
2025-11-11T14:17:33.519984Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.520000Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.520006Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:17:33.525678Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Successfully connected. Initializing session
2025-11-11T14:17:33.527245Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Server session id: test_restart_compute_node_consumer_1_10_13347409557716996297_v1
2025-11-11T14:17:33.527310Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.528962Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:17:33.529158Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Confirm partition stream create. Partition stream id: 2. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 2. Read offset: (NULL)
2025-11-11T14:17:33.529309Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Confirm partition stream create. Partition stream id: 3. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 3. Read offset: (NULL)
2025-11-11T14:17:33.529358Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Confirm partition stream create. Partition stream id: 4. Cluster: "". Topic: "test_restart_compute_node_output". Partition: 1. Read offset: (NULL)
2025-11-11T14:17:33.530062Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.530123Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (4-7)
2025-11-11T14:17:33.530165Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-11-11T14:17:33.530174Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (5-5)
2025-11-11T14:17:33.530183Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (6-6)
2025-11-11T14:17:33.530188Z :DEBUG: [local] Take Data. Partition 0. Read: {3, 0} (7-7)
2025-11-11T14:17:33.530305Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Commit offsets [4, 8). Partition stream id: 1
2025-11-11T14:17:33.530382Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] The application data is transferred to the client. Number of messages 4, size 12 bytes
2025-11-11T14:17:33.530740Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:17:33.530800Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 2 (4-7)
2025-11-11T14:17:33.530840Z :DEBUG: [local] Take Data. Partition 2. Read: {0, 0} (4-4)
2025-11-11T14:17:33.530853Z :DEBUG: [local] Take Data. Partition 2. Read: {1, 0} (5-5)
2025-11-11T14:17:33.530862Z :DEBUG: [local] Take Data. Partition 2. Read: {2, 0} (6-6)
2025-11-11T14:17:33.530868Z :DEBUG: [local] Take Data. Partition 2. Read: {3, 0} (7-7)
2025-11-11T14:17:33.530928Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Commit offsets [4, 8). Partition stream id: 2
2025-11-11T14:17:33.530988Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] The application data is transferred to the client. Number of messages 4, size 12 bytes
2025-11-11T14:17:33.533219Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Committed response: cookies { assign_id: 4 partition_cookie: 1 }
2025-11-11T14:17:33.533301Z :DEBUG: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] [null] Committed response: cookies { assign_id: 2 partition_cookie: 1 }
Closing session. Got 8 messages
2025-11-11T14:17:33.533464Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Closing read session. Close timeout: 5.000000s
2025-11-11T14:17:33.533508Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:0:0 null:test_restart_compute_node_output:3:3:0:0 null:test_restart_compute_node_output:2:2:7:8 null:test_restart_compute_node_output:0:1:7:8
2025-11-11T14:17:33.533520Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Counters: { Errors: 0 CurrentSessionLifetimeMs: 14 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:17:33.533898Z :NOTICE: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] 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:33.537220Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:33.537236Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:test_restart_compute_node_output:1:4:0:0 null:test_restart_compute_node_output:3:3:0:0 null:test_restart_compute_node_output:2:2:7:8 null:test_restart_compute_node_output:0:1:7:8
2025-11-11T14:17:33.537247Z :INFO: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Counters: { Errors: 0 CurrentSessionLifetimeMs: 17 BytesRead: 24 MessagesRead: 8 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:33.537261Z :NOTICE: [local] [local] [d0f3eb99-4c570e57-e0fa0c3e-5d8ecb82] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:12.695188Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Starting read session
2025-11-11T14:16:12.695236Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Starting session to cluster null (localhost:11587)
2025-11-11T14:16:12.695586Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.695599Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.695605Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:12.706709Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] Successfully connected. Initializing session
2025-11-11T14:16:12.708767Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] Server session id: test_start_new_query_consumer_1_5_14176918992901784232_v1
2025-11-11T14:16:12.708838Z :DEBUG: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:12.717990Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] [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-11-11T14:16:13.694854Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:13.694934Z :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-11-11T14:16:13.694963Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Counters: { Errors: 0 CurrentSessionLifetimeMs: 999 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:13.697379Z :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-11-11T14:16:13.697393Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:13.697465Z :NOTICE: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] 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:13.697555Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:13.697562Z :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-11-11T14:16:13.697569Z :INFO: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:13.697578Z :NOTICE: [local] [local] [77480a18-44224de5-8cd35a45-89542e57] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:57.775600Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Starting read session
2025-11-11T14:16:57.775640Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Starting session to cluster null (localhost:25220)
2025-11-11T14:16:57.776018Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:57.776031Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:57.776036Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Reconnecting session to cluster null in 0.000000s
2025-11-11T14:16:57.781379Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Successfully connected. Initializing session
2025-11-11T14:16:57.782466Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Server session id: test_watermarks_no_shared_consumer_1_7_474722663735113915_v1
2025-11-11T14:16:57.782540Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:57.783919Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "test_watermarks_no_shared_output". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:57.784654Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-11T14:16:57.784709Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-1)
2025-11-11T14:16:57.784750Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:57.784759Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:57.784856Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Commit offsets [0, 2). Partition stream id: 1
2025-11-11T14:16:57.784943Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] The application data is transferred to the client. Number of messages 2, size 70 bytes
2025-11-11T14:16:57.787194Z :DEBUG: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 2 messages
2025-11-11T14:16:57.787305Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Closing read session. Close timeout: 5.000000s
2025-11-11T14:16:57.787355Z :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-11-11T14:16:57.787364Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-11T14:16:57.787568Z :NOTICE: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] 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:57.787681Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:57.787691Z :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-11-11T14:16:57.787703Z :INFO: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Counters: { Errors: 0 CurrentSessionLifetimeMs: 12 BytesRead: 70 MessagesRead: 2 BytesReadCompressed: 70 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:57.787712Z :NOTICE: [local] [local] [7a7426d6-c1327ae1-d26fbdbb-a07e78a7] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
