2025-11-05T14:13:22.053705Z :GetAllStartPartitionSessions INFO: Random seed for debugging is 1762352002053638
2025-11-05T14:13:22.366899Z node 1 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[1:7569244214448469304:2139];send_to=[0:7307199536658146131:7762515];
2025-11-05T14:13:22.369086Z node 1 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-11-05T14:13:22.413034Z node 2 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[2:7569244216243761351:2076];send_to=[0:7307199536658146131:7762515];
2025-11-05T14:13:22.414681Z node 2 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-11-05T14:13:22.609539Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: : Created
2025-11-05T14:13:22.616095Z node 2 :PQ_READ_PROXY DEBUG: Direct read cache: : Created
test_client.cpp: SetPath # /home/runner/.ya/build/build_root/j3ko/003c2f/r3tmp/tmps5TCaU/pdisk_1.dat
2025-11-05T14:13:22.848894Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(2, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-11-05T14:13:22.848951Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(2, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-11-05T14:13:22.884050Z node 1 :HIVE WARN: HIVE#72057594037968897 Handle TEvInterconnect::TEvNodeConnected, NodeId 2 Cookie 2
2025-11-05T14:13:22.896183Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(2, (0,0,0,0)) VolatileState: Connecting -> Connected
2025-11-05T14:13:22.898600Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(1, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-11-05T14:13:22.898665Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(1, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-11-05T14:13:22.901152Z node 1 :IMPORT WARN: Table profiles were not loaded
2025-11-05T14:13:22.926076Z node 1 :HIVE WARN: HIVE#72057594037968897 Node(1, (0,0,0,0)) VolatileState: Connecting -> Connected
TServer::EnableGrpc on GrpcPort 24643, node 1
2025-11-05T14:13:22.966780Z node 1 :GRPC_SERVER WARN: SchemeBoardDelete /Root Strong=0
2025-11-05T14:13:22.968910Z node 1 :GRPC_SERVER WARN: SchemeBoardDelete /Root Strong=0
2025-11-05T14:13:22.999261Z node 1 :NET_CLASSIFIER WARN: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/j3ko/003c2f/r3tmp/yandex98PaEp.tmp
2025-11-05T14:13:22.999297Z node 1 :NET_CLASSIFIER WARN: will try to initialize from file: /home/runner/.ya/build/build_root/j3ko/003c2f/r3tmp/yandex98PaEp.tmp
2025-11-05T14:13:22.999474Z node 1 :NET_CLASSIFIER WARN: successfully initialized from file: /home/runner/.ya/build/build_root/j3ko/003c2f/r3tmp/yandex98PaEp.tmp
2025-11-05T14:13:22.999635Z node 1 :NET_CLASSIFIER ERROR: got bad distributable configuration
2025-11-05T14:13:23.053801Z INFO: TTestServer started on Port 22792 GrpcPort 24643
TClient is connected to server localhost:22792
PQClient connected to localhost:24643
WaitRootIsUp 'Root'...
TClient::Ls request: Root
TClient::Ls response: 2025-11-05T14:13:23.389313Z node 1 :TX_CONVEYOR ERROR: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "Root"
    PathId: 1
    SchemeshardId: 72057594046644480
    PathType: EPathTypeDir
    CreateFinished: true
    CreateTxId: 1
    CreateStep: 0
    ParentPathId: 1
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 1
      SubDomainVersion: 0
      SecurityStateVersion: 0
    }
    ChildrenExist: false
  }
  Children {
    Name: ".sys"
    PathId: 18446744073709551615
    SchemeshardId: 72057594046644480
    PathType: EPathTypeDir
    CreateFinished: true
    CreateTxId: 0
    CreateStep: 0
    ParentPathId: 18446744073709551615
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 0
      Pl...
(TRUNCATED)
WaitRootIsUp 'Root' success.
2025-11-05T14:13:23.408970Z node 1 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976710657:0, at schemeshard:  72057594046644480
waiting...
2025-11-05T14:13:23.428881Z node 2 :TX_CONVEYOR ERROR: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
waiting...
waiting...
waiting...
2025-11-05T14:13:26.137656Z node 2 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [2:7569244229128663503:2289], status: SCHEME_ERROR, issues: <main>: Error: Type annotation, code: 1030
    <main>:3:16: Error: At function: KiReadTable!
        <main>:3:16: Error: Cannot find table 'db.[/Root/PQ/Config/V2/Cluster]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions., code: 2003
2025-11-05T14:13:26.137613Z node 1 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [1:7569244227333372099:2318], status: SCHEME_ERROR, issues: <main>: Error: Type annotation, code: 1030
    <main>:3:16: Error: At function: KiReadTable!
        <main>:3:16: Error: Cannot find table 'db.[/Root/PQ/Config/V2/Cluster]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions., code: 2003
2025-11-05T14:13:26.138396Z node 2 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=2&id=NDhlZWMyNGItYWM3YjIzMjEtNzA2MzRiMzMtODVjZDgzMmM=, ActorId: [2:7569244229128663501:2288], ActorState: ExecuteState, TraceId: 01k9a5v0t96ddepejxtsq5dxcp, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-11-05T14:13:26.138652Z node 1 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=1&id=ZjlkYWVhNGEtNzkxYTFlZGUtNTVkODUyYTItMTJkYThiN2U=, ActorId: [1:7569244227333372096:2316], ActorState: ExecuteState, TraceId: 01k9a5v0q93ne1tmg6e1n5rnxh, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-11-05T14:13:26.140378Z node 2 :PERSQUEUE_CLUSTER_TRACKER ERROR: failed to list clusters: { Response { QueryIssues { message: "Type annotation" issue_code: 1030 severity: 1 issues { position { row: 3 column: 16 } message: "At function: KiReadTable!" end_position { row: 3 column: 16 } severity: 1 issues { position { row: 3 column: 16 } message: "Cannot find table \'db.[/Root/PQ/Config/V2/Cluster]\' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions." end_position { row: 3 column: 16 } issue_code: 2003 severity: 1 } } } TxMeta { } } YdbStatus: SCHEME_ERROR ConsumedRu: 1 }
2025-11-05T14:13:26.141167Z node 1 :PERSQUEUE_CLUSTER_TRACKER ERROR: failed to list clusters: { Response { QueryIssues { message: "Type annotation" issue_code: 1030 severity: 1 issues { position { row: 3 column: 16 } message: "At function: KiReadTable!" end_position { row: 3 column: 16 } severity: 1 issues { position { row: 3 column: 16 } message: "Cannot find table \'db.[/Root/PQ/Config/V2/Cluster]\' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions." end_position { row: 3 column: 16 } issue_code: 2003 severity: 1 } } } TxMeta { } } YdbStatus: SCHEME_ERROR ConsumedRu: 1 }
2025-11-05T14:13:26.143179Z node 1 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710661:0, at schemeshard:  72057594046644480
2025-11-05T14:13:26.291779Z node 1 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710662:0, at schemeshard:  72057594046644480
2025-11-05T14:13:26.510985Z node 1 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710663:0, at schemeshard:  72057594046644480
=== Init DC: UPSERT INTO `/Root/PQ/Config/V2/Cluster` (name, balancer, local, enabled, weight) VALUES ("dc1", "localhost:24643", true, true, 1000), ("dc2", "dc2.logbroker.yandex.net", false, false, 1000);
2025-11-05T14:13:26.868960Z node 1 :KQP_EXECUTER ERROR: TxId: 281474976710664. Ctx: { TraceId: 01k9a5v1evbrqjj20bj6z9rymw, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=1&id=OGYzZWM0OTItYTc1YmFkZDgtNzgyYzQ5NS00ZDYzN2EwYg==, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
=== CheckClustersList. Subcribe to ClusterTracker from [1:7569244231628339847:2949] 
2025-11-05T14:13:27.364187Z node 1 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[1:7569244214448469304:2139];send_to=[0:7307199536658146131:7762515];
2025-11-05T14:13:27.364262Z node 1 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-11-05T14:13:27.409721Z node 2 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[2:7569244216243761351:2076];send_to=[0:7307199536658146131:7762515];
2025-11-05T14:13:27.409771Z node 2 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
=== CheckClustersList. Ok
2025-11-05T14:13:32.747816Z node 1 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976710676:0, at schemeshard:  72057594046644480
waiting...
PQ Client: create topic: rt3.dc1--test-topic with 5 partitions
CallPersQueueGRPC request to localhost:24643
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--test-topic"
  }
}
2025-11-05T14:13:32.870238Z node 1 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--test-topic, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
CallPersQueueGRPC request to localhost:24643
MetaRequest {
  CmdCreateTopic {
    Topic: "rt3.dc1--test-topic"
    NumPartitions: 5
    Config {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
    }
  }
}
CallPersQueueGRPC response:
Status: 129
ProxyErrorCode: 53
SchemeStatus: 1
FlatTxId {
  TxId: 281474976710679
  SchemeShardTabletId: 72057594046644480
  PathId: 9
}
ErrorCode: OK
AddTopic: rt3.dc1--test-topic
===Run query:``DECLARE $version as Int64; DECLARE $path AS Utf8; DECLARE $cluster as Utf8; UPSERT INTO `/Root/PQ/Config/V2/Topics` (path, dc) VALUES ($path, $cluster); UPSERT INTO `/Root/PQ/Config/V2/Versions` (name, version) VALUES ("Topics", $version);`` with topic = test-topic, dc = dc1
2025-11-05T14:13:32.945492Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][] pipe [1:7569244257398144318:3381] connected; active server actors: 1
2025-11-05T14:13:32.947228Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] updating configuration. Deleted partitions []. Added partitions [1, 2, 3, 4, 0]
2025-11-05T14:13:32.953003Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-05T14:13:32.956051Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvInterconnect::TEvNodeInfo
2025-11-05T14:13:32.958319Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-11-05T14:13:32.956697Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] BALANCER INIT DONE for rt3.dc1--test-topic: (0, 72075186224037892) (1, 72075186224037892) (2, 72075186224037892) (3, 72075186224037892) (4, 72075186224037892) 
2025-11-05T14:13:32.959286Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] TEvClientConnected TabletId 72057594046644480, NodeId 1, Generation 2
2025-11-05T14:13:32.961957Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-05T14:13:32.962220Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] doesn't have tx info
2025-11-05T14:13:32.962239Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] PlanStep 0, PlanTxId 0, ExecStep 0, ExecTxId 0
2025-11-05T14:13:32.962262Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] no config, start with empty partitions and default config
2025-11-05T14:13:32.962307Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Txs.size=0, PlannedTxs.size=0
2025-11-05T14:13:32.962342Z node 1 :PERSQUEUE NOTICE: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T14:13:32.962384Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892] doesn't have tx writes info
2025-11-05T14:13:32.963233Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [2:7569244259193435066:2382], now have 1 active actors on pipe
2025-11-05T14:13:32.964455Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] TEvClientConnected TabletId 72075186224037892, NodeId 1, Generation 1
2025-11-05T14:13:32.981025Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244257398144317:3380], now have 1 active actors on pipe
2025-11-05T14:13:32.982410Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7569244214448469712 RawX2: 4294969571 } TxId: 281474976710679 Config { TabletConfig { PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true ReadRules: "user" ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } } }
2025-11-05T14:13:32.982618Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Propose TxId 281474976710679, WriteId (empty maybe)
2025-11-05T14:13:32.982667Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state UNKNOWN
2025-11-05T14:13:32.982704Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State UNKNOWN
2025-11-05T14:13:32.982746Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] schedule TEvProposeTransactionResult(PREPARED)
2025-11-05T14:13:32.982771Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from UNKNOWN to PREPARING
2025-11-05T14:13:32.982828Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976710679
2025-11-05T14:13:32.983211Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] save tx TxId: 281474976710679 State: PREPARED MinStep: 1762352013000 MaxStep: 18446744073709551615 Kind: KIND_CONFIG TabletConfig { PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7569244214448469712 RawX2: 4294969571 } Partitions { }
2025-11-05T14:13:32.983339Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T14:13:32.988611Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T14:13:32.988666Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARING
2025-11-05T14:13:32.988707Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State PREPARING
2025-11-05T14:13:32.988734Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from PREPARING to PREPARED
2025-11-05T14:13:32.993240Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransactionAttach TabletId: 72075186224037892 TxId: 281474976710679
2025-11-05T14:13:32.996549Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244257398144411:3447], now have 1 active actors on pipe
2025-11-05T14:13:33.005134Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvTxProcessing::TEvPlanStep Transactions { TxId: 281474976710679 AckTo { RawX1: 0 RawX2: 0 } } Step: 1762352013037 MediatorID: 72057594046382081 TabletID: 72075186224037892
2025-11-05T14:13:33.005200Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARED
2025-11-05T14:13:33.005635Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State PREPARED
2025-11-05T14:13:33.005671Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from PREPARED to PLANNING
2025-11-05T14:13:33.005698Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] PlanStep 1762352013037, PlanTxId 281474976710679
2025-11-05T14:13:33.005732Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976710679
2025-11-05T14:13:33.006193Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] save tx TxId: 281474976710679 State: PLANNED MinStep: 1762352013000 MaxStep: 18446744073709551615 Step: 1762352013037 Kind: KIND_CONFIG TabletConfig { PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7569244214448469712 RawX2: 4294969571 } Partitions { }
2025-11-05T14:13:33.006329Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T14:13:33.025976Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T14:13:33.026022Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PLANNING
2025-11-05T14:13:33.026036Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State PLANNING
2025-11-05T14:13:33.026079Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from PLANNING to PLANNED
2025-11-05T14:13:33.026118Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxQueue.size 1
2025-11-05T14:13:33.026158Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] New ExecStep 1762352013037, ExecTxId 281474976710679
2025-11-05T14:13:33.043671Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from PLANNED to CALCULATING
2025-11-05T14:13:33.043787Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:2:Initializer] Start initializing step TInitConfigStep
2025-11-05T14:13:33.043857Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T14:13:33.043883Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:3:Initializer] Start initializing step TInitConfigStep
2025-11-05T14:13:33.043902Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T14:13:33.043914Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:4:Initializer] Start initializing step TInitConfigStep
2025-11-05T14:13:33.043933Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T14:13:33.043944Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:0:Initializer] Start initializing step TInitConfigStep
2025-11-05T14:13:33.043968Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T14:13:33.052104Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:1:Initializer] Start initializing step TInitConfigStep
2025-11-05T14:13:33.052164Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T14:13:33.052926Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:2:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T14:13:33.053327Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 2, State: StateInit] bootstrapping 2 [1:7569244261693111721:2467]
2025-11-05T14:13:33.080929Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:2:Initializer] Initializing completed.
2025-11-05T14:13:33.080979Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 2, State: StateInit] init complete for topic 'rt3.dc1--test-topic' partition 2 generation 1 [1:7569244261693111721:2467]
2025-11-05T14:13:33.081032Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateInit] SYNC INIT topic rt3.dc1--test-topic partitition 2 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T14:13:33.085799Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Process pending events. Count 1
2025-11-05T14:13:33.085864Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.086003Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.086037Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.086064Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.086094Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.086122Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.086168Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 2 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T14:13:33.086409Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:3:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T14:13:33.087724Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 3, State: StateInit] bootstrapping 3 [1:7569244261693111722:2468]
2025-11-05T14:13:33.089961Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:3:Initializer] Initializing completed.
2025-11-05T14:13:33.089997Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 3, State: StateInit] init complete for topic 'rt3.dc1--test-topic' partition 3 generation 1 [1:7569244261693111722:2468]
2025-11-05T14:13:33.090024Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateInit] SYNC INIT topic rt3.dc1--test-topic partitition 3 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T14:13:33.091162Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Process pending events. Count 1
2025-11-05T14:13:33.091195Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.091280Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.091335Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.091352Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.091366Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.091380Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.091412Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 3 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T14:13:33.091665Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:4:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T14:13:33.091864Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 4, State: StateInit] bootstrapping 4 [1:7569244261693111723:2469]
2025-11-05T14:13:33.094242Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:4:Initializer] Initializing completed.
2025-11-05T14:13:33.094276Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 4, State: StateInit] init complete for topic 'rt3.dc1--test-topic' partition 4 generation 1 [1:7569244261693111723:2469]
2025-11-05T14:13:33.094302Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateInit] SYNC INIT topic rt3.dc1--test-topic partitition 4 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T14:13:33.095359Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Process pending events. Count 1
2025-11-05T14:13:33.095393Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.095477Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.095526Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.095543Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.095557Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.095577Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.095612Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 4 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T14:13:33.095875Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T14:13:33.096087Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 0, State: StateInit] bootstrapping 0 [1:7569244261693111724:2470]
2025-11-05T14:13:33.098559Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:0:Initializer] Initializing completed.
2025-11-05T14:13:33.098595Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 0, State: StateInit] init complete for topic 'rt3.dc1--test-topic' partition 0 generation 1 [1:7569244261693111724:2470]
2025-11-05T14:13:33.098621Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateInit] SYNC INIT topic rt3.dc1--test-topic partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T14:13:33.099681Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Process pending events. Count 1
2025-11-05T14:13:33.099711Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.099781Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.099801Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.099823Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.099839Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.099853Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.099907Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T14:13:33.100168Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:1:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T14:13:33.100398Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 1, State: StateInit] bootstrapping 1 [1:7569244261693111717:2466]
2025-11-05T14:13:33.102854Z node 1 :PERSQUEUE DEBUG: [rt3.dc1--test-topic:1:Initializer] Initializing completed.
2025-11-05T14:13:33.102885Z node 1 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 1, State: StateInit] init complete for topic 'rt3.dc1--test-topic' partition 1 generation 1 [1:7569244261693111717:2466]
2025-11-05T14:13:33.102910Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateInit] SYNC INIT topic rt3.dc1--test-topic partitition 1 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T14:13:33.103990Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Process pending events. Count 1
2025-11-05T14:13:33.104021Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.104105Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.104128Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.104149Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.104164Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.104202Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Still pending for come commits
2025-11-05T14:13:33.104602Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 1 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T14:13:33.104950Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762352013037, TxId 281474976710679, Partition 2
2025-11-05T14:13:33.104972Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Handle TEvProposePartitionConfigResult
2025-11-05T14:13:33.104994Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Partition responses 1/5
2025-11-05T14:13:33.105020Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T14:13:33.105043Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATING
2025-11-05T14:13:33.105061Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATING FrontTxId 281474976710679
2025-11-05T14:13:33.105079Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 1, Expected 5
2025-11-05T14:13:33.105095Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.105201Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762352013037, TxId 281474976710679, Partition 3
2025-11-05T14:13:33.105211Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Handle TEvProposePartitionConfigResult
2025-11-05T14:13:33.105224Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Partition responses 2/5
2025-11-05T14:13:33.105234Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T14:13:33.105245Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATING
2025-11-05T14:13:33.105266Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATING FrontTxId 281474976710679
2025-11-05T14:13:33.105279Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 2, Expected 5
2025-11-05T14:13:33.105292Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.105507Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762352013037, TxId 281474976710679, Partition 4
2025-11-05T14:13:33.105517Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Handle TEvProposePartitionConfigResult
2025-11-05T14:13:33.105533Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Partition responses 3/5
2025-11-05T14:13:33.105543Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T14:13:33.105552Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATING
2025-11-05T14:13:33.105561Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATING FrontTxId 281474976710679
2025-11-05T14:13:33.105570Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 3, Expected 5
2025-11-05T14:13:33.105578Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.105771Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762352013037, TxId 281474976710679, Partition 0
2025-11-05T14:13:33.105779Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Handle TEvProposePartitionConfigResult
2025-11-05T14:13:33.105788Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Partition responses 4/5
2025-11-05T14:13:33.105796Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T14:13:33.105805Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATING
2025-11-05T14:13:33.105814Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATING FrontTxId 281474976710679
2025-11-05T14:13:33.105822Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 4, Expected 5
2025-11-05T14:13:33.105831Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.106005Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762352013037, TxId 281474976710679, Partition 1
2025-11-05T14:13:33.106014Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Handle TEvProposePartitionConfigResult
2025-11-05T14:13:33.106022Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] Partition responses 5/5
2025-11-05T14:13:33.106030Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T14:13:33.106038Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATING
2025-11-05T14:13:33.106047Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATING FrontTxId 281474976710679
2025-11-05T14:13:33.106055Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 5, Expected 5
2025-11-05T14:13:33.106077Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from CALCULATING to CALCULATED
2025-11-05T14:13:33.106131Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976710679
2025-11-05T14:13:33.106666Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] save tx TxId: 281474976710679 State: CALCULATED MinStep: 1762352013000 MaxStep: 18446744073709551615 Step: 1762352013037 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7569244214448469712 RawX2: 4294969571 } Partitions { Partition { PartitionId: 2 } Partition { PartitionId: 3 } Partition { PartitionId: 4 } Partition { PartitionId: 0 } Partition { PartitionId: 1 } }
2025-11-05T14:13:33.106794Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T14:13:33.114158Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T14:13:33.114190Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATED
2025-11-05T14:13:33.114202Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State CALCULATED
2025-11-05T14:13:33.114232Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State CALCULATED FrontTxId 281474976710679
2025-11-05T14:13:33.114251Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from CALCULATED to WAIT_RS
2025-11-05T14:13:33.114321Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Send TEvTxProcessing::TEvReadSet to 0 receivers. Wait TEvTxProcessing::TEvReadSet from 0 senders.
2025-11-05T14:13:33.114364Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] HaveParticipantsDecision 1
2025-11-05T14:13:33.114458Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from WAIT_RS to EXECUTING
2025-11-05T14:13:33.114475Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 0, Expected 5
2025-11-05T14:13:33.114580Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762352013037, TxId 281474976710679
2025-11-05T14:13:33.114611Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.114633Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.114835Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115091Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762352013037, TxId 281474976710679
2025-11-05T14:13:33.115108Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115120Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115213Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115307Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762352013037, TxId 281474976710679
2025-11-05T14:13:33.115321Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115331Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115403Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115505Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762352013037, TxId 281474976710679
2025-11-05T14:13:33.115520Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115538Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115668Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115769Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762352013037, TxId 281474976710679
2025-11-05T14:13:33.115791Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115803Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115891Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.115988Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:33.116047Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:33.116066Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:33.116078Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:33.116115Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:33.122571Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:33.122604Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.122620Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.122784Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:33.122809Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.122820Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.122972Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:33.122981Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.122987Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.123108Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:33.123122Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.123146Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.123241Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:33.123254Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.123260Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.123329Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762352013037, TxId 281474976710679, Partition 0
2025-11-05T14:13:33.123345Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T14:13:33.123376Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTING
2025-11-05T14:13:33.123391Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTING FrontTxId 281474976710679
2025-11-05T14:13:33.123402Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 1, Expected 5
2025-11-05T14:13:33.123421Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.123450Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762352013037, TxId 281474976710679, Partition 1
2025-11-05T14:13:33.123456Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T14:13:33.123461Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTING
2025-11-05T14:13:33.123466Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTING FrontTxId 281474976710679
2025-11-05T14:13:33.123488Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 2, Expected 5
2025-11-05T14:13:33.123501Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.123519Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762352013037, TxId 281474976710679, Partition 2
2025-11-05T14:13:33.123524Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T14:13:33.123544Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTING
2025-11-05T14:13:33.123553Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTING FrontTxId 281474976710679
2025-11-05T14:13:33.123558Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 3, Expected 5
2025-11-05T14:13:33.123562Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.123575Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762352013037, TxId 281474976710679, Partition 3
2025-11-05T14:13:33.123579Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T14:13:33.123583Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTING
2025-11-05T14:13:33.123587Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTING FrontTxId 281474976710679
2025-11-05T14:13:33.123594Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 4, Expected 5
2025-11-05T14:13:33.123598Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 status has not changed
2025-11-05T14:13:33.123608Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762352013037, TxId 281474976710679, Partition 4
2025-11-05T14:13:33.123612Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T14:13:33.123616Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTING
2025-11-05T14:13:33.123620Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTING FrontTxId 281474976710679
2025-11-05T14:13:33.123626Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 5, Expected 5
2025-11-05T14:13:33.123647Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId: 281474976710679 send TEvPersQueue::TEvProposeTransactionResult(COMPLETE)
2025-11-05T14:13:33.123661Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] complete TxId 281474976710679
2025-11-05T14:13:33.123954Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Apply new config PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } Version: 0 Generation: 0 Important: false }
2025-11-05T14:13:33.124053Z node 1 :PERSQUEUE NOTICE: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T14:13:33.124097Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] delete partitions for TxId 281474976710679
2025-11-05T14:13:33.124109Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from EXECUTING to EXECUTED
2025-11-05T14:13:33.124132Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976710679
2025-11-05T14:13:33.124411Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] save tx TxId: 281474976710679 State: EXECUTED MinStep: 1762352013000 MaxStep: 18446744073709551615 Step: 1762352013037 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { LifetimeSeconds: 86400 LowWatermark: 8388608 SourceIdLifetimeSeconds: 86400 WriteSpeedInBytesPerSecond: 20000000 BurstSize: 20000000 TotalPartitions: 5 SourceIdMaxCounts: 6000000 } PartitionIds: 1 PartitionIds: 2 PartitionIds: 3 PartitionIds: 4 PartitionIds: 0 TopicName: "rt3.dc1--test-topic" Version: 0 LocalDC: true Codecs { Ids: 0 Ids: 1 Ids: 2 Codecs: "raw" Codecs: "gzip" Codecs: "lzop" } TopicPath: "/Root/PQ/rt3.dc1--test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 AllPartitions { PartitionId: 1 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 2 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 3 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 4 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7569244214448469712 RawX2: 4294969571 } Partitions { Partition { PartitionId: 2 } Partition { PartitionId: 3 } Partition { PartitionId: 4 } Partition { PartitionId: 0 } Partition { PartitionId: 1 } }
2025-11-05T14:13:33.124580Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T14:13:33.130872Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T14:13:33.130893Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTED
2025-11-05T14:13:33.130905Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State EXECUTED
2025-11-05T14:13:33.130919Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679 State EXECUTED FrontTxId 281474976710679
2025-11-05T14:13:33.130935Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TPersQueue::SendEvReadSetAckToSenders
2025-11-05T14:13:33.130956Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from EXECUTED to WAIT_RS_ACKS
2025-11-05T14:13:33.130995Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] PredicateAcks: 0/0
2025-11-05T14:13:33.131013Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] HaveAllRecipientsReceive 1, AllSupportivePartitionsHaveBeenDeleted 1
2025-11-05T14:13:33.131034Z node 1 :PQ_TX DEBUG: [TxId: 281474976710679] PredicateAcks: 0/0
2025-11-05T14:13:33.131063Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] add an TxId 281474976710679 to the list for deletion
2025-11-05T14:13:33.131082Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976710679 moved from WAIT_RS_ACKS to DELETING
2025-11-05T14:13:33.131121Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] delete key for TxId 281474976710679
2025-11-05T14:13:33.131180Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T14:13:33.133107Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T14:13:33.133130Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state DELETING
2025-11-05T14:13:33.133138Z node 1 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976710679, State DELETING
2025-11-05T14:13:33.133193Z node 1 :PQ_TX INFO: [PQ: 72075186224037892] delete TxId 281474976710679
2025-11-05T14:13:33.156197Z node 1 :KQP_EXECUTER ERROR: TxId: 281474976710680. Ctx: { TraceId: 01k9a5v7mza558sbbase1h2hk3, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=1&id=MTYzZDZmMC1jNmYyOGJkNy01YTYyNjIxNy0xMmJlNTE1Yw==, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
===Query complete
TClient::Ls request: /Root/PQ/rt3.dc1--test-topic
2025-11-05T14:13:33.188792Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.188835Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
TClient::Ls response: Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--test-topic"
    PathId: 9
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710679
    CreateStep: 1762352013037
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    ChildrenExist: false
    BalancerTabletID: 72075186224037893
  }
  PersQueueGroup {
    Name: "rt3.dc1--test-topic"
    PathId: 9
    TotalGroupCount: 5
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSi...
(TRUNCATED)
GetTopicVersionFromPath:  record 2025-11-05T14:13:33.191752Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
Status: 1
StatusCode: SUCCESS
SchemeStatus: 0
PathDescription {
  Self {
    Name: "rt3.dc1--test-topic"
    PathId: 9
    SchemeshardId: 72057594046644480
    PathType: EPathTypePersQueueGroup
    CreateFinished: true
    CreateTxId: 281474976710679
    CreateStep: 1762352013037
    ParentPathId: 2
    PathState: EPathStateNoChanges
    Owner: "root@builtin"
    ACL: ""
    EffectiveACL: ""
    PathVersion: 2
    PathSubType: EPathSubTypeEmpty
    Version {
      GeneralVersion: 2
      ACLVersion: 0
      EffectiveACLVersion: 0
      UserAttrsVersion: 1
      ChildrenVersion: 0
      PQVersion: 1
    }
    ChildrenExist: false
    BalancerTabletID: 72075186224037893
  }
  PersQueueGroup {
    Name: "rt3.dc1--test-topic"
    PathId: 9
    TotalGroupCount: 5
    PartitionPerTablet: 5
    PQTabletConfig {
      PartitionConfig {
        LifetimeSeconds: 86400
        LowWatermark: 8388608
        SourceIdLifetimeSeconds: 86400
        WriteSpeedInBytesPerSecond: 20000000
        BurstSize: 20000000
        SourceIdMaxCounts: 6000000
      }
      LocalDC: true
      ReadRules: "user"
      ReadFromTimestampsMs: 0
      ConsumerFormatVersions: 0
      ConsumerCodecs {
      }
      Codecs {
        Ids: 0
        Ids: 1
        Ids: 2
        Codecs: "raw"
        Codecs: "gzip"
        Codecs: "lzop"
      }
      ReadRuleVersions: 0
      YdbDatabasePath: "/Root"
    }
    Partitions {
      PartitionId: 0
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 1
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 2
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 3
      TabletId: 72075186224037892
      Status: Active
    }
    Partitions {
      PartitionId: 4
      TabletId: 72075186224037892
      Status: Active
    }
    AlterVersion: 1
    BalancerTabletID: 72075186224037893
    NextPartitionId: 5
  }
  DomainDescription {
    SchemeShardId_Depricated: 72057594046644480
    PathId_Depricated: 1
    ProcessingParams {
      Version: 1
      PlanResolution: 7
      Coordinators: 72057594046316545
      TimeCastBucketsPerMediator: 2
      Mediators: 72057594046382081
    }
    DomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    PathsInside: 8
    PathsLimit: 10000
    ShardsInside: 6
    ShardsLimit: 200000
    ResourcesDomainKey {
      SchemeShard: 72057594046644480
      PathId: 1
    }
    DiskSpaceUsage {
      Tables {
        TotalSize: 0
        DataSize: 0
        IndexSize: 0
      }
      Topics {
        ReserveSize: 0
        AccountSize: 0
        DataSize: 0
        UsedReserveSize: 0
      }
    }
    PQPartitionsInside: 5
    PQPartitionsLimit: 1000000
  }
}
Path: "/Root/PQ/rt3.dc1--test-topic"
 name rt3.dc1--test-topic version1
CallPersQueueGRPC request to localhost:24643
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--test-topic"
  }
}
2025-11-05T14:13:33.191780Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.195834Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.195860Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.196851Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.196901Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.198805Z node 1 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--test-topic, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
2025-11-05T14:13:33.203041Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.203082Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.289524Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.289558Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.294195Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.294224Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.296334Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.296421Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.297167Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.297186Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.303308Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.303337Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.390651Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.390687Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.394463Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.394497Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.396868Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.396908Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.397581Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.397604Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.403678Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.403711Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.490744Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.490782Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.494879Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.494947Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.496885Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.496909Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.497888Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.497907Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.504065Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.504096Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.591153Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.591193Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.595483Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.595520Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.597257Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.597301Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.598241Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.598264Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.604426Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.604468Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.691461Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.691497Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.696160Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.696192Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.697599Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.697623Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.698598Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.698623Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
CallPersQueueGRPC request to localhost:24643
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--test-topic"
  }
}
2025-11-05T14:13:33.702219Z node 1 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 128
ErrorReason: "the following topics are not created: rt3.dc1--test-topic, Marker# PQ95"
ErrorCode: UNKNOWN_TOPIC
2025-11-05T14:13:33.704793Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.704824Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.792441Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.792483Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.796416Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.796449Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.797911Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.797934Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.798949Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.798969Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.805109Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.805147Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.892968Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.892997Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.896771Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.896799Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.898288Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.898312Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.899284Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.899305Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.905481Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.905509Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.993451Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.993483Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.997105Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.997129Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.998629Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.998655Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:33.999623Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:33.999643Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.005847Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.005903Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.093421Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.093456Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.097680Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.097712Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.099022Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.099056Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.099998Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.100033Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.106139Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.106167Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.193794Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.193834Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.197823Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.197857Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.202028Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.202064Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.202117Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.202129Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
CallPersQueueGRPC request to localhost:24643
MetaRequest {
  CmdGetTopicMetadata {
    Topic: "rt3.dc1--test-topic"
  }
}
2025-11-05T14:13:34.206526Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.206558Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.207449Z node 1 :PERSQUEUE INFO: proxy answer <none>
CallPersQueueGRPC response:
Status: 1
ErrorCode: OK
MetaResponse {
  CmdGetTopicMetadataResult {
    TopicInfo {
      Topic: "rt3.dc1--test-topic"
      NumPartitions: 5
      Config {
        PartitionConfig {
          LifetimeSeconds: 86400
          LowWatermark: 8388608
          SourceIdLifetimeSeconds: 86400
          WriteSpeedInBytesPerSecond: 20000000
          BurstSize: 20000000
          SourceIdMaxCounts: 6000000
        }
        Version: 1
        LocalDC: true
        Codecs {
          Ids: 0
          Ids: 1
          Ids: 2
          Codecs: "raw"
          Codecs: "gzip"
          Codecs: "lzop"
        }
        TopicPath: "/Root/PQ/rt3.dc1--test-topic"
        YdbDatabasePath: "/Root"
        Consumers {
          Name: "user"
          ReadFromTimestampsMs: 0
          FormatVersion: 0
          Codec {
          }
          Version: 0
          Important: false
        }
      }
      ErrorCode: OK
    }
  }
}
=== Topic created, have version: 1
2025-11-05T14:13:34.233307Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: try to update token
2025-11-05T14:13:34.237949Z :INFO: [] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-11-05T14:13:34.238010Z :INFO: [] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:24643
2025-11-05T14:13:34.250164Z node 1 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-11-05T14:13:34.250204Z node 1 :PQ_WRITE_PROXY DEBUG: new session created cookie 1
2025-11-05T14:13:34.255995Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "test-topic" message_group_id: "src" }
2025-11-05T14:13:34.261014Z node 1 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId:  grpc read done: success: 1 data: init_request { topic: "test-topic" message_group_id: "src" }
2025-11-05T14:13:34.261317Z node 1 :PQ_WRITE_PROXY INFO: session request cookie: 1 topic: "test-topic" message_group_id: "src" from ipv6:[::1]:60504
2025-11-05T14:13:34.261372Z node 1 :PQ_WRITE_PROXY INFO: write session:  cookie=1 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:60504 proto=v1  topic=test-topic durationSec=0
2025-11-05T14:13:34.261384Z node 1 :PQ_WRITE_PROXY INFO: init check schema
2025-11-05T14:13:34.263174Z node 1 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId:  describe result for acl check
2025-11-05T14:13:34.263332Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint32; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `/Root/PQ/SourceIdMeta2` WHERE Hash == $Hash AND Topic == $Topic AND SourceId == $SourceId;
2025-11-05T14:13:34.263348Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;DECLARE $SeqNo AS Uint64;
UPSERT INTO `/Root/PQ/SourceIdMeta2` (Hash, Topic, SourceId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2025-11-05T14:13:34.263358Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint32; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `/Root/PQ/SourceIdMeta2` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND SourceId = $SourceId AND Partition = $Partition;
2025-11-05T14:13:34.263376Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) StartKqpSession
2025-11-05T14:13:34.265436Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) Select from the table
2025-11-05T14:13:34.294089Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.294120Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.303675Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.303708Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.305174Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.305194Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.305247Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.305257Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.307413Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.307428Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.394732Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.394774Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.399225Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) RequestPQRB
2025-11-05T14:13:34.401191Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) Received partition 3 from PQRB for SourceId=src
2025-11-05T14:13:34.401221Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) Update the table
2025-11-05T14:13:34.401742Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.401765Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.400813Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244265988079293:2505] connected; active server actors: 1
2025-11-05T14:13:34.402030Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244265988079293:2505] disconnected; active server actors: 1
2025-11-05T14:13:34.402060Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244265988079293:2505] disconnected no session
2025-11-05T14:13:34.405716Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.405736Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.405770Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.405778Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.407902Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.407925Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.495316Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.495353Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.505010Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.505050Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.508443Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.508469Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.508511Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.508524Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.508547Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.508558Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.531332Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) HandleUpdate PartitionPersisted=0 Status=SUCCESS
2025-11-05T14:13:34.531381Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=3, SeqNo=(NULL)
2025-11-05T14:13:34.531399Z node 1 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [1:7569244265988079252:2505] (SourceId=src, PreferedPartition=(NULL)) Start idle
2025-11-05T14:13:34.531420Z node 1 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 1 sessionId:  partition: 3 expectedGeneration: (NULL)
2025-11-05T14:13:34.532435Z node 1 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=3) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 1, Generation: 1
2025-11-05T14:13:34.532483Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244265988079313:2505], now have 1 active actors on pipe
2025-11-05T14:13:34.532564Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:34.532600Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 3
2025-11-05T14:13:34.532721Z node 1 :PERSQUEUE INFO: new Cookie src|819b1919-6d0611c9-5c4e4e0-d1272793_0 generated for partition 3 topic 'rt3.dc1--test-topic' owner src
2025-11-05T14:13:34.532773Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.532897Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.532929Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.532977Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] TPartition::ReplyOwnerOk. Partition: 3
2025-11-05T14:13:34.533035Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 3 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T14:13:34.533243Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:34.533262Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 3
2025-11-05T14:13:34.533319Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 3 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T14:13:34.533444Z node 1 :PQ_WRITE_PROXY INFO: session inited cookie: 1 partition: 3 MaxSeqNo: 0 sessionId: src|819b1919-6d0611c9-5c4e4e0-d1272793_0
2025-11-05T14:13:34.534542Z :INFO: [] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762352014534 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:34.534691Z :INFO: [] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|819b1919-6d0611c9-5c4e4e0-d1272793_0" topic: "test-topic" cluster: "dc1" partition_id: 3 supported_codecs: CODEC_RAW supported_codecs: CODEC_GZIP supported_codecs: CODEC_LZOP
2025-11-05T14:13:34.534973Z :INFO: [] MessageGroupId [src] SessionId [src|819b1919-6d0611c9-5c4e4e0-d1272793_0] Write session: close. Timeout = 0 ms
2025-11-05T14:13:34.535007Z :INFO: [] MessageGroupId [src] SessionId [src|819b1919-6d0611c9-5c4e4e0-d1272793_0] Write session will now close
2025-11-05T14:13:34.535040Z :DEBUG: [] MessageGroupId [src] SessionId [src|819b1919-6d0611c9-5c4e4e0-d1272793_0] Write session: aborting
2025-11-05T14:13:34.535428Z :INFO: [] MessageGroupId [src] SessionId [src|819b1919-6d0611c9-5c4e4e0-d1272793_0] Write session: gracefully shut down, all writes complete
2025-11-05T14:13:34.535473Z :DEBUG: [] MessageGroupId [src] SessionId [src|819b1919-6d0611c9-5c4e4e0-d1272793_0] Write session: destroy
2025-11-05T14:13:34.535952Z node 1 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId: src|819b1919-6d0611c9-5c4e4e0-d1272793_0 grpc read done: success: 0 data: 
2025-11-05T14:13:34.535985Z node 1 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|819b1919-6d0611c9-5c4e4e0-d1272793_0 grpc read failed
2025-11-05T14:13:34.536516Z node 1 :PQ_WRITE_PROXY INFO: session v1 closed cookie: 1 sessionId: src|819b1919-6d0611c9-5c4e4e0-d1272793_0
2025-11-05T14:13:34.536546Z node 1 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|819b1919-6d0611c9-5c4e4e0-d1272793_0 is DEAD
2025-11-05T14:13:34.537202Z node 1 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=3) Received event: NActors::TEvents::TEvPoison
2025-11-05T14:13:34.537325Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244265988079313:2505] destroyed
2025-11-05T14:13:34.537385Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] TPartition::DropOwner.
2025-11-05T14:13:34.537418Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.537437Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
Session was created
2025-11-05T14:13:34.596192Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.596229Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.607929Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.607957Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.610481Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.610501Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.610519Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.610526Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.610570Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.610582Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.696550Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.696597Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.707844Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.707877Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.710874Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.710918Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.710968Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.710978Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.711001Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.711012Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.796844Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.796880Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.808456Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.808494Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.811958Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.811996Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.812059Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.812070Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.812094Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.812104Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.899981Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.900019Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.910670Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.910719Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.912228Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.912261Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.912315Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.912330Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:34.912357Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:34.912369Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.000872Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.000912Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.010911Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.010968Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.012528Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.012556Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.012623Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.012638Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.012665Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.012695Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.101017Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.101060Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.111232Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.111265Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.112765Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.112817Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.112880Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.112905Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.112932Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.112942Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.201334Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.201382Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.211592Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.211633Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.213087Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.213108Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.213141Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.213151Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.213177Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.213188Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.302716Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.302755Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.312782Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.312818Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.316774Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.316830Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.316880Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.316891Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.316917Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.316948Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.403576Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.403612Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.412881Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.412919Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.416917Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.416916Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.416940Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.416942Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.416987Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.416998Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.503942Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.503983Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.513169Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.513201Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.517269Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.517299Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.517371Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.517386Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.517427Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.517442Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
>>> Ready to answer: ok
2025-11-05T14:13:35.560152Z :INFO: [/Root] [] [cccd1399-defcfb5a-831497d5-d10bd556] Open read subsessions to databases: { name: dc1, endpoint: localhost:24643, path: /Root }, { name: dc2, endpoint: localhost:24643, path: /Root }
2025-11-05T14:13:35.573106Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Starting read session
2025-11-05T14:13:35.573163Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Starting single session
2025-11-05T14:13:35.573979Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] In Reconnect, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.574055Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] New values: ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.574129Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Reconnecting session to cluster  in 0.000000s
2025-11-05T14:13:35.575542Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Starting read session
2025-11-05T14:13:35.575579Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Starting single session
2025-11-05T14:13:35.575672Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] In Reconnect, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.575703Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] New values: ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.575730Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] Reconnecting session to cluster  in 0.000000s
2025-11-05T14:13:35.581823Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] Successfully connected. Initializing session
2025-11-05T14:13:35.581859Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Successfully connected. Initializing session
2025-11-05T14:13:35.583569Z node 1 :PQ_READ_PROXY DEBUG: new grpc connection
2025-11-05T14:13:35.583607Z node 1 :PQ_READ_PROXY DEBUG: new session created cookie 1
2025-11-05T14:13:35.583761Z node 1 :PQ_READ_PROXY DEBUG: new grpc connection
2025-11-05T14:13:35.583773Z node 1 :PQ_READ_PROXY DEBUG: new session created cookie 2
2025-11-05T14:13:35.593458Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { path: "test-topic" } consumer: "shared/user" } }
2025-11-05T14:13:35.593751Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 read init: from# ipv6:[::1]:60514, request# { init_request { topics_read_settings { path: "test-topic" } consumer: "shared/user" } }
2025-11-05T14:13:35.594036Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer  session  grpc read done: success# 1, data# { init_request { topics_read_settings { path: "test-topic" } consumer: "shared/user" } }
2025-11-05T14:13:35.594197Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 read init: from# ipv6:[::1]:60514, request# { init_request { topics_read_settings { path: "test-topic" } consumer: "shared/user" } }
2025-11-05T14:13:35.594229Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 auth for : user
2025-11-05T14:13:35.594424Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 auth for : user
2025-11-05T14:13:35.594623Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 Handle describe topics response
2025-11-05T14:13:35.594675Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 Handle describe topics response
2025-11-05T14:13:35.594745Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 auth is DEAD
2025-11-05T14:13:35.594751Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 auth is DEAD
2025-11-05T14:13:35.594810Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 auth ok: topics# 1, initDone# 0
2025-11-05T14:13:35.594810Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 auth ok: topics# 1, initDone# 0
2025-11-05T14:13:35.596259Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 register session: topic# rt3.dc1--test-topic
2025-11-05T14:13:35.596701Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 register session: topic# rt3.dc1--test-topic
2025-11-05T14:13:35.597053Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Server session id: shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.597050Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] Server session id: shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.597112Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] In ContinueReadingDataImpl, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.597109Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] In ContinueReadingDataImpl, ReadSizeBudget = 524288, ReadSizeServerDelta = 0
2025-11-05T14:13:35.597292Z :DEBUG: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-11-05T14:13:35.597292Z :DEBUG: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 524288
2025-11-05T14:13:35.598834Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 grpc read done: success# 1, data# { read_request { bytes_size: 524288 } }
2025-11-05T14:13:35.598900Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 grpc read done: success# 1, data# { read_request { bytes_size: 524288 } }
2025-11-05T14:13:35.598981Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 got read request: guid# 30e6ed72-e770416f-d65fa982-82a3dee
2025-11-05T14:13:35.599028Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 got read request: guid# 52de092b-77c7b582-21802dcb-f8274ed5
2025-11-05T14:13:35.600051Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 assign: record# { Partition: 3 TabletId: 72075186224037892 Topic: "rt3.dc1--test-topic" Generation: 1 Step: 2 Session: "shared/user_1_1_2887843246936756272_v1" ClientId: "user" PipeClient { RawX1: 7569244270283046722 RawX2: 4503603922340328 } Path: "/Root/PQ/rt3.dc1--test-topic" }
2025-11-05T14:13:35.600178Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 assign: record# { Partition: 1 TabletId: 72075186224037892 Topic: "rt3.dc1--test-topic" Generation: 1 Step: 4 Session: "shared/user_1_1_2887843246936756272_v1" ClientId: "user" PipeClient { RawX1: 7569244270283046722 RawX2: 4503603922340328 } Path: "/Root/PQ/rt3.dc1--test-topic" }
2025-11-05T14:13:35.600267Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 INITING TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1)
2025-11-05T14:13:35.600337Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 INITING TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 1(assignId:2)
2025-11-05T14:13:35.596880Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046721:2537] connected; active server actors: 1
2025-11-05T14:13:35.597564Z node 2 :PERSQUEUE_READ_BALANCER NOTICE: [72075186224037893][rt3.dc1--test-topic] consumer "user" register session for pipe [1:7569244270283046721:2537] session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.597635Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user register readable partition 0
2025-11-05T14:13:35.597694Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user family created family=1 (Status=Free, Partitions=[0])
2025-11-05T14:13:35.597708Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user register readable partition 1
2025-11-05T14:13:35.597732Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user family created family=2 (Status=Free, Partitions=[1])
2025-11-05T14:13:35.597763Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user register readable partition 2
2025-11-05T14:13:35.597789Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user family created family=3 (Status=Free, Partitions=[2])
2025-11-05T14:13:35.597802Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user register readable partition 3
2025-11-05T14:13:35.597830Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user family created family=4 (Status=Free, Partitions=[3])
2025-11-05T14:13:35.597843Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user register readable partition 4
2025-11-05T14:13:35.597862Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user family created family=5 (Status=Free, Partitions=[4])
2025-11-05T14:13:35.601034Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 assign: record# { Partition: 4 TabletId: 72075186224037892 Topic: "rt3.dc1--test-topic" Generation: 1 Step: 1 Session: "shared/user_1_2_142094002327387421_v1" ClientId: "user" PipeClient { RawX1: 7569244270283046721 RawX2: 4503603922340329 } Path: "/Root/PQ/rt3.dc1--test-topic" }
2025-11-05T14:13:35.601218Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 assign: record# { Partition: 2 TabletId: 72075186224037892 Topic: "rt3.dc1--test-topic" Generation: 1 Step: 3 Session: "shared/user_1_2_142094002327387421_v1" ClientId: "user" PipeClient { RawX1: 7569244270283046721 RawX2: 4503603922340329 } Path: "/Root/PQ/rt3.dc1--test-topic" }
2025-11-05T14:13:35.601323Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 assign: record# { Partition: 0 TabletId: 72075186224037892 Topic: "rt3.dc1--test-topic" Generation: 1 Step: 5 Session: "shared/user_1_2_142094002327387421_v1" ClientId: "user" PipeClient { RawX1: 7569244270283046721 RawX2: 4503603922340329 } Path: "/Root/PQ/rt3.dc1--test-topic" }
2025-11-05T14:13:35.601386Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INITING TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 4(assignId:1)
2025-11-05T14:13:35.601444Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INITING TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2)
2025-11-05T14:13:35.601480Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INITING TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 0(assignId:3)
2025-11-05T14:13:35.604929Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [1:7569244270283046725:2542]
2025-11-05T14:13:35.604979Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244270283046725:2542], now have 1 active actors on pipe
2025-11-05T14:13:35.605006Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244270283046726:2543], now have 1 active actors on pipe
2025-11-05T14:13:35.605020Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244270283046731:2545], now have 1 active actors on pipe
2025-11-05T14:13:35.605049Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:35.605075Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 3
2025-11-05T14:13:35.605115Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Created session shared/user_1_1_2887843246936756272_v1 on pipe: [1:7569244270283046725:2542]
2025-11-05T14:13:35.605161Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244270283046730:2544], now have 1 active actors on pipe
2025-11-05T14:13:35.605187Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [1:7569244270283046732:2546], now have 1 active actors on pipe
2025-11-05T14:13:35.605241Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 1(assignId:2) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [1:7569244270283046726:2543]
2025-11-05T14:13:35.605277Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [1:7569244270283046731:2545]
2025-11-05T14:13:35.605315Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 4(assignId:1) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [1:7569244270283046730:2544]
2025-11-05T14:13:35.605371Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.605393Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.605444Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 0(assignId:3) pipe restart attempt 0 pipe creation result: OK TabletId: 72075186224037892 Generation: 1, pipe: [1:7569244270283046732:2546]
2025-11-05T14:13:35.605474Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user_1_1_2887843246936756272_v1:1 with generation 1
2025-11-05T14:13:35.605535Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.605572Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.605702Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 3 user user session is set to 0 (startOffset 0) session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.605724Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.605858Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:35.605875Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 1
2025-11-05T14:13:35.605892Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Created session shared/user_1_1_2887843246936756272_v1 on pipe: [1:7569244270283046726:2543]
2025-11-05T14:13:35.605913Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:35.605922Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 2
2025-11-05T14:13:35.605937Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Created session shared/user_1_2_142094002327387421_v1 on pipe: [1:7569244270283046731:2545]
2025-11-05T14:13:35.605958Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:35.605966Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 4
2025-11-05T14:13:35.605978Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Created session shared/user_1_2_142094002327387421_v1 on pipe: [1:7569244270283046730:2544]
2025-11-05T14:13:35.605997Z node 1 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'rt3.dc1--test-topic' requestId: <none>
2025-11-05T14:13:35.606005Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'rt3.dc1--test-topic' partition 0
2025-11-05T14:13:35.606018Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Created session shared/user_1_2_142094002327387421_v1 on pipe: [1:7569244270283046732:2546]
2025-11-05T14:13:35.606037Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:35.606069Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user_1_1_2887843246936756272_v1:2 with generation 1
2025-11-05T14:13:35.606087Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user_1_2_142094002327387421_v1:2 with generation 1
2025-11-05T14:13:35.606100Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user_1_2_142094002327387421_v1:1 with generation 1
2025-11-05T14:13:35.606113Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: registered server session: shared/user_1_2_142094002327387421_v1:3 with generation 1
2025-11-05T14:13:35.606144Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.606166Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606202Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 1 user user session is set to 0 (startOffset 0) session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.606218Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606284Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.606302Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606327Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 2 user user session is set to 0 (startOffset 0) session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.606342Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606395Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.606414Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.597901Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user register reading session ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=0)
2025-11-05T14:13:35.606439Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 4 user user session is set to 0 (startOffset 0) session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.606452Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606506Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.606519Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.606543Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Topic 'rt3.dc1--test-topic' partition 0 user user session is set to 0 (startOffset 0) session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.597927Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user rebalancing was scheduled
2025-11-05T14:13:35.606553Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.607007Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:35.607026Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:35.607039Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:35.607051Z node 1 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T14:13:35.597972Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046722:2536] connected; active server actors: 1
2025-11-05T14:13:35.598002Z node 2 :PERSQUEUE_READ_BALANCER NOTICE: [72075186224037893][rt3.dc1--test-topic] consumer "user" register session for pipe [1:7569244270283046722:2536] session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.598025Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user register reading session ReadingSession "shared/user_1_1_2887843246936756272_v1" (Sender=[1:7569244270283046715:2536], Pipe=[1:7569244270283046722:2536], Partitions=[], ActiveFamilyCount=0)
2025-11-05T14:13:35.598076Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing. Sessions=2, Families=5, UnradableFamilies=5 [5 (4), 4 (3), 3 (2), 2 (1), 1 (0), ], RequireBalancing=0 []
2025-11-05T14:13:35.598144Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=5 (Status=Free, Partitions=[4]) for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=0)
2025-11-05T14:13:35.598226Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 5 status Active partitions [4] session "shared/user_1_2_142094002327387421_v1" sender [1:7569244270283046716:2537] lock partition 4 for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=1) generation 1 step 1
2025-11-05T14:13:35.598306Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=4 (Status=Free, Partitions=[3]) for ReadingSession "shared/user_1_1_2887843246936756272_v1" (Sender=[1:7569244270283046715:2536], Pipe=[1:7569244270283046722:2536], Partitions=[], ActiveFamilyCount=0)
2025-11-05T14:13:35.598335Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 4 status Active partitions [3] session "shared/user_1_1_2887843246936756272_v1" sender [1:7569244270283046715:2536] lock partition 3 for ReadingSession "shared/user_1_1_2887843246936756272_v1" (Sender=[1:7569244270283046715:2536], Pipe=[1:7569244270283046722:2536], Partitions=[], ActiveFamilyCount=1) generation 1 step 2
2025-11-05T14:13:35.598362Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=3 (Status=Free, Partitions=[2]) for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=1)
2025-11-05T14:13:35.598396Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 3 status Active partitions [2] session "shared/user_1_2_142094002327387421_v1" sender [1:7569244270283046716:2537] lock partition 2 for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=2) generation 1 step 3
2025-11-05T14:13:35.598426Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=2 (Status=Free, Partitions=[1]) for ReadingSession "shared/user_1_1_2887843246936756272_v1" (Sender=[1:7569244270283046715:2536], Pipe=[1:7569244270283046722:2536], Partitions=[], ActiveFamilyCount=1)
2025-11-05T14:13:35.598469Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 2 status Active partitions [1] session "shared/user_1_1_2887843246936756272_v1" sender [1:7569244270283046715:2536] lock partition 1 for ReadingSession "shared/user_1_1_2887843246936756272_v1" (Sender=[1:7569244270283046715:2536], Pipe=[1:7569244270283046722:2536], Partitions=[], ActiveFamilyCount=2) generation 1 step 4
2025-11-05T14:13:35.598514Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=1 (Status=Free, Partitions=[0]) for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=2)
2025-11-05T14:13:35.598543Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 1 status Active partitions [0] session "shared/user_1_2_142094002327387421_v1" sender [1:7569244270283046716:2537] lock partition 0 for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=3) generation 1 step 5
2025-11-05T14:13:35.598577Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user start rebalancing. familyCount=5, sessionCount=2, desiredFamilyCount=2, allowPlusOne=1
2025-11-05T14:13:35.598614Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing duration: 0.000512s
2025-11-05T14:13:35.613509Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Can't process txs
2025-11-05T14:13:35.617601Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Can't process txs
2025-11-05T14:13:35.617652Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Can't process txs
2025-11-05T14:13:35.617672Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Can't process txs
2025-11-05T14:13:35.618235Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:35.618262Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.618278Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.618340Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:35.618353Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.618365Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.618414Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:35.618426Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.618435Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.618480Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:35.618492Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.618503Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.618544Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T14:13:35.618556Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.618565Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.618604Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 3 messageNo: 0  requestId: <none> cookie: 18446744073709551615
2025-11-05T14:13:35.618637Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 1 messageNo: 0  requestId: <none> cookie: 18446744073709551615
2025-11-05T14:13:35.618657Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 2 messageNo: 0  requestId: <none> cookie: 18446744073709551615
2025-11-05T14:13:35.618676Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 4 messageNo: 0  requestId: <none> cookie: 18446744073709551615
2025-11-05T14:13:35.618697Z node 1 :PERSQUEUE DEBUG: Answer ok topic: 'rt3.dc1--test-topic' partition: 0 messageNo: 0  requestId: <none> cookie: 18446744073709551615
2025-11-05T14:13:35.618886Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 0 WriteTimestampMS: 1762352013090 CreateTimestampMS: 1762352013090 SizeLag: 0 WriteTimestampEstimateMS: 1762352015513 ClientHasAnyCommits: false } Cookie: 18446744073709551615 }
2025-11-05T14:13:35.618930Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 INIT DONE TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1) EndOffset 0 readOffset 0 committedOffset 0
2025-11-05T14:13:35.618994Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 1(assignId:2) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 0 WriteTimestampMS: 1762352013102 CreateTimestampMS: 1762352013102 SizeLag: 0 WriteTimestampEstimateMS: 1762352015517 ClientHasAnyCommits: false } Cookie: 18446744073709551615 }
2025-11-05T14:13:35.619010Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 INIT DONE TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 1(assignId:2) EndOffset 0 readOffset 0 committedOffset 0
2025-11-05T14:13:35.619061Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 0 WriteTimestampMS: 1762352013081 CreateTimestampMS: 1762352013081 SizeLag: 0 WriteTimestampEstimateMS: 1762352015605 ClientHasAnyCommits: false } Cookie: 18446744073709551615 }
2025-11-05T14:13:35.619077Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INIT DONE TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2) EndOffset 0 readOffset 0 committedOffset 0
2025-11-05T14:13:35.619126Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 4(assignId:1) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 0 WriteTimestampMS: 1762352013094 CreateTimestampMS: 1762352013094 SizeLag: 0 WriteTimestampEstimateMS: 1762352015517 ClientHasAnyCommits: false } Cookie: 18446744073709551615 }
2025-11-05T14:13:35.619143Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INIT DONE TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 4(assignId:1) EndOffset 0 readOffset 0 committedOffset 0
2025-11-05T14:13:35.619194Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 0(assignId:3) initDone 0 event { CmdGetClientOffsetResult { Offset: 0 EndOffset: 0 WriteTimestampMS: 1762352013098 CreateTimestampMS: 1762352013098 SizeLag: 0 WriteTimestampEstimateMS: 1762352015517 ClientHasAnyCommits: false } Cookie: 18446744073709551615 }
2025-11-05T14:13:35.619211Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 INIT DONE TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 0(assignId:3) EndOffset 0 readOffset 0 committedOffset 0
2025-11-05T14:13:35.619277Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 sending to client partition status
2025-11-05T14:13:35.619601Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 sending to client partition status
2025-11-05T14:13:35.619640Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 sending to client partition status
Got new read session event: 2025-11-05T14:13:35.619747Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 sending to client partition status
2025-11-05T14:13:35.619766Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 sending to client partition status
StartPartitionSession { Partition session id: 1 Topic: "test-topic" Partition: 2 Database name: dc1 Database path: /Root Database id: account-dc1 CommittedOffset: 0 EndOffset: 0 }
2025-11-05T14:13:35.620624Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test-topic". Partition: 2. Read offset: (NULL)
Got new read session event: StartPartitionSession { Partition session id: 1 Topic: "test-topic" Partition: 3 Database name: dc2 Database path: /Root Database id: account-dc2 CommittedOffset: 0 EndOffset: 0 }
2025-11-05T14:13:35.620906Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test-topic". Partition: 3. Read offset: (NULL)
Got new read session event: StartPartitionSession { Partition session id: 2 Topic: "test-topic" Partition: 4 Database name: dc1 Database path: /Root Database id: account-dc1 CommittedOffset: 0 EndOffset: 0 }
2025-11-05T14:13:35.621980Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Confirm partition stream create. Partition stream id: 2. Cluster: "-". Topic: "test-topic". Partition: 4. Read offset: (NULL)
Got new read session event: StartPartitionSession { Partition session id: 2 Topic: "test-topic" Partition: 1 Database name: dc2 Database path: /Root Database id: account-dc2 CommittedOffset: 0 EndOffset: 0 }
2025-11-05T14:13:35.622138Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] [] Confirm partition stream create. Partition stream id: 2. Cluster: "-". Topic: "test-topic". Partition: 1. Read offset: (NULL)
2025-11-05T14:13:35.624957Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 2 } }
2025-11-05T14:13:35.625106Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 got StartRead from client: partition# TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2), readOffset# 0, commitOffset# (empty maybe)
2025-11-05T14:13:35.625168Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 Start reading TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2) EndOffset 0 readOffset 0 committedOffset 0 clientCommitOffset (empty maybe) clientReadOffset 0
2025-11-05T14:13:35.625208Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 1 } }
2025-11-05T14:13:35.625211Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 2(assignId:2) wait data in partition inited, cookie 1 from offset0
2025-11-05T14:13:35.625272Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 got StartRead from client: partition# TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1), readOffset# 0, commitOffset# (empty maybe)
2025-11-05T14:13:35.625313Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 Start reading TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1) EndOffset 0 readOffset 0 committedOffset 0 clientCommitOffset (empty maybe) clientReadOffset 0
2025-11-05T14:13:35.625335Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 TopicId: Topic rt3.dc1--test-topic in dc dc1 in database: Root, partition 3(assignId:1) wait data in partition inited, cookie 1 from offset0
Got new read session event: StartPartitionSession { Partition session id: 3 Topic: "test-topic" Partition: 0 Database name: dc1 Database path: /Root Database id: account-dc1 CommittedOffset: 0 EndOffset: 0 }
2025-11-05T14:13:35.626047Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] [] Confirm partition stream create. Partition stream id: 3. Cluster: "-". Topic: "test-topic". Partition: 0. Read offset: (NULL)
2025-11-05T14:13:35.626191Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Closing read session. Close timeout: 0.010000s
2025-11-05T14:13:35.626246Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:0:3:0:0 -:test-topic:4:2:0:0 -:test-topic:2:1:0:0
2025-11-05T14:13:35.626291Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 53 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.626719Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Closing read session. Close timeout: 0.010000s
2025-11-05T14:13:35.626761Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:1:2:0:0 -:test-topic:3:1:0:0
2025-11-05T14:13:35.626786Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 51 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.627146Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Closing read session. Close timeout: 0.000000s
2025-11-05T14:13:35.627196Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:0:3:0:0 -:test-topic:4:2:0:0 -:test-topic:2:1:0:0
2025-11-05T14:13:35.627229Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 54 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.627252Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Closing read session. Close timeout: 0.000000s
2025-11-05T14:13:35.627280Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:1:2:0:0 -:test-topic:3:1:0:0
2025-11-05T14:13:35.627298Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 51 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.627323Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Closing read session. Close timeout: 0.000000s
2025-11-05T14:13:35.627360Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:1:2:0:0 -:test-topic:3:1:0:0
2025-11-05T14:13:35.627391Z :INFO: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 51 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.627478Z :NOTICE: [/Root] [/Root] [891974d6-82edac93-fe8802bf-6eba33c2] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-05T14:13:35.627588Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Closing read session. Close timeout: 0.000000s
2025-11-05T14:13:35.627620Z :INFO: [/Root] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test-topic:0:3:0:0 -:test-topic:4:2:0:0 -:test-topic:2:1:0:0
2025-11-05T14:13:35.627641Z :INFO: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Counters: { Errors: 0 CurrentSessionLifetimeMs: 54 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T14:13:35.627675Z :NOTICE: [/Root] [/Root] [9232251f-eaea06b7-c066eace-b76ec4aa] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-05T14:13:35.629063Z node 1 :PQ_READ_PROXY DEBUG: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 1 } }
2025-11-05T14:13:35.629091Z node 1 :PQ_READ_PROXY DEBUG: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 grpc read done: success# 1, data# { start_partition_session_response { partition_session_id: 2 } }
2025-11-05T14:13:35.629147Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 grpc closed
2025-11-05T14:13:35.629163Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 grpc closed
2025-11-05T14:13:35.629175Z node 1 :PQ_READ_PROXY INFO: session cookie 1 consumer shared/user session shared/user_1_1_2887843246936756272_v1 is DEAD
2025-11-05T14:13:35.629196Z node 1 :PQ_READ_PROXY INFO: session cookie 2 consumer shared/user session shared/user_1_2_142094002327387421_v1 is DEAD
2025-11-05T14:13:35.630154Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Destroy direct read session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.630192Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244270283046726:2543] destroyed
2025-11-05T14:13:35.630208Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Destroy direct read session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.630223Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244270283046725:2542] destroyed
2025-11-05T14:13:35.630233Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Destroy direct read session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630245Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244270283046732:2546] destroyed
2025-11-05T14:13:35.630256Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Destroy direct read session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630269Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244270283046731:2545] destroyed
2025-11-05T14:13:35.630279Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Destroy direct read session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630292Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [1:7569244270283046730:2544] destroyed
2025-11-05T14:13:35.630331Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.630345Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.630357Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630369Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630380Z node 1 :PQ_READ_PROXY DEBUG: Direct read cache: server session deregistered: shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.630359Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046722:2536] disconnected; active server actors: 1
2025-11-05T14:13:35.630387Z node 2 :PERSQUEUE_READ_BALANCER NOTICE: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046722:2536] client user disconnected session shared/user_1_1_2887843246936756272_v1
2025-11-05T14:13:35.630464Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user rebalancing was scheduled
2025-11-05T14:13:35.630519Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing. Sessions=1, Families=5, UnradableFamilies=2 [2 (1), 4 (3), ], RequireBalancing=0 []
2025-11-05T14:13:35.630566Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=4 (Status=Free, Partitions=[3]) for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=3)
2025-11-05T14:13:35.630629Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 4 status Active partitions [3] session "shared/user_1_2_142094002327387421_v1" sender [1:7569244270283046716:2537] lock partition 3 for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=4) generation 1 step 6
2025-11-05T14:13:35.630677Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing family=2 (Status=Free, Partitions=[1]) for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=4)
2025-11-05T14:13:35.630710Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] consumer user family 2 status Active partitions [1] session "shared/user_1_2_142094002327387421_v1" sender [1:7569244270283046716:2537] lock partition 1 for ReadingSession "shared/user_1_2_142094002327387421_v1" (Sender=[1:7569244270283046716:2537], Pipe=[1:7569244270283046721:2537], Partitions=[], ActiveFamilyCount=5) generation 1 step 7
2025-11-05T14:13:35.630736Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user start rebalancing. familyCount=5, sessionCount=1, desiredFamilyCount=5, allowPlusOne=0
2025-11-05T14:13:35.630764Z node 2 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][rt3.dc1--test-topic] consumer user balancing duration: 0.000227s
2025-11-05T14:13:35.639503Z node 2 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046721:2537] disconnected; active server actors: 1
2025-11-05T14:13:35.639536Z node 2 :PERSQUEUE_READ_BALANCER NOTICE: [72075186224037893][rt3.dc1--test-topic] pipe [1:7569244270283046721:2537] client user disconnected session shared/user_1_2_142094002327387421_v1
2025-11-05T14:13:35.710621Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.710657Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.713878Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.713909Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.718117Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.718155Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.718214Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.718226Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.718256Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.718268Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.809524Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.809561Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.816054Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.816089Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.818288Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.818312Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.818352Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.818362Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.818380Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.818397Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.909522Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.909552Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.916604Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.916633Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.919290Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.919317Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.919323Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.919357Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:35.919366Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:35.919391Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.009933Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.009966Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.017437Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.017478Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.019474Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.019476Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.019495Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.019513Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.019541Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.019555Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.112786Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.112826Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.118037Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.118068Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.120659Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.120705Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.120760Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.120774Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.120801Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.120814Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.213099Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.213136Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.221033Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.221067Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.221533Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.221554Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.221587Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.221599Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.221626Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.221638Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.313404Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.313436Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.321120Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.321151Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.322728Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.322787Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.322898Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.322940Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.323012Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.323045Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.413761Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.413800Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 2, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.422044Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.422077Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 3, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.423541Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.423568Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 4, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.423611Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.423623Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 1, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T14:13:36.423650Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T14:13:36.423661Z node 1 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
