2025-10-26T18:06:44.015841Z node 10 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[10:7565593500232009469:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:06:44.016381Z node 10 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-10-26T18:06:44.026822Z node 11 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[11:7565593502613866951:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:06:44.028089Z node 11 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-10-26T18:06:44.029961Z node 11 :PQ_READ_PROXY DEBUG: Direct read cache created
2025-10-26T18:06:44.087344Z node 10 :PQ_READ_PROXY DEBUG: Direct read cache created
test_client.cpp: SetPath # /home/runner/.ya/build/build_root/70hy/00051b/r3tmp/tmpMevRpH/pdisk_1.dat
2025-10-26T18:06:44.377577Z node 10 :IMPORT WARN: Table profiles were not loaded
2025-10-26T18:06:44.439428Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(10, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-10-26T18:06:44.439558Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(10, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-10-26T18:06:44.441341Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(11, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-10-26T18:06:44.441479Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(11, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-10-26T18:06:44.447323Z node 10 :HIVE WARN: HIVE#72057594037968897 Handle TEvInterconnect::TEvNodeConnected, NodeId 11 Cookie 11
2025-10-26T18:06:44.447484Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(10, (0,0,0,0)) VolatileState: Connecting -> Connected
2025-10-26T18:06:44.447988Z node 10 :HIVE WARN: HIVE#72057594037968897 Node(11, (0,0,0,0)) VolatileState: Connecting -> Connected
TServer::EnableGrpc on GrpcPort 27557, node 10
2025-10-26T18:06:44.516844Z node 10 :NET_CLASSIFIER WARN: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/70hy/00051b/r3tmp/yandextYO4AN.tmp
2025-10-26T18:06:44.516885Z node 10 :NET_CLASSIFIER WARN: will try to initialize from file: /home/runner/.ya/build/build_root/70hy/00051b/r3tmp/yandextYO4AN.tmp
2025-10-26T18:06:44.517050Z node 10 :NET_CLASSIFIER WARN: successfully initialized from file: /home/runner/.ya/build/build_root/70hy/00051b/r3tmp/yandextYO4AN.tmp
2025-10-26T18:06:44.517405Z node 10 :NET_CLASSIFIER ERROR: got bad distributable configuration
2025-10-26T18:06:44.577842Z INFO: TTestServer started on Port 26710 GrpcPort 27557
TClient is connected to server localhost:26710
PQClient connected to localhost:27557
WaitRootIsUp 'Root'...
TClient::Ls request: Root
TClient::Ls response: 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
    }
  }
  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
      PlanResolution: 7
      Coo...
(TRUNCATED)
WaitRootIsUp 'Root' success.
2025-10-26T18:06:44.879341Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976715657:0, at schemeshard:  72057594046644480
waiting...
waiting...
2025-10-26T18:06:44.932253Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715659:0, at schemeshard:  72057594046644480
waiting...
waiting...
waiting...
2025-10-26T18:06:48.725940Z node 11 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [11:7565593519793736402:4292], 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-10-26T18:06:48.728743Z node 11 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=11&id=YmNjNDFiZGMtMWM0NGRiNmQtMjQ4NTlkOWEtNjJmNjBlMGI=, ActorId: [11:7565593519793736400:4291], ActorState: ExecuteState, TraceId: 01k8gv75bh18v4nxnwqzbe38bc, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-10-26T18:06:48.729750Z node 11 :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-10-26T18:06:48.750734Z node 10 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [10:7565593517411879695:4298], 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-10-26T18:06:48.753182Z node 10 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=10&id=ZDVjZTk1NjctNmJiM2Q4MjUtZmQ2ZmU4OTQtZWU4M2Y3Mjc=, ActorId: [10:7565593517411879692:4297], ActorState: ExecuteState, TraceId: 01k8gv75c51m1ejg7gg5kqa8mv, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-10-26T18:06:48.753824Z node 10 :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-10-26T18:06:48.765574Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715662:0, at schemeshard:  72057594046644480
2025-10-26T18:06:48.865849Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715663:0, at schemeshard:  72057594046644480
2025-10-26T18:06:49.017432Z node 10 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[10:7565593500232009469:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:06:49.017532Z node 10 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-10-26T18:06:49.027303Z node 11 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[11:7565593502613866951:4098];send_to=[0:7307199536658146131:7762515];
2025-10-26T18:06:49.027407Z node 11 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:68;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-10-26T18:06:49.035791Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715664:0, at schemeshard:  72057594046644480
=== Init DC: UPSERT INTO `/Root/PQ/Config/V2/Cluster` (name, balancer, local, enabled, weight) VALUES ("dc1", "localhost", true, true, 1000), ("dc2", "dc2.logbroker.yandex.net", false, true, 1000);
2025-10-26T18:06:49.489588Z node 10 :KQP_EXECUTER ERROR: TxId: 281474976715665. Ctx: { TraceId: 01k8gv75x00ne48ascdw9c5qbh, Database: , DatabaseId: /Root, SessionId: ydb://session/3?node_id=10&id=NzQ5MGVhYzUtODIxMGEyMzktOWE2ZDIyZjQtOTA0NzkzNDI=, CurrentExecutionId: , CustomerSuppliedId: , PoolId: }. Database not set, use /Root
=== CheckClustersList. Subcribe to ClusterTracker from [10:7565593521706847353:12323] 
=== CheckClustersList. Ok
2025-10-26T18:06:55.817560Z node 10 :PQ_READ_PROXY DEBUG: new Create topic request
2025-10-26T18:06:55.863032Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvInterconnect::TEvNodeInfo
2025-10-26T18:06:55.865092Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-10-26T18:06:55.868693Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-10-26T18:06:55.868985Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] doesn't have tx info
2025-10-26T18:06:55.869011Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] PlanStep 0, PlanTxId 0, ExecStep 0, ExecTxId 0
2025-10-26T18:06:55.869031Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] no config, start with empty partitions and default config
2025-10-26T18:06:55.869055Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Txs.size=0, PlannedTxs.size=0
2025-10-26T18:06:55.869082Z node 10 :PERSQUEUE NOTICE: Tablet 72075186224037892 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:06:55.869118Z node 10 :PERSQUEUE INFO: Tablet 72075186224037892 doesn't have tx writes info
2025-10-26T18:06:55.871617Z node 10 :PERSQUEUE DEBUG: Tablet 72075186224037892 server connected, pipe [10:7565593547476651634:8468], now have 1 active actors on pipe
2025-10-26T18:06:55.872124Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 } TxId: 281474976715679 Config { TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 } } }
2025-10-26T18:06:55.872251Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Propose TxId 281474976715679, WriteId (empty maybe)
2025-10-26T18:06:55.872273Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state UNKNOWN
2025-10-26T18:06:55.872290Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State UNKNOWN
2025-10-26T18:06:55.872313Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] schedule TEvProposeTransactionResult(PREPARED)
2025-10-26T18:06:55.872333Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState PREPARING
2025-10-26T18:06:55.872415Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715679
2025-10-26T18:06:55.872806Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] save tx TxId: 281474976715679 State: PREPARED MinStep: 1761502015847 MaxStep: 18446744073709551615 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.872976Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.879483Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.879545Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARING
2025-10-26T18:06:55.879579Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State PREPARING
2025-10-26T18:06:55.879607Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState PREPARED
2025-10-26T18:06:55.884955Z node 11 :PERSQUEUE_READ_BALANCER INFO: balancer: [72075186224037893] topic  pipe [10:7565593547476651635:8645] connected; active server actors: 1
2025-10-26T18:06:55.886162Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037893] topic rt3.dc1--acc--some-topic updating configuration. Deleted partitions []. Added partitions [0]
2025-10-26T18:06:55.886918Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-10-26T18:06:55.889132Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: BALANCER INIT DONE for rt3.dc1--acc--some-topic: (0, 72075186224037892) 
2025-10-26T18:06:55.889223Z node 10 :PERSQUEUE DEBUG: Tablet 72075186224037892 server connected, pipe [11:7565593549858508112:10], now have 1 active actors on pipe
2025-10-26T18:06:55.889529Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037893 topic rt3.dc1--acc--some-topic TEvClientConnected TabletId 72075186224037892, NodeId 10, Generation 1
2025-10-26T18:06:55.890209Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: tablet 72075186224037893 topic rt3.dc1--acc--some-topic TEvClientConnected TabletId 72057594046644480, NodeId 10, Generation 2
2025-10-26T18:06:55.893974Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransactionAttach TabletId: 72075186224037892 TxId: 281474976715679
2025-10-26T18:06:55.896690Z node 10 :PERSQUEUE DEBUG: Tablet 72075186224037892 server connected, pipe [10:7565593547476651715:8437], now have 1 active actors on pipe
2025-10-26T18:06:55.896811Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvTxProcessing::TEvPlanStep Transactions { TxId: 281474976715679 AckTo { RawX1: 7565593500232010026 RawX2: 42949681283 } } Step: 1761502015938 MediatorID: 72057594046382081 TabletID: 72075186224037892
2025-10-26T18:06:55.896850Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARED
2025-10-26T18:06:55.896867Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State PREPARED
2025-10-26T18:06:55.896887Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState PLANNING
2025-10-26T18:06:55.896912Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] PlanStep 1761502015938, PlanTxId 281474976715679
2025-10-26T18:06:55.896949Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715679
2025-10-26T18:06:55.897438Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] save tx TxId: 281474976715679 State: PLANNED MinStep: 1761502015847 MaxStep: 18446744073709551615 Step: 1761502015938 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.897589Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.901037Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.901104Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PLANNING
2025-10-26T18:06:55.901127Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State PLANNING
2025-10-26T18:06:55.901156Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState PLANNED
2025-10-26T18:06:55.901185Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from PLANNING to PLANNED
2025-10-26T18:06:55.901206Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxQueue.size 1
2025-10-26T18:06:55.901233Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] New ExecStep 1761502015938, ExecTxId 281474976715679
2025-10-26T18:06:55.902245Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState CALCULATING
2025-10-26T18:06:55.902275Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from PLANNED to CALCULATING
2025-10-26T18:06:55.902351Z node 10 :PERSQUEUE DEBUG: Initializing topic 'rt3.dc1--acc--some-topic' partition 0. Step TInitConfigStep
2025-10-26T18:06:55.902415Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-10-26T18:06:55.902841Z node 10 :PERSQUEUE DEBUG: Initializing topic 'rt3.dc1--acc--some-topic' partition 0. Step TInitInternalFieldsStep
2025-10-26T18:06:55.903178Z node 10 :PERSQUEUE INFO: bootstrapping 0 [10:7565593547476651727:4306]
2025-10-26T18:06:55.907214Z node 10 :PERSQUEUE DEBUG: Initializing topic 'rt3.dc1--acc--some-topic' partition 0. Completed.
2025-10-26T18:06:55.907256Z node 10 :PERSQUEUE INFO: init complete for topic 'rt3.dc1--acc--some-topic' partition 0 generation 1 [10:7565593547476651727:4306]
2025-10-26T18:06:55.907286Z node 10 :PERSQUEUE DEBUG: SYNC INIT topic rt3.dc1--acc--some-topic partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-10-26T18:06:55.910554Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Process pending events. Count 1
2025-10-26T18:06:55.910825Z node 10 :PERSQUEUE DEBUG: Topic 'rt3.dc1--acc--some-topic' partition 0 user acc@consumer2 readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-10-26T18:06:55.910839Z node 10 :PERSQUEUE DEBUG: Topic 'rt3.dc1--acc--some-topic' partition 0 user acc@consumer1 readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-10-26T18:06:55.911115Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1761502015938, TxId 281474976715679, Partition 0
2025-10-26T18:06:55.911150Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] Handle TEvProposePartitionConfigResult
2025-10-26T18:06:55.911171Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] Partition responses 1/1
2025-10-26T18:06:55.911193Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-10-26T18:06:55.911214Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State CALCULATING
2025-10-26T18:06:55.911241Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 State CALCULATING FrontTxId 281474976715679
2025-10-26T18:06:55.911263Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-10-26T18:06:55.911291Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState CALCULATED
2025-10-26T18:06:55.911323Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from CALCULATING to CALCULATED
2025-10-26T18:06:55.911347Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715679
2025-10-26T18:06:55.911950Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] save tx TxId: 281474976715679 State: CALCULATED MinStep: 1761502015847 MaxStep: 18446744073709551615 Step: 1761502015938 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.912144Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.916018Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.916063Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATED
2025-10-26T18:06:55.916086Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State CALCULATED
2025-10-26T18:06:55.916111Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 State CALCULATED FrontTxId 281474976715679
2025-10-26T18:06:55.916136Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState WAIT_RS
2025-10-26T18:06:55.916163Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from CALCULATED to WAIT_RS
2025-10-26T18:06:55.916193Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvTxProcessing::TEvReadSet to 0 receivers. Wait TEvTxProcessing::TEvReadSet from 0 senders.
2025-10-26T18:06:55.916220Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] HaveParticipantsDecision 1
2025-10-26T18:06:55.916265Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState EXECUTING
2025-10-26T18:06:55.916304Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from WAIT_RS to EXECUTING
2025-10-26T18:06:55.916325Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 0, Expected 1
2025-10-26T18:06:55.916381Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1761502015938, TxId 281474976715679
2025-10-26T18:06:55.917102Z node 10 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-10-26T18:06:55.922477Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1761502015938, TxId 281474976715679, Partition 0
2025-10-26T18:06:55.922535Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-10-26T18:06:55.922570Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State EXECUTING
2025-10-26T18:06:55.922600Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 State EXECUTING FrontTxId 281474976715679
2025-10-26T18:06:55.922624Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-10-26T18:06:55.922624Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-10-26T18:06:55.922658Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId: 281474976715679 send TEvPersQueue::TEvProposeTransactionResult(COMPLETE)
2025-10-26T18:06:55.922702Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] complete TxId 281474976715679
2025-10-26T18:06:55.923330Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 Generation: 0 Important: false }
2025-10-26T18:06:55.923473Z node 10 :PERSQUEUE NOTICE: Tablet 72075186224037892 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:06:55.923651Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete partitions for TxId 281474976715679
2025-10-26T18:06:55.923685Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState EXECUTED
2025-10-26T18:06:55.923717Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from EXECUTING to EXECUTED
2025-10-26T18:06:55.923767Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715679
2025-10-26T18:06:55.924345Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] save tx TxId: 281474976715679 State: EXECUTED MinStep: 1761502015847 MaxStep: 18446744073709551615 Step: 1761502015938 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "MyGreatType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "MyGreatType" Version: 0 Generation: 0 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.924656Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.931394Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.931441Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTED
2025-10-26T18:06:55.931465Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State EXECUTED
2025-10-26T18:06:55.931490Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 State EXECUTED FrontTxId 281474976715679
2025-10-26T18:06:55.931510Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TPersQueue::SendEvReadSetAckToSenders
2025-10-26T18:06:55.931550Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState WAIT_RS_ACKS
2025-10-26T18:06:55.931576Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679 moved from EXECUTED to WAIT_RS_ACKS
2025-10-26T18:06:55.931620Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] PredicateAcks: 0/0
2025-10-26T18:06:55.931633Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] HaveAllRecipientsReceive 1, AllSupportivePartitionsHaveBeenDeleted 1
2025-10-26T18:06:55.931650Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715679] PredicateAcks: 0/0
2025-10-26T18:06:55.931671Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] add an TxId 281474976715679 to the list for deletion
2025-10-26T18:06:55.931698Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, NewState DELETING
2025-10-26T18:06:55.931727Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete key for TxId 281474976715679
2025-10-26T18:06:55.931812Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
{ operation { ready: true status: SUCCESS } }
{  }
2025-10-26T18:06:55.937084Z node 10 :PQ_READ_PROXY DEBUG: new Describe topic request
2025-10-26T18:06:55.942705Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.942772Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state DELETING
2025-10-26T18:06:55.942801Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715679, State DELETING
2025-10-26T18:06:55.942831Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete TxId 281474976715679
{ operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.PersQueue.V1.DescribeTopicResult" value: "\n;\n\030rt3.dc1--acc--some-topic\022\014root@builtin(\021J\017\010\302\343\316\215\2423\020\237\247\200\200\200\200@\022z\010\001\020\200\270\231)\030\0010\200\200@8\200\200@J\037\n\racc/consumer1 \001:\014data-streamsJ\036\n\racc/consumer2 \001:\013MyGreatTypeR\033\n\026_partitions_per_tablet\022\0011`\200\200\227\223\005h\200\233\356\002" } } }
{ self { name: "rt3.dc1--acc--some-topic" owner: "root@builtin" type: TOPIC created_at { plan_step: 1761502015938 tx_id: 281474976715679 } } settings { partitions_count: 1 retention_period_ms: 86400000 supported_format: FORMAT_BASE max_partition_write_speed: 1048576 max_partition_write_burst: 1048576 read_rules { consumer_name: "acc/consumer1" supported_format: FORMAT_BASE service_type: "data-streams" } read_rules { consumer_name: "acc/consumer2" supported_format: FORMAT_BASE service_type: "MyGreatType" } attributes { key: "_partitions_per_tablet" value: "1" } message_group_seqno_retention_period_ms: 1382400000 max_partition_message_groups_seqno_stored: 6000000 } }
2025-10-26T18:06:55.949406Z node 10 :PQ_READ_PROXY DEBUG: new Alter topic request
2025-10-26T18:06:55.952223Z node 10 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterPersQueueGroup, opId: 281474976715680:0, at schemeshard:  72057594046644480
2025-10-26T18:06:55.960880Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 } TxId: 281474976715680 Config { TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 } } }
2025-10-26T18:06:55.961090Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Propose TxId 281474976715680, WriteId (empty maybe)
2025-10-26T18:06:55.961135Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state UNKNOWN
2025-10-26T18:06:55.961156Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State UNKNOWN
2025-10-26T18:06:55.961186Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] schedule TEvProposeTransactionResult(PREPARED)
2025-10-26T18:06:55.961212Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState PREPARING
2025-10-26T18:06:55.961317Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715680
2025-10-26T18:06:55.962851Z node 11 :PERSQUEUE_READ_BALANCER DEBUG: balancer: [72075186224037893] topic rt3.dc1--acc--some-topic updating configuration. Deleted partitions []. Added partitions []
2025-10-26T18:06:55.962058Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] save tx TxId: 281474976715680 State: PREPARED MinStep: 1761502016000 MaxStep: 18446744073709551615 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 ReadRuleGenerations: 2 AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 Generation: 2 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.962263Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.966960Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.967017Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARING
2025-10-26T18:06:55.967041Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State PREPARING
2025-10-26T18:06:55.967064Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState PREPARED
2025-10-26T18:06:55.970611Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransactionAttach TabletId: 72075186224037892 TxId: 281474976715680
2025-10-26T18:06:55.972239Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvTxProcessing::TEvPlanStep Transactions { TxId: 281474976715680 AckTo { RawX1: 7565593500232010026 RawX2: 42949681283 } } Step: 1761502016015 MediatorID: 72057594046382081 TabletID: 72075186224037892
2025-10-26T18:06:55.972301Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARED
2025-10-26T18:06:55.972331Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State PREPARED
2025-10-26T18:06:55.972361Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState PLANNING
2025-10-26T18:06:55.972387Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] PlanStep 1761502016015, PlanTxId 281474976715680
2025-10-26T18:06:55.972443Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715680
2025-10-26T18:06:55.973251Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] save tx TxId: 281474976715680 State: PLANNED MinStep: 1761502016000 MaxStep: 18446744073709551615 Step: 1761502016015 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 ReadRuleGenerations: 2 AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 Generation: 2 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.973452Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.985899Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.985984Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state PLANNING
2025-10-26T18:06:55.986010Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State PLANNING
2025-10-26T18:06:55.986038Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState PLANNED
2025-10-26T18:06:55.986067Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from PLANNING to PLANNED
2025-10-26T18:06:55.986094Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxQueue.size 1
2025-10-26T18:06:55.986124Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] New ExecStep 1761502016015, ExecTxId 281474976715680
2025-10-26T18:06:55.986471Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState CALCULATING
2025-10-26T18:06:55.986505Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from PLANNED to CALCULATING
2025-10-26T18:06:55.986704Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Handle TEvPQ::TEvProposePartitionConfig Step 1761502016015, TxId 281474976715680
2025-10-26T18:06:55.986907Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1761502016015, TxId 281474976715680, Partition 0
2025-10-26T18:06:55.986939Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] Handle TEvProposePartitionConfigResult
2025-10-26T18:06:55.986965Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] Partition responses 1/1
2025-10-26T18:06:55.986988Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-10-26T18:06:55.987010Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State CALCULATING
2025-10-26T18:06:55.987034Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 State CALCULATING FrontTxId 281474976715680
2025-10-26T18:06:55.987058Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-10-26T18:06:55.987081Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState CALCULATED
2025-10-26T18:06:55.987103Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from CALCULATING to CALCULATED
2025-10-26T18:06:55.987129Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715680
2025-10-26T18:06:55.987871Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] save tx TxId: 281474976715680 State: CALCULATED MinStep: 1761502016000 MaxStep: 18446744073709551615 Step: 1761502016015 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 ReadRuleGenerations: 2 AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 Generation: 2 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:55.988100Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:55.992391Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:55.992436Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATED
2025-10-26T18:06:55.992459Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State CALCULATED
2025-10-26T18:06:55.992497Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 State CALCULATED FrontTxId 281474976715680
2025-10-26T18:06:55.992525Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState WAIT_RS
2025-10-26T18:06:55.992549Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from CALCULATED to WAIT_RS
2025-10-26T18:06:55.992577Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvTxProcessing::TEvReadSet to 0 receivers. Wait TEvTxProcessing::TEvReadSet from 0 senders.
2025-10-26T18:06:55.992603Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] HaveParticipantsDecision 1
2025-10-26T18:06:55.992649Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState EXECUTING
2025-10-26T18:06:55.992673Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from WAIT_RS to EXECUTING
2025-10-26T18:06:55.992693Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 0, Expected 1
2025-10-26T18:06:55.992755Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1761502016015, TxId 281474976715680
2025-10-26T18:06:55.993097Z node 10 :PERSQUEUE DEBUG: Topic 'rt3.dc1--acc--some-topic' partition 0 user acc@consumer3 reinit with generation 2 done
2025-10-26T18:06:55.993506Z node 10 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-10-26T18:06:55.998718Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1761502016015, TxId 281474976715680, Partition 0
2025-10-26T18:06:55.998756Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-10-26T18:06:55.998787Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State EXECUTING
2025-10-26T18:06:55.998805Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 State EXECUTING FrontTxId 281474976715680
2025-10-26T18:06:55.998820Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-10-26T18:06:55.998856Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId: 281474976715680 send TEvPersQueue::TEvProposeTransactionResult(COMPLETE)
2025-10-26T18:06:55.998870Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-10-26T18:06:55.998882Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] complete TxId 281474976715680
2025-10-26T18:06:55.999370Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 ReadRuleGenerations: 2 AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 Generation: 2 Important: false }
2025-10-26T18:06:55.999415Z node 10 :PERSQUEUE NOTICE: Tablet 72075186224037892 disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-10-26T18:06:55.999540Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete partitions for TxId 281474976715680
2025-10-26T18:06:55.999569Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState EXECUTED
2025-10-26T18:06:55.999589Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from EXECUTING to EXECUTED
2025-10-26T18:06:55.999616Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715680
2025-10-26T18:06:56.000120Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] save tx TxId: 281474976715680 State: EXECUTED MinStep: 1761502016000 MaxStep: 18446744073709551615 Step: 1761502016015 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 86400 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "rt3.dc1--acc--some-topic" Version: 2 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "acc" Ident: "acc" Topic: "some-topic" DC: "dc1" ReadRules: "acc@consumer1" ReadRules: "acc@consumer2" ReadRules: "acc@consumer3" ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ReadFromTimestampsMs: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerFormatVersions: 0 ConsumerCodecs { } ConsumerCodecs { } ConsumerCodecs { } ReadRuleServiceTypes: "data-streams" ReadRuleServiceTypes: "AnotherType" ReadRuleServiceTypes: "SecondType" FormatVersion: 0 Codecs { } ReadRuleVersions: 0 ReadRuleVersions: 0 ReadRuleVersions: 0 TopicPath: "/Root/PQ/rt3.dc1--acc--some-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 ReadRuleGenerations: 0 ReadRuleGenerations: 2 AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 72075186224037892 } Consumers { Name: "acc@consumer1" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer2" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "AnotherType" Version: 0 Generation: 0 Important: false } Consumers { Name: "acc@consumer3" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "SecondType" Version: 0 Generation: 2 Important: false } } BootstrapConfig { } SourceActor { RawX1: 7565593500232009785 RawX2: 42949685286 }
2025-10-26T18:06:56.000377Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:56.003156Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:56.003220Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTED
2025-10-26T18:06:56.003268Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State EXECUTED
2025-10-26T18:06:56.003313Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 State EXECUTED FrontTxId 281474976715680
2025-10-26T18:06:56.003350Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TPersQueue::SendEvReadSetAckToSenders
2025-10-26T18:06:56.003389Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState WAIT_RS_ACKS
2025-10-26T18:06:56.003425Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680 moved from EXECUTED to WAIT_RS_ACKS
2025-10-26T18:06:56.003465Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] PredicateAcks: 0/0
2025-10-26T18:06:56.003479Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] HaveAllRecipientsReceive 1, AllSupportivePartitionsHaveBeenDeleted 1
2025-10-26T18:06:56.003496Z node 10 :PERSQUEUE DEBUG: [TxId: 281474976715680] PredicateAcks: 0/0
2025-10-26T18:06:56.003522Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] add an TxId 281474976715680 to the list for deletion
2025-10-26T18:06:56.003548Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, NewState DELETING
2025-10-26T18:06:56.003577Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete key for TxId 281474976715680
2025-10-26T18:06:56.003658Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-10-26T18:06:56.007586Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-10-26T18:06:56.007633Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Try execute txs with state DELETING
2025-10-26T18:06:56.007674Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] TxId 281474976715680, State DELETING
2025-10-26T18:06:56.007703Z node 10 :PERSQUEUE DEBUG: [PQ: 72075186224037892] delete TxId 281474976715680
{ operation { ready: true status: SUCCESS } }
{  }
2025-10-26T18:06:56.047134Z node 10 :PQ_READ_PROXY DEBUG: new Describe topic request
{ operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.PersQueue.V1.DescribeTopicResult" value: "\n;\n\030rt3.dc1--acc--some-topic\022\014root@builtin(\021J\017\010\302\343\316\215\2423\020\237\247\200\200\200\200@\022\231\001\010\001\020\200\270\231)\030\0010\200\200@8\200\200@J\037\n\racc/consumer1 \001:\014data-streamsJ\036\n\racc/consumer2 \001:\013AnotherTypeJ\035\n\racc/consumer3 \001:\nSecondTypeR\033\n\026_partitions_per_tablet\022\0011`\200\200\227\223\005h\200\233\356\002" } } }
{ self { name: "rt3.dc1--acc--some-topic" owner: "root@builtin" type: TOPIC created_at { plan_step: 1761502015938 tx_id: 281474976715679 } } settings { partitions_count: 1 retention_period_ms: 86400000 supported_format: FORMAT_BASE max_partition_write_speed: 1048576 max_partition_write_burst: 1048576 read_rules { consumer_name: "acc/consumer1" supported_format: FORMAT_BASE service_type: "data-streams" } read_rules { consumer_name: "acc/consumer2" supported_format: FORMAT_BASE service_type: "AnotherType" } read_rules { consumer_name: "acc/consumer3" supported_format: FORMAT_BASE service_type: "SecondType" } attributes { key: "_partitions_per_tablet" value: "1" } message_group_seqno_retention_period_ms: 1382400000 max_partition_message_groups_seqno_stored: 6000000 } }
2025-10-26T18:06:56.049928Z node 10 :PQ_READ_PROXY DEBUG: new Alter topic request
{ operation { ready: true status: BAD_REQUEST issues { message: "Unknown read rule service type \'BadServiceType\' for consumer \'acc/consumer1\'" issue_code: 500003 severity: 1 } } }
{  }
2025-10-26T18:06:56.051696Z node 10 :PQ_READ_PROXY DEBUG: new Describe topic request
{ operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.PersQueue.V1.DescribeTopicResult" value: "\n;\n\030rt3.dc1--acc--some-topic\022\014root@builtin(\021J\017\010\302\343\316\215\2423\020\237\247\200\200\200\200@\022\231\001\010\001\020\200\270\231)\030\0010\200\200@8\200\200@J\037\n\racc/consumer1 \001:\014data-streamsJ\036\n\racc/consumer2 \001:\013AnotherTypeJ\035\n\racc/consumer3 \001:\nSecondTypeR\033\n\026_partitions_per_tablet\022\0011`\200\200\227\223\005h\200\233\356\002" } } }
{ self { name: "rt3.dc1--acc--some-topic" owner: "root@builtin" type: TOPIC created_at { plan_step: 1761502015938 tx_id: 281474976715679 } } settings { partitions_count: 1 retention_period_ms: 86400000 supported_format: FORMAT_BASE max_partition_write_speed: 1048576 max_partition_write_burst: 1048576 read_rules { consumer_name: "acc/consumer1" supported_format: FORMAT_BASE service_type: "data-streams" } read_rules { consumer_name: "acc/consumer2" supported_format: FORMAT_BASE service_type: "AnotherType" } read_rules { consumer_name: "acc/consumer3" supported_format: FORMAT_BASE service_type: "SecondType" } attributes { key: "_partitions_per_tablet" value: "1" } message_group_seqno_retention_period_ms: 1382400000 max_partition_message_groups_seqno_stored: 6000000 } }
2025-10-26T18:06:56.652088Z node 10 :KQP_COMPUTE WARN: SelfId: [10:7565593551771619254:4307], TxId: 281474976715681, task: 1, CA Id [10:7565593551771619252:4307]. Got EvDeliveryProblem, TabletId: 72075186224037891, NotDelivered: 0
2025-10-26T18:06:56.688217Z node 10 :KQP_COMPUTE WARN: SelfId: [10:7565593551771619254:4307], TxId: 281474976715681, task: 1, CA Id [10:7565593551771619252:4307]. Got EvDeliveryProblem, TabletId: 72075186224037891, NotDelivered: 1
2025-10-26T18:06:56.737555Z node 10 :KQP_COMPUTE WARN: SelfId: [10:7565593551771619254:4307], TxId: 281474976715681, task: 1, CA Id [10:7565593551771619252:4307]. Got EvDeliveryProblem, TabletId: 72075186224037891, NotDelivered: 1
