2025-11-01T19:50:07.461055Z node 24 :METADATA_PROVIDER WARN: log.cpp:841: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[24:7567846652596916994:2080];send_to=[0:7307199536658146131:7762515];
2025-11-01T19:50:07.461151Z node 24 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:71;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
test_client.cpp: SetPath # /home/runner/.ya/build/build_root/4xuc/001ab0/r3tmp/tmpjJ3JkC/pdisk_1.dat
2025-11-01T19:50:07.506252Z node 25 :METADATA_PROVIDER WARN: log.cpp:841: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[25:7567846652071711099:2075];send_to=[0:7307199536658146131:7762515];
2025-11-01T19:50:07.544685Z node 24 :PQ_READ_PROXY DEBUG: caching_service.cpp:44: Direct read cache: : Created
2025-11-01T19:50:07.554708Z node 24 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2025-11-01T19:50:07.560624Z node 25 :PQ_READ_PROXY DEBUG: caching_service.cpp:44: Direct read cache: : Created
2025-11-01T19:50:07.561687Z node 25 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:71;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-11-01T19:50:07.574208Z node 25 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2025-11-01T19:50:07.759226Z node 24 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2025-11-01T19:50:07.792506Z node 24 :IMPORT WARN: schemeshard_import.cpp:307: Table profiles were not loaded
2025-11-01T19:50:07.798962Z node 25 :CONFIGS_DISPATCHER ERROR: configs_dispatcher.cpp:1229: Notification cookie mismatch for subscription [25:7567846652071711059:2073] 1762026607479487 != 1762026607479484
2025-11-01T19:50:07.806411Z node 25 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: LookupError, path: Root/.metadata/script_executions
2025-11-01T19:50:07.833039Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(24, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-11-01T19:50:07.833207Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(24, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-11-01T19:50:07.836880Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(25, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-11-01T19:50:07.837005Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(25, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-11-01T19:50:07.850007Z node 24 :HIVE WARN: hive_impl.cpp:811: HIVE#72057594037968897 Handle TEvInterconnect::TEvNodeConnected, NodeId 25 Cookie 25
2025-11-01T19:50:07.850242Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(24, (0,0,0,0)) VolatileState: Connecting -> Connected
2025-11-01T19:50:07.852817Z node 24 :HIVE WARN: node_info.cpp:25: HIVE#72057594037968897 Node(25, (0,0,0,0)) VolatileState: Connecting -> Connected
TServer::EnableGrpc on GrpcPort 23548, node 24
2025-11-01T19:50:08.065989Z node 24 :NET_CLASSIFIER WARN: net_classifier.cpp:190: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/4xuc/001ab0/r3tmp/yandexYuypf3.tmp
2025-11-01T19:50:08.066030Z node 24 :NET_CLASSIFIER WARN: net_classifier.cpp:196: will try to initialize from file: /home/runner/.ya/build/build_root/4xuc/001ab0/r3tmp/yandexYuypf3.tmp
2025-11-01T19:50:08.066214Z node 24 :NET_CLASSIFIER WARN: net_classifier.cpp:202: successfully initialized from file: /home/runner/.ya/build/build_root/4xuc/001ab0/r3tmp/yandexYuypf3.tmp
2025-11-01T19:50:08.066455Z node 24 :NET_CLASSIFIER ERROR: net_classifier.cpp:228: got bad distributable configuration
2025-11-01T19:50:08.143951Z INFO: TTestServer started on Port 29665 GrpcPort 23548
2025-11-01T19:50:08.270600Z node 24 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: PathErrorUnknown, path: Root/.metadata/script_executions
2025-11-01T19:50:08.344778Z node 25 :KQP_PROXY WARN: kqp_finalize_script_service.cpp:135: [ScriptExecutions] [TKqpFinalizeScriptService] Failed to check script execution tables existence, scheme status: PathErrorUnknown, path: Root/.metadata/script_executions
2025-11-01T19:50:08.490993Z node 24 :TX_CONVEYOR ERROR: log.cpp:841: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
2025-11-01T19:50:08.545414Z node 25 :TX_CONVEYOR ERROR: log.cpp:841: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
TClient is connected to server localhost:29665
PQClient connected to localhost:23548
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
    }
    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-01T19:50:08.609592Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976715657:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp:311)
waiting...
waiting...
2025-11-01T19:50:08.702725Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715659:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:690)
waiting...
waiting...
waiting...
2025-11-01T19:50:12.462893Z node 24 :METADATA_PROVIDER ERROR: log.cpp:841: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[24:7567846652596916994:2080];send_to=[0:7307199536658146131:7762515];
2025-11-01T19:50:12.463004Z node 24 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:71;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-11-01T19:50:12.494723Z node 25 :METADATA_PROVIDER ERROR: log.cpp:841: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[25:7567846652071711099:2075];send_to=[0:7307199536658146131:7762515];
2025-11-01T19:50:12.494878Z node 25 :METADATA_PROVIDER ERROR: log.cpp:841: fline=accessor_snapshot_base.cpp:71;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
2025-11-01T19:50:15.313815Z node 25 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [25:7567846686431449885:2309], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.313947Z node 25 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [25:7567846686431449896:2312], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.314061Z node 25 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:263: [WorkloadService] [Service] Failed to fetch pool default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.314960Z node 25 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [25:7567846686431449900:2314], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.315143Z node 25 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:263: [WorkloadService] [Service] Failed to fetch pool default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.333378Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateResourcePool, opId: 281474976710657:3, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_resource_pool.cpp:179)
2025-11-01T19:50:15.338047Z node 24 :KQP_PROXY ERROR: kqp_proxy_service.cpp:1316: TraceId: "01k90fgpca2nahzsfz8gne529k", Request deadline has expired for 1.315238s seconds
2025-11-01T19:50:15.342600Z node 24 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [24:7567846686956656481:2337], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.342721Z node 24 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [24:7567846686956656489:2340], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.342863Z node 24 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:263: [WorkloadService] [Service] Failed to fetch pool default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.344955Z node 24 :KQP_WORKLOAD_SERVICE WARN: scheme_actors.cpp:225: [WorkloadService] [TPoolFetcherActor] ActorId: [24:7567846686956656496:2342], DatabaseId: /Root, PoolId: default, Failed to fetch pool info, NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.345078Z node 24 :KQP_WORKLOAD_SERVICE WARN: kqp_workload_service.cpp:263: [WorkloadService] [Service] Failed to fetch pool default, DatabaseId: /Root, status: NOT_FOUND, issues: { <main>: Error: Resource pool default not found or you don't have access permissions }
2025-11-01T19:50:15.361350Z node 24 :TX_PROXY ERROR: schemereq.cpp:593: Actor# [24:7567846686956656497:2743] txid# 281474976715662, issues: { message: "Check failed: path: \'/Root/.metadata/workload_manager/pools/default\', error: path exists but creating right now (id: [OwnerId: 72057594046644480, LocalPathId: 9], type: EPathTypeResourcePool, state: EPathStateCreate)" severity: 1 }
2025-11-01T19:50:15.385289Z node 24 :KQP_WORKLOAD_SERVICE WARN: helpers.h:73: [WorkloadService] [TPoolCreatorActor] ActorId: [24:7567846686956656495:2341], DatabaseId: /Root, PoolId: default, Scheduled retry for error: { <main>: Error: Transaction 281474976710657 completed, doublechecking }
2025-11-01T19:50:15.385810Z node 25 :KQP_WORKLOAD_SERVICE WARN: helpers.h:73: [WorkloadService] [TPoolCreatorActor] ActorId: [25:7567846686431449899:2313], DatabaseId: /Root, PoolId: default, Scheduled retry for error: { <main>: Error: Transaction 281474976710657 completed, doublechecking }
2025-11-01T19:50:15.454219Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715663:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:690)
2025-11-01T19:50:15.456307Z node 24 :TX_PROXY ERROR: schemereq.cpp:593: Actor# [24:7567846686956656612:2805] txid# 281474976715664, issues: { message: "Check failed: path: \'/Root/.metadata/workload_manager/pools/default\', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 9], type: EPathTypeResourcePool, state: EPathStateNoChanges)" severity: 1 }
2025-11-01T19:50:15.480903Z node 25 :TX_PROXY ERROR: schemereq.cpp:593: Actor# [25:7567846686431449928:2191] txid# 281474976710658, issues: { message: "Check failed: path: \'/Root/.metadata/workload_manager/pools/default\', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 9], type: EPathTypeResourcePool, state: EPathStateNoChanges)" severity: 1 }
2025-11-01T19:50:15.517921Z node 24 :KQP_COMPILE_ACTOR ERROR: kqp_compile_actor.cpp:570: Compilation failed, self: [24:7567846686956656629:2353], 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-01T19:50:15.520092Z node 24 :KQP_SESSION WARN: kqp_session_actor.cpp:2506: SessionId: ydb://session/3?node_id=24&id=NWY2OTY2YTEtZjQzZjRlYjMtOWIwNGUzODAtNjQ1MGEzZDU=, ActorId: [24:7567846686956656479:2336], ActorState: ExecuteState, TraceId: 01k90fgwha8f1n9zbgph0yn565, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-11-01T19:50:15.520856Z node 24 :PERSQUEUE_CLUSTER_TRACKER ERROR: cluster_tracker.cpp:167: 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-01T19:50:15.549756Z node 25 :KQP_COMPILE_ACTOR ERROR: kqp_compile_actor.cpp:570: Compilation failed, self: [25:7567846686431449935: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-01T19:50:15.551260Z node 25 :KQP_SESSION WARN: kqp_session_actor.cpp:2506: SessionId: ydb://session/3?node_id=25&id=NTk0ODZkMDUtMjUzNjk5YTYtNzVlOGU2YzEtNWI4YTg5ODQ=, ActorId: [25:7567846686431449882:2308], ActorState: ExecuteState, TraceId: 01k90fgwgadfjg7j7a46tebpjz, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-11-01T19:50:15.551992Z node 25 :PERSQUEUE_CLUSTER_TRACKER ERROR: cluster_tracker.cpp:167: 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-01T19:50:15.600271Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715665:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:690)
2025-11-01T19:50:15.862532Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715666:0, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:690)
=== 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-11-01T19:50:16.639546Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715667. Ctx: { TraceId: 01k90fgx8v6jbrysspj4zxj84f, Database: , SessionId: ydb://session/3?node_id=24&id=ZDZhYTk0M2MtYWFmYjQ2M2ItZDQ2NGY1OGMtZGRjZDcyOTc=, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
=== CheckClustersList. Subcribe to ClusterTracker from [24:7567846691251624374:3155] 
2025-11-01T19:50:22.732086Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard_impl.cpp:7727: Cannot get console configs
2025-11-01T19:50:22.732129Z node 24 :IMPORT WARN: schemeshard_import.cpp:307: Table profiles were not loaded
=== CheckClustersList. Ok
CreateTopicNoLegacy: rt3.dc2--account--topic1
Create topic: /Root/PQ/rt3.dc2--account--topic1
AddTopic: rt3.dc2--account--topic1
===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 = account/topic1, dc = dc2
2025-11-01T19:50:25.709764Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:25.767064Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037893][] pipe [24:7567846729906330500:3429] connected; active server actors: 1
2025-11-01T19:50:25.768178Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037893][rt3.dc2--account--topic1] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:25.769260Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037893][rt3.dc2--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-01T19:50:25.771483Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037893][rt3.dc2--account--topic1] BALANCER INIT DONE for rt3.dc2--account--topic1: (0, 72075186224037892) 
2025-11-01T19:50:25.773898Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037892] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:25.777725Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037892] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:25.778108Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037892] no config, start with empty partitions and default config
2025-11-01T19:50:25.778158Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:25.778216Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037892] doesn't have tx writes info
2025-11-01T19:50:25.780486Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037893][rt3.dc2--account--topic1] TEvClientConnected TabletId 72075186224037892, NodeId 25, Generation 1
2025-11-01T19:50:25.780865Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037892] server connected, pipe [24:7567846729906330511:2472], now have 1 active actors on pipe
2025-11-01T19:50:25.780910Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037892] server connected, pipe [24:7567846729906330499:3428], now have 1 active actors on pipe
2025-11-01T19:50:25.781830Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:25.790181Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:25.800443Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037892] server connected, pipe [24:7567846729906330542:3464], now have 1 active actors on pipe
2025-11-01T19:50:25.802354Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:25.808493Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:25.810647Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic1:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:25.810758Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037892][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:25.811329Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic1:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:25.811793Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037892][Partition][0][StateInit] bootstrapping 0 [25:7567846729381123204:2389]
2025-11-01T19:50:25.816926Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic1:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:25.816975Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc2--account--topic1:0:Initializer] Initializing completed.
2025-11-01T19:50:25.817018Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037892][Partition][0][StateInit] init complete for topic 'rt3.dc2--account--topic1' partition 0 generation 1 [25:7567846729381123204:2389]
2025-11-01T19:50:25.817068Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037892][Partition][0][StateInit] SYNC INIT topic rt3.dc2--account--topic1 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:25.817146Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037892][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:25.821204Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037892][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:25.821274Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:25.821554Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.821584Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037892][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:25.821645Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037892][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:25.821677Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.821711Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.821741Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037892][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:25.821808Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc2--account--topic1' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:25.821834Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037892][Partition][0][StateIdle] Topic 'rt3.dc2--account--topic1' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:25.821897Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037892][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:25.822799Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:25.823048Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:25.831467Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:25.831714Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037892][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026625842, TxId 281474976715672
2025-11-01T19:50:25.831771Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.831798Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.832206Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:25.832757Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037892][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:25.846096Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037892][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:25.846600Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037892][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:25.846886Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037892][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:25.846935Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:25.846963Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.846991Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:25.847044Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037892][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:25.847869Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037892] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 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.dc2--account--topic1" Version: 0 LocalDC: false RequireAuthWrite: true RequireAuthRead: true Producer: "account" Ident: "account" Topic: "topic1" DC: "dc2" FormatVersion: 0 Codecs { } TopicPath: "/Root/PQ/rt3.dc2--account--topic1" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:25.848077Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:25.848795Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:25.858296Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:25.858475Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:25.874562Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:25.920249Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:25.920302Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:25.920324Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:25.955286Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715673. Ctx: { TraceId: 01k90fh6p0er4k3s0yjam1kt1v, Database: , SessionId: ydb://session/3?node_id=24&id=Y2ZhMWU2LWUzZTE2OTViLWE5NjNmZjlkLTNjMzhjNmE0, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
===Query complete
Create topic result: 1 
CreateTopicNoLegacy: rt3.dc1--account--topic1
2025-11-01T19:50:26.020477Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.020530Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.020556Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
Create topic: /Root/PQ/rt3.dc1--account--topic1
AddTopic: rt3.dc1--account--topic1
===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 = account/topic1, dc = dc1
2025-11-01T19:50:26.043557Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:26.107456Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037895][] pipe [24:7567846734201297951:3546] connected; active server actors: 1
2025-11-01T19:50:26.107979Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037895][rt3.dc1--account--topic1] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:26.110548Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037895][rt3.dc1--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-11-01T19:50:26.117544Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037895][rt3.dc1--account--topic1] BALANCER INIT DONE for rt3.dc1--account--topic1: (0, 72075186224037894) 
2025-11-01T19:50:26.122330Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.122387Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.122416Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.225411Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.225467Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.225499Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.236307Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037894] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:26.249154Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037894] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:26.249658Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037894] no config, start with empty partitions and default config
2025-11-01T19:50:26.249729Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037894] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:26.249804Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037894] doesn't have tx writes info
2025-11-01T19:50:26.251794Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037894] server connected, pipe [24:7567846734201297950:3545], now have 1 active actors on pipe
2025-11-01T19:50:26.251847Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037894] server connected, pipe [24:7567846734201297978:2489], now have 1 active actors on pipe
2025-11-01T19:50:26.252958Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:26.254399Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037895][rt3.dc1--account--topic1] TEvClientConnected TabletId 72075186224037894, NodeId 25, Generation 1
2025-11-01T19:50:26.264205Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:26.278838Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037894] server connected, pipe [24:7567846734201298010:3594], now have 1 active actors on pipe
2025-11-01T19:50:26.281553Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:26.288078Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:26.289895Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic1:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:26.289999Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037894][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:26.290524Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic1:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:26.295795Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037894][Partition][0][StateInit] bootstrapping 0 [25:7567846733676090624:2395]
2025-11-01T19:50:26.300344Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic1:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:26.300395Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc1--account--topic1:0:Initializer] Initializing completed.
2025-11-01T19:50:26.300435Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037894][Partition][0][StateInit] init complete for topic 'rt3.dc1--account--topic1' partition 0 generation 1 [25:7567846733676090624:2395]
2025-11-01T19:50:26.300486Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037894][Partition][0][StateInit] SYNC INIT topic rt3.dc1--account--topic1 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:26.300545Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037894][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:26.305227Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037894][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:26.305317Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.305579Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.305623Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037894][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:26.305668Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037894][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:26.305701Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.305735Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.305761Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037894][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:26.305826Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037894][Partition][0][StateIdle] Topic 'rt3.dc1--account--topic1' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:26.305848Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037894][Partition][0][StateIdle] Topic 'rt3.dc1--account--topic1' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:26.305911Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037894][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:26.307473Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715675. Ctx: { TraceId: 01k90fh70g2swcecxzbmdn27px, Database: , SessionId: ydb://session/3?node_id=24&id=ZWMzODNmOWItNGQ3OGQ1OGEtMzU4MmMxZmQtNDk4YjdmYTk=, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
2025-11-01T19:50:26.308948Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:26.309248Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037894][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:26.317580Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:26.317808Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037894][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026626318, TxId 281474976715674
2025-11-01T19:50:26.317837Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.317858Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.318100Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.318594Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037894][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:26.323988Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037894][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:26.324454Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037894][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:26.324757Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037894][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:26.324799Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.324825Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.324852Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.324902Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037894][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:26.325819Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037894] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 2097152 BurstSize: 2097152 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--account--topic1" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "account" Ident: "account" Topic: "topic1" DC: "dc1" FormatVersion: 0 Codecs { } TopicPath: "/Root/PQ/rt3.dc1--account--topic1" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:26.326028Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037894] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:26.326727Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:26.330400Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.330477Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.330505Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.337937Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:26.338121Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:26.344741Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
===Query complete
Create topic result: 1 
2025-11-01T19:50:26.379724Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: try to update token
2025-11-01T19:50:26.380314Z :INFO: [] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-11-01T19:50:26.380391Z :INFO: [] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:23548
2025-11-01T19:50:26.397227Z :DEBUG: [] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "account/topic1" message_group_id: "src" }
2025-11-01T19:50:26.399162Z node 24 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:107: new grpc connection
2025-11-01T19:50:26.399222Z node 24 :PQ_WRITE_PROXY DEBUG: grpc_pq_write.h:141: new session created cookie 1
2025-11-01T19:50:26.402960Z node 24 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 1 sessionId:  grpc read done: success: 1 data: init_request { topic: "account/topic1" message_group_id: "src" }
2025-11-01T19:50:26.403230Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:447: session request cookie: 1 topic: "account/topic1" message_group_id: "src" from ipv6:[::1]:56634
2025-11-01T19:50:26.403264Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:1538: write session:  cookie=1 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:56634 proto=v1  topic=account/topic1 durationSec=0
2025-11-01T19:50:26.403283Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:571: init check schema
2025-11-01T19:50:26.403363Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:282: Handle describe topics
2025-11-01T19:50:26.403389Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:328: SendSchemeCacheRequest
2025-11-01T19:50:26.403485Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:355: send request for 1 topics, got 1 requests infly, db = ""
2025-11-01T19:50:26.406897Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.406943Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.406966Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.408639Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:362: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName:  DomainOwnerId: 0 Instant: 2 ResultSet [{ Path: Root/PQ/rt3.dc1--account--topic1 TableId: [72057594046644480:14:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: false SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) Users: [] Groups: [] } }] }
2025-11-01T19:50:26.408819Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:385: Got describe topics SC response
2025-11-01T19:50:26.410962Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:632: session v1 cookie: 1 sessionId:  describe result for acl check
2025-11-01T19:50:26.411234Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:62: 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-01T19:50:26.411255Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:63: 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-01T19:50:26.411272Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__table_helper.h:64: 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-01T19:50:26.411300Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:111: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) StartKqpSession
2025-11-01T19:50:26.417848Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:142: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) Select from the table
2025-11-01T19:50:26.430888Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.430936Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.430970Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.510918Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.510964Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.510988Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.534671Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.534723Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.534756Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.610783Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.610848Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.610875Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.634925Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.634994Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.635024Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.714892Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.714950Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.714975Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.735198Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.735255Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.735281Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.757010Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:67: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) RequestPQRB
2025-11-01T19:50:26.758301Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037895][rt3.dc1--account--topic1] pipe [24:7567846734201298130:2500] connected; active server actors: 1
2025-11-01T19:50:26.758424Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__old_chooser_actor.h:80: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) Received partition 0 from PQRB for SourceId=src
2025-11-01T19:50:26.758460Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:174: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) Update the table
2025-11-01T19:50:26.799121Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1659: [72075186224037895][rt3.dc1--account--topic1] pipe [24:7567846734201298130:2500] disconnected.
2025-11-01T19:50:26.799176Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1670: [72075186224037895][rt3.dc1--account--topic1] pipe [24:7567846734201298130:2500] disconnected; active server actors: 1
2025-11-01T19:50:26.799197Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1695: [72075186224037895][rt3.dc1--account--topic1] pipe [24:7567846734201298130:2500] disconnected no session
2025-11-01T19:50:26.815048Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.815099Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.815123Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.835554Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.835601Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.835625Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.916313Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.916357Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.916391Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.935907Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.935954Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.935977Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.973783Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:183: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) HandleUpdate PartitionPersisted=0 Status=SUCCESS
2025-11-01T19:50:26.973850Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:305: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=(NULL)
2025-11-01T19:50:26.973882Z node 24 :PQ_PARTITION_CHOOSER DEBUG: partition_chooser_impl__abstract_chooser_actor.h:268: TPartitionChooser [24:7567846734201298071:2500] (SourceId=src, PreferedPartition=(NULL)) Start idle
2025-11-01T19:50:26.973936Z node 24 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:694: ProceedPartition. session cookie: 1 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-11-01T19:50:26.977661Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037894] server connected, pipe [24:7567846734201298156:2500], now have 1 active actors on pipe
2025-11-01T19:50:26.978196Z node 24 :PQ_WRITE_PROXY DEBUG: writer.cpp:822: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 25, Generation: 1
2025-11-01T19:50:26.978436Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:146: Handle TEvRequest topic: 'rt3.dc1--account--topic1' requestId: <none>
2025-11-01T19:50:26.978491Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2635: [PQ: 72075186224037894] got client message batch for topic 'rt3.dc1--account--topic1' partition 0
2025-11-01T19:50:26.978608Z node 25 :PERSQUEUE INFO: ownerinfo.cpp:30: new Cookie src|ec08fb43-7afe567e-29d3f560-ad010487_0 generated for partition 0 topic 'rt3.dc1--account--topic1' owner src
2025-11-01T19:50:26.978667Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.978704Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.978732Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037894][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:26.978810Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.978864Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:35: [72075186224037894][Partition][0][StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2025-11-01T19:50:26.978941Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:181: Answer ok topic: 'rt3.dc1--account--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-01T19:50:26.980164Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:146: Handle TEvRequest topic: 'rt3.dc1--account--topic1' requestId: <none>
2025-11-01T19:50:26.980202Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2635: [PQ: 72075186224037894] got client message batch for topic 'rt3.dc1--account--topic1' partition 0
2025-11-01T19:50:26.980325Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:181: Answer ok topic: 'rt3.dc1--account--topic1' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-01T19:50:26.980729Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:871: session inited cookie: 1 partition: 0 MaxSeqNo: 0 sessionId: src|ec08fb43-7afe567e-29d3f560-ad010487_0
2025-11-01T19:50:26.982982Z :INFO: [] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762026626982 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-01T19:50:26.983153Z :INFO: [] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|ec08fb43-7afe567e-29d3f560-ad010487_0" topic: "account/topic1" cluster: "dc1"
2025-11-01T19:50:26.984171Z :INFO: [] MessageGroupId [src] SessionId [src|ec08fb43-7afe567e-29d3f560-ad010487_0] Write session: close. Timeout = 0 ms
2025-11-01T19:50:26.984259Z :INFO: [] MessageGroupId [src] SessionId [src|ec08fb43-7afe567e-29d3f560-ad010487_0] Write session will now close
2025-11-01T19:50:26.984357Z :DEBUG: [] MessageGroupId [src] SessionId [src|ec08fb43-7afe567e-29d3f560-ad010487_0] Write session: aborting
2025-11-01T19:50:26.985088Z :INFO: [] MessageGroupId [src] SessionId [src|ec08fb43-7afe567e-29d3f560-ad010487_0] Write session: gracefully shut down, all writes complete
2025-11-01T19:50:26.985177Z :DEBUG: [] MessageGroupId [src] SessionId [src|ec08fb43-7afe567e-29d3f560-ad010487_0] Write session: destroy
2025-11-01T19:50:26.992043Z node 24 :PQ_WRITE_PROXY DEBUG: write_session_actor.cpp:254: session v1 cookie: 1 sessionId: src|ec08fb43-7afe567e-29d3f560-ad010487_0 grpc read done: success: 0 data: 
2025-11-01T19:50:26.992089Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:256: session v1 cookie: 1 sessionId: src|ec08fb43-7afe567e-29d3f560-ad010487_0 grpc read failed
2025-11-01T19:50:26.992361Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:824: session v1 closed cookie: 1 sessionId: src|ec08fb43-7afe567e-29d3f560-ad010487_0
2025-11-01T19:50:26.993521Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2746: [PQ: 72075186224037894] server disconnected, pipe [24:7567846734201298156:2500] destroyed
2025-11-01T19:50:26.993582Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:138: [72075186224037894][Partition][0][StateIdle] TPartition::DropOwner.
2025-11-01T19:50:26.993650Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:26.993678Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:26.993702Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:26.992401Z node 24 :PQ_WRITE_PROXY INFO: write_session_actor.cpp:304: session v1 cookie: 1 sessionId: src|ec08fb43-7afe567e-29d3f560-ad010487_0 is DEAD
2025-11-01T19:50:26.992905Z node 24 :PQ_WRITE_PROXY DEBUG: writer.cpp:562: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
waiting...
2025-11-01T19:50:27.015794Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037893][rt3.dc2--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-01T19:50:27.015955Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037895][rt3.dc1--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-11-01T19:50:27.017943Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.017995Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.018017Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.036706Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037893][rt3.dc2--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-01T19:50:27.036832Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037895][rt3.dc1--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-11-01T19:50:27.036963Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.037008Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.037032Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
waiting...
2025-11-01T19:50:27.054634Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037893][rt3.dc2--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-01T19:50:27.054757Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037895][rt3.dc1--account--topic1] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
CreateTopicNoLegacy: /Root/LbCommunal/account/topic2
Create topic: /Root/LbCommunal/account/topic2
2025-11-01T19:50:27.118184Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.118227Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.118250Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
AddTopic: /Root/LbCommunal/account/topic2
===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 = /Root/LbCommunal/account/topic2, dc = unknown
2025-11-01T19:50:27.128851Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:27.137092Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.137151Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.137174Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.209748Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037896] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:27.217166Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037896] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:27.217525Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037896] no config, start with empty partitions and default config
2025-11-01T19:50:27.217581Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037896] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:27.217666Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037896] doesn't have tx writes info
2025-11-01T19:50:27.218513Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037896] server connected, pipe [24:7567846738496265609:3787], now have 1 active actors on pipe
2025-11-01T19:50:27.218586Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.218613Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.218636Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.220401Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037896] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.229399Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037896] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.238000Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.238044Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.238063Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.318899Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.318943Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.318967Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.330694Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037897][] pipe [24:7567846738496265611:3788] connected; active server actors: 1
2025-11-01T19:50:27.331263Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037897][topic2] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:27.338936Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.338981Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.339002Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.346453Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037897][topic2] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037897
2025-11-01T19:50:27.346663Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037897][topic2] BALANCER INIT DONE for topic2: (0, 72075186224037896) 
2025-11-01T19:50:27.355430Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037896] server connected, pipe [24:7567846738496265650:2530], now have 1 active actors on pipe
2025-11-01T19:50:27.356930Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037897][topic2] TEvClientConnected TabletId 72075186224037896, NodeId 25, Generation 1
2025-11-01T19:50:27.365575Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037896] server connected, pipe [24:7567846738496265683:3840], now have 1 active actors on pipe
2025-11-01T19:50:27.366658Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037896] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.373638Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:128: HandleClustersUpdate
2025-11-01T19:50:27.373683Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:130: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-11-01T19:50:27.376233Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715682. Ctx: { TraceId: 01k90fh82wfcxg9ew9pgp683dw, Database: , SessionId: ydb://session/3?node_id=24&id=MTk1YWYzMTQtY2MwNTY4MTktZWI3MWY1ZDAtOGNjYzRjNGU=, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
2025-11-01T19:50:27.393186Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037896] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.394654Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic2:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:27.394729Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037896][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:27.395199Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic2:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:27.395560Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037896][Partition][0][StateInit] bootstrapping 0 [25:7567846737971058083:2410]
2025-11-01T19:50:27.400739Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account--topic2:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:27.400789Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc1--account--topic2:0:Initializer] Initializing completed.
2025-11-01T19:50:27.400829Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037896][Partition][0][StateInit] init complete for topic 'rt3.dc1--account--topic2' partition 0 generation 1 [25:7567846737971058083:2410]
2025-11-01T19:50:27.400869Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037896][Partition][0][StateInit] SYNC INIT topic rt3.dc1--account--topic2 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:27.400923Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037896][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:27.404500Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037896][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:27.404580Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.404808Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.404839Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037896][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:27.404878Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037896][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:27.404904Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.404930Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.404954Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037896][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:27.405004Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037896][Partition][0][StateIdle] Topic 'rt3.dc1--account--topic2' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:27.405023Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037896][Partition][0][StateIdle] Topic 'rt3.dc1--account--topic2' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:27.405080Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037896][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:27.405719Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037896] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.405911Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037896][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:27.414239Z node 25 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:128: HandleClustersUpdate
2025-11-01T19:50:27.414267Z node 25 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:130: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-11-01T19:50:27.416207Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037896] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.416472Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037896][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026627403, TxId 281474976715680
2025-11-01T19:50:27.416515Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.416540Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.416891Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.417327Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037896][PQCacheProxy]CacheProxy. Passthrough write request to KV
===Query complete
2025-11-01T19:50:27.420736Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.420780Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.420804Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.423985Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037896][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:27.424483Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037896][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:27.424747Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037896][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:27.424782Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.424809Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.424836Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.424887Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037896][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:27.425816Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037896] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 2097152 BurstSize: 2097152 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: "topic2" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "account@account" Ident: "account@account" Topic: "topic2" DC: "dc1" FormatVersion: 0 Codecs { } TopicPath: "/Root/LbCommunal/account/topic2" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } FederationAccount: "account" AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:27.426009Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037896] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:27.427383Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037896] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.439126Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037896] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.439313Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037896] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.439934Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.439960Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.439983Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
Create topic result: 1 
CreateTopicNoLegacy: /Root/LbCommunal/account/topic2-mirrored-from-dc2
2025-11-01T19:50:27.450113Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037896] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
Create topic: /Root/LbCommunal/account/topic2-mirrored-from-dc2
AddTopic: /Root/LbCommunal/account/topic2-mirrored-from-dc2
===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 = /Root/LbCommunal/account/topic2-mirrored-from-dc2, dc = unknown
2025-11-01T19:50:27.474691Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:27.506886Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.506933Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.506955Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.526382Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037899][] pipe [24:7567846738496265801:3920] connected; active server actors: 1
2025-11-01T19:50:27.526856Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037899][topic2-mirrored-from-dc2] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:27.525872Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.525918Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.525941Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.527861Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037899][topic2-mirrored-from-dc2] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037899
2025-11-01T19:50:27.529786Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037899][topic2-mirrored-from-dc2] BALANCER INIT DONE for topic2-mirrored-from-dc2: (0, 72075186224037898) 
2025-11-01T19:50:27.540458Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037898] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:27.543197Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.543248Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.543274Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.545643Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037898] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:27.546033Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037898] no config, start with empty partitions and default config
2025-11-01T19:50:27.546285Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037898] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:27.546352Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037898] doesn't have tx writes info
2025-11-01T19:50:27.547090Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037898] server connected, pipe [24:7567846738496265799:3919], now have 1 active actors on pipe
2025-11-01T19:50:27.547148Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037898] server connected, pipe [24:7567846738496265822:2552], now have 1 active actors on pipe
2025-11-01T19:50:27.547627Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037899][topic2-mirrored-from-dc2] TEvClientConnected TabletId 72075186224037898, NodeId 25, Generation 1
2025-11-01T19:50:27.549992Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037898] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.558969Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037898] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.572195Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037898] server connected, pipe [24:7567846738496265857:3966], now have 1 active actors on pipe
2025-11-01T19:50:27.573147Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037898] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.578257Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037898] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.579871Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic2:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:27.579964Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037898][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:27.580425Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic2:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:27.580836Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037898][Partition][0][StateInit] bootstrapping 0 [25:7567846737971058211:2418]
2025-11-01T19:50:27.590381Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account--topic2:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:27.590434Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc2--account--topic2:0:Initializer] Initializing completed.
2025-11-01T19:50:27.590475Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037898][Partition][0][StateInit] init complete for topic 'rt3.dc2--account--topic2' partition 0 generation 1 [25:7567846737971058211:2418]
2025-11-01T19:50:27.590519Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037898][Partition][0][StateInit] SYNC INIT topic rt3.dc2--account--topic2 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:27.590579Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037898][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:27.593926Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037898][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:27.593994Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.594201Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.594232Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037898][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:27.594266Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037898][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:27.594292Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.594322Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.594347Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037898][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:27.594399Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037898][Partition][0][StateIdle] Topic 'rt3.dc2--account--topic2' partition 0 user user readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:27.594421Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037898][Partition][0][StateIdle] Topic 'rt3.dc2--account--topic2' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:27.594481Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037898][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:27.598549Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037898] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.598831Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037898][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:27.607355Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037898] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.607596Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037898][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026627613, TxId 281474976715683
2025-11-01T19:50:27.607634Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.607657Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.608007Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.608078Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.608106Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.608131Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.608521Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037898][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:27.612903Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037898][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:27.613379Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037898][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:27.613642Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037898][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:27.613681Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.613711Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.613739Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.613791Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037898][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:27.614516Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037898] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 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: "topic2-mirrored-from-dc2" Version: 0 LocalDC: false RequireAuthWrite: true RequireAuthRead: true Producer: "account@account" Ident: "account@account" Topic: "topic2" DC: "dc2" FormatVersion: 0 Codecs { } TopicPath: "/Root/LbCommunal/account/topic2-mirrored-from-dc2" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } FederationAccount: "account" AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "user" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:27.614700Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037898] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:27.615376Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037898] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.626190Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.626237Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.626273Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.627219Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037898] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.627372Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037898] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:27.642686Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037898] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:27.643429Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.643457Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.643482Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.695231Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.695288Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.695326Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.711006Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.711064Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.711091Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.726445Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.726499Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.726524Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.743827Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.743877Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.743901Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.797232Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.797298Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.797340Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.812331Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.812378Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.812399Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.826823Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.826885Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.826910Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.840790Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715684. Ctx: { TraceId: 01k90fh8dg566cp3gm5ap3anqf, Database: , SessionId: ydb://session/3?node_id=24&id=NGU0MDBjYmYtNDRhNTFhNGItZWQyYTQ2YTItMTQ1ZTZjNTE=, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
2025-11-01T19:50:27.844389Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.844441Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.844479Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
===Query complete
Create topic result: 1 
2025-11-01T19:50:27.890476Z node 24 :TX_PROXY ERROR: schemereq.cpp:593: Actor# [24:7567846738496265921:4015] txid# 281474976715685, issues: { message: "Check failed: path: \'/Root/LbCommunal\', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 15], type: EPathTypeDir, state: EPathStateNoChanges)" severity: 1 }
Error 1: Check failed: path: '/Root/LbCommunal', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 15], type: EPathTypeDir, state: EPathStateNoChanges)
2025-11-01T19:50:27.897430Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.897482Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.897508Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
waiting...
2025-11-01T19:50:27.914088Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.914141Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.914169Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
CreateTopicNoLegacy: /Root/LbCommunal/account2/topic3
2025-11-01T19:50:27.927247Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.927286Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.927309Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
Create topic: /Root/LbCommunal/account2/topic3
AddTopic: /Root/LbCommunal/account2/topic3
===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 = /Root/LbCommunal/account2/topic3, dc = unknown
2025-11-01T19:50:27.944528Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.944578Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.944605Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:27.947246Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:27.992612Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037901][] pipe [24:7567846738496266032:4101] connected; active server actors: 1
2025-11-01T19:50:27.993069Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037901][topic3] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:27.994438Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037901][topic3] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037901
2025-11-01T19:50:27.996565Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037901][topic3] BALANCER INIT DONE for topic3: (0, 72075186224037900) 
2025-11-01T19:50:27.998751Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:27.998812Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:27.998836Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.010005Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037900] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:28.014652Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.014695Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.014716Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.015216Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037900] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:28.015568Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037900] no config, start with empty partitions and default config
2025-11-01T19:50:28.015628Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037900] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:28.015693Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037900] doesn't have tx writes info
2025-11-01T19:50:28.016006Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037900] server connected, pipe [24:7567846738496266053:2569], now have 1 active actors on pipe
2025-11-01T19:50:28.016050Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037900] server connected, pipe [24:7567846738496266029:4099], now have 1 active actors on pipe
2025-11-01T19:50:28.017086Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037900] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.017348Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037901][topic3] TEvClientConnected TabletId 72075186224037900, NodeId 25, Generation 1
2025-11-01T19:50:28.024531Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037900] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.028377Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.028426Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.028461Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.037215Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037900] server connected, pipe [24:7567846742791233387:4147], now have 1 active actors on pipe
2025-11-01T19:50:28.039275Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037900] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.045223Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037900] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.046621Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.046662Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.046699Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.046882Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account2--topic3:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:28.046964Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037900][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:28.047462Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account2--topic3:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:28.047879Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037900][Partition][0][StateInit] bootstrapping 0 [25:7567846742266025634:2426]
2025-11-01T19:50:28.052868Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc1--account2--topic3:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:28.052924Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc1--account2--topic3:0:Initializer] Initializing completed.
2025-11-01T19:50:28.052967Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037900][Partition][0][StateInit] init complete for topic 'rt3.dc1--account2--topic3' partition 0 generation 1 [25:7567846742266025634:2426]
2025-11-01T19:50:28.053016Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037900][Partition][0][StateInit] SYNC INIT topic rt3.dc1--account2--topic3 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:28.053073Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037900][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:28.055493Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037900][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:28.055566Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.055773Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.055796Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037900][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:28.055834Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037900][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:28.055863Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.055891Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.055918Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037900][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:28.055978Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037900][Partition][0][StateIdle] Topic 'rt3.dc1--account2--topic3' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:28.056034Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037900][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:28.056671Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037900] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.056871Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037900][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.064618Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037900] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.064834Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037900][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026628075, TxId 281474976715687
2025-11-01T19:50:28.064871Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.064893Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.065210Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.065644Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037900][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:28.071595Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037900][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:28.072073Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037900][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:28.072301Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037900][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:28.072337Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.072362Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.072388Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.072434Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037900][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.073248Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037900] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 2097152 BurstSize: 2097152 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: "topic3" Version: 0 LocalDC: true RequireAuthWrite: true RequireAuthRead: true Producer: "account2@account2" Ident: "account2@account2" Topic: "topic3" DC: "dc1" FormatVersion: 0 Codecs { } TopicPath: "/Root/LbCommunal/account2/topic3" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } FederationAccount: "account2" AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:28.073473Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037900] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:28.074169Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037900] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.083657Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037900] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.083806Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037900] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.089457Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037900] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.098659Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.098700Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.098723Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.115056Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.115106Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.115133Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.130901Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.130954Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.130975Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.146882Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.146925Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.146945Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.158940Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.158994Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.159021Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.175452Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715688. Ctx: { TraceId: 01k90fh8w7dc8960j3qypz2hy8, Database: , SessionId: ydb://session/3?node_id=24&id=NzY5MDRmYjUtYmVkNWUwODctNjUwZGVkOTMtYzk5YzExNjU=, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
2025-11-01T19:50:28.200040Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.200097Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.200125Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.215375Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.215432Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.215475Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
===Query complete
Create topic result: 1 
CreateTopicNoLegacy: /Root/LbCommunal/account2/topic3-mirrored-from-dc2
2025-11-01T19:50:28.233237Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.233291Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.233318Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.247338Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.247405Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.247433Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
Create topic: /Root/LbCommunal/account2/topic3-mirrored-from-dc2
2025-11-01T19:50:28.259543Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.259604Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.259629Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
AddTopic: /Root/LbCommunal/account2/topic3-mirrored-from-dc2
===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 = /Root/LbCommunal/account2/topic3-mirrored-from-dc2, dc = unknown
2025-11-01T19:50:28.273506Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:196: new Create topic request
2025-11-01T19:50:28.304527Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.304571Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.304595Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.318475Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.318515Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.318549Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.325737Z node 24 :PERSQUEUE_READ_BALANCER INFO: read_balancer__balancing.cpp:1655: [72075186224037903][] pipe [24:7567846742791233484:4220] connected; active server actors: 1
2025-11-01T19:50:28.326252Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer__balancing.cpp:1519: [72075186224037903][topic3-mirrored-from-dc2] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-01T19:50:28.329164Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:971: [72075186224037903][topic3-mirrored-from-dc2] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037903
2025-11-01T19:50:28.331094Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:140: [72075186224037903][topic3-mirrored-from-dc2] BALANCER INIT DONE for topic3-mirrored-from-dc2: (0, 72075186224037902) 
2025-11-01T19:50:28.334893Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.334940Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.334964Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.351895Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.351937Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.351961Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.359736Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.359786Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.359812Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.364511Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2960: [PQ: 72075186224037902] Handle TEvInterconnect::TEvNodeInfo
2025-11-01T19:50:28.368668Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2992: [PQ: 72075186224037902] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-01T19:50:28.369094Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:787: [PQ: 72075186224037902] no config, start with empty partitions and default config
2025-11-01T19:50:28.369154Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037902] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:28.369214Z node 25 :PERSQUEUE INFO: pq_impl.cpp:612: [PQ: 72075186224037902] doesn't have tx writes info
2025-11-01T19:50:28.370760Z node 24 :PERSQUEUE_READ_BALANCER DEBUG: read_balancer.cpp:404: [72075186224037903][topic3-mirrored-from-dc2] TEvClientConnected TabletId 72075186224037902, NodeId 25, Generation 1
2025-11-01T19:50:28.371641Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037902] server connected, pipe [24:7567846742791233521:2587], now have 1 active actors on pipe
2025-11-01T19:50:28.371685Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037902] server connected, pipe [24:7567846742791233483:4219], now have 1 active actors on pipe
2025-11-01T19:50:28.372421Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037902] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.379374Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037902] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.393731Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037902] server connected, pipe [24:7567846742791233560:4278], now have 1 active actors on pipe
2025-11-01T19:50:28.395967Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037902] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.401444Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037902] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.403008Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account2--topic3:0:Initializer] Start initializing step TInitConfigStep
2025-11-01T19:50:28.403098Z node 25 :PERSQUEUE DEBUG: partition.cpp:1312: [72075186224037902][Partition][0][StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-01T19:50:28.403583Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account2--topic3:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-01T19:50:28.403930Z node 25 :PERSQUEUE INFO: partition_init.cpp:1101: [72075186224037902][Partition][0][StateInit] bootstrapping 0 [25:7567846742266025758:2432]
2025-11-01T19:50:28.407030Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.407068Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.407088Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.413490Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:81: [rt3.dc2--account2--topic3:0:Initializer] Start initializing step TInitFieldsStep
2025-11-01T19:50:28.413544Z node 25 :PERSQUEUE DEBUG: partition_init.cpp:61: [rt3.dc2--account2--topic3:0:Initializer] Initializing completed.
2025-11-01T19:50:28.413582Z node 25 :PERSQUEUE INFO: partition.cpp:707: [72075186224037902][Partition][0][StateInit] init complete for topic 'rt3.dc2--account2--topic3' partition 0 generation 1 [25:7567846742266025758:2432]
2025-11-01T19:50:28.413642Z node 25 :PERSQUEUE DEBUG: partition.cpp:727: [72075186224037902][Partition][0][StateInit] SYNC INIT topic rt3.dc2--account2--topic3 partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-01T19:50:28.413693Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037902][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:28.415421Z node 25 :PERSQUEUE DEBUG: partition.cpp:4273: [72075186224037902][Partition][0][StateIdle] Process pending events. Count 1
2025-11-01T19:50:28.415468Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.415652Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.415673Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037902][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:28.415708Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037902][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:28.415731Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.415756Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.415779Z node 25 :PERSQUEUE DEBUG: partition.cpp:2318: [72075186224037902][Partition][0][StateIdle] Still pending for come commits
2025-11-01T19:50:28.415832Z node 25 :PERSQUEUE DEBUG: partition_read.cpp:923: [72075186224037902][Partition][0][StateIdle] Topic 'rt3.dc2--account2--topic3' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-01T19:50:28.415885Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:60: [72075186224037902][Partition][0][StateIdle] Process MLP pending events. Count 0
2025-11-01T19:50:28.416424Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037902] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.416608Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037902][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.421793Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.421834Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.421854Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.429149Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037902] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.429384Z node 25 :PERSQUEUE DEBUG: partition.cpp:1416: [72075186224037902][Partition][0][StateIdle] Handle TEvPQ::TEvTxCommit Step 1762026628432, TxId 281474976715689
2025-11-01T19:50:28.429424Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.429445Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.429751Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.430134Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037902][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:28.436431Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037902][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:28.436802Z node 25 :PERSQUEUE DEBUG: partition_mlp.cpp:83: [72075186224037902][Partition][0][StateIdle] Initializing MLP Consumers: 0
2025-11-01T19:50:28.437007Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037902][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:28.437044Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.437066Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.437087Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.437134Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037902][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.437799Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:398: [PQ: 72075186224037902] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 MaxSizeInPartition: 9223372036854775807 LifetimeSeconds: 64800 SourceIdLifetimeSeconds: 1382400 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: "topic3-mirrored-from-dc2" Version: 0 LocalDC: false RequireAuthWrite: true RequireAuthRead: true Producer: "account2@account2" Ident: "account2@account2" Topic: "topic3" DC: "dc2" FormatVersion: 0 Codecs { } TopicPath: "/Root/LbCommunal/account2/topic3-mirrored-from-dc2" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } FederationAccount: "account2" AllPartitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 Generation: 0 } MonitoringProjectId: ""
2025-11-01T19:50:28.437962Z node 25 :PERSQUEUE NOTICE: pq_impl.cpp:913: [PQ: 72075186224037902] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-01T19:50:28.438502Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037902] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.439135Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.439161Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.439183Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.452136Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.452178Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.452200Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.452519Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037902] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.452655Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:3570: [PQ: 72075186224037902] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-01T19:50:28.463044Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.463089Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.463110Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.463802Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:1045: [PQ: 72075186224037902] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-01T19:50:28.506723Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.506786Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.506807Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.507804Z node 24 :KQP_EXECUTER ERROR: kqp_planner.cpp:123: TxId: 281474976715690. Ctx: { TraceId: 01k90fh96178y3s4ngc32x8hq0, Database: , SessionId: ydb://session/3?node_id=24&id=YzJlYmM4MjYtNjg0OWI1MjctN2EwZTM2Yy0zY2E5YzBiOA==, PoolId: default, DatabaseId: /Root}. Database not set, use /Root
2025-11-01T19:50:28.515398Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.515442Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.515465Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.520547Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.520587Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.520610Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.545300Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.545347Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.545380Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
===Query complete
Create topic result: 1 
2025-11-01T19:50:28.552272Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.552322Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.552344Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.563753Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.563796Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.563818Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.610904Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.610952Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.610975Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.618914Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.618965Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.618987Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.622870Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.622916Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.622932Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.644552Z node 24 :FLAT_TX_SCHEMESHARD WARN: schemeshard__operation.cpp:183: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715691:1, at schemeshard:  72057594046644480, first GetDB called at:  (GetDB first called at /home/runner/actions_runner/_work/ydb/ydb/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:690)
2025-11-01T19:50:28.650196Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.650243Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.650265Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.655150Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.655189Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.655212Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.666972Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.667019Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.667044Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.711271Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.711319Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.711341Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.720008Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.720051Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.720072Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.725265Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.725306Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.725326Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.751678Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.751723Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.751744Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.759066Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.759103Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.759122Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.770899Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.770948Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.770971Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.815096Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.815146Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.815170Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.820996Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.821047Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.821070Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.831244Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.831297Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.831328Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.852124Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.852177Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.852197Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.860983Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.861021Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.861042Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.861953Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:176: new Commit Offset request
2025-11-01T19:50:28.862240Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:41: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 auth for : user
2025-11-01T19:50:28.862276Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:282: Handle describe topics
2025-11-01T19:50:28.862292Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:328: SendSchemeCacheRequest
2025-11-01T19:50:28.862347Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:355: send request for 1 topics, got 1 requests infly, db = "/Root/LbCommunal/account"
2025-11-01T19:50:28.867308Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:362: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName: /Root/LbCommunal/account DomainOwnerId: 0 Instant: 3 ResultSet [{ Path: Root/LbCommunal/account/topic2 TableId: [72057594046644480:17:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) Users: [] Groups: [] } }] }
2025-11-01T19:50:28.867469Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:385: Got describe topics SC response
2025-11-01T19:50:28.867512Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:131: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 Handle describe topics response
2025-11-01T19:50:28.867696Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:68: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 auth is DEAD
2025-11-01T19:50:28.867840Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:129: CommitOffset auth ok, got 1 topics
2025-11-01T19:50:28.867928Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:268: strict CommitOffset, partition 0 committing to position 0
2025-11-01T19:50:28.869048Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037896] server connected, pipe [24:7567846742791233752:2623], now have 1 active actors on pipe
2025-11-01T19:50:28.869498Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.869527Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.869547Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.869994Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:146: Handle TEvRequest topic: 'topic2' requestId: <none>
2025-11-01T19:50:28.870043Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2635: [PQ: 72075186224037896] got client message batch for topic 'rt3.dc1--account--topic2' partition 0
2025-11-01T19:50:28.870128Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.870164Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.870183Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037896][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:28.870262Z node 25 :PERSQUEUE DEBUG: partition.cpp:3666: [72075186224037896][Partition][0][StateIdle] Topic 'rt3.dc1--account--topic2' partition 0 user user offset is set to 0 (startOffset 0) session 
2025-11-01T19:50:28.870290Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.870483Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037896][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:28.874888Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037896][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:28.875022Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037896][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:28.875069Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.875094Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.875118Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.875169Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037896][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.875211Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:181: Answer ok topic: 'topic2' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-01T19:50:28.875614Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:231: CommitOffset, commit done.
2025-11-01T19:50:28.876724Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2746: [PQ: 72075186224037896] server disconnected, pipe [24:7567846742791233752:2623] destroyed
{ operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.Topic.CommitOffsetResult" } } }
2025-11-01T19:50:28.884535Z node 24 :PQ_READ_PROXY DEBUG: grpc_pq_schema.cpp:176: new Commit Offset request
2025-11-01T19:50:28.884741Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:41: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 auth for : user
2025-11-01T19:50:28.884777Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:282: Handle describe topics
2025-11-01T19:50:28.884796Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:328: SendSchemeCacheRequest
2025-11-01T19:50:28.884870Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:355: send request for 1 topics, got 1 requests infly, db = "/Root/LbCommunal/account"
2025-11-01T19:50:28.887416Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:362: Handle SchemeCache response: result# { ErrorCount: 0 DatabaseName: /Root/LbCommunal/account DomainOwnerId: 0 Instant: 4 ResultSet [{ Path: Root/LbCommunal/account/topic2-mirrored-from-dc2 TableId: [72057594046644480:18:0] RequestType: ByPath Operation: OpList RedirectRequired: true ShowPrivatePath: true SyncVersion: true Status: Ok Kind: KindTopic DomainInfo { DomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] ResourcesDomainKey: [OwnerId: 72057594046644480, LocalPathId: 1] Params { Version: 1 PlanResolution: 7 Coordinators: 72057594046316545 TimeCastBucketsPerMediator: 2 Mediators: 72057594046382081 } ServerlessComputeResourcesMode: (empty maybe) Users: [] Groups: [] } }] }
2025-11-01T19:50:28.887566Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:385: Got describe topics SC response
2025-11-01T19:50:28.887607Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:131: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 Handle describe topics response
2025-11-01T19:50:28.887771Z node 24 :PQ_READ_PROXY DEBUG: read_init_auth_actor.cpp:68: session cookie 0 consumer shared/user session read_info:ipv6:[::1]:56758 auth is DEAD
2025-11-01T19:50:28.887900Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:129: CommitOffset auth ok, got 1 topics
2025-11-01T19:50:28.887951Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:268: strict CommitOffset, partition 0 committing to position 0
2025-11-01T19:50:28.893063Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2721: [PQ: 72075186224037898] server connected, pipe [24:7567846742791233764:2628], now have 1 active actors on pipe
2025-11-01T19:50:28.893192Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:146: Handle TEvRequest topic: 'topic2-mirrored-from-dc2' requestId: <none>
2025-11-01T19:50:28.893237Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2635: [PQ: 72075186224037898] got client message batch for topic 'rt3.dc2--account--topic2' partition 0
2025-11-01T19:50:28.893330Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.893371Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.893393Z node 25 :PERSQUEUE DEBUG: partition.cpp:2302: [72075186224037898][Partition][0][StateIdle] Batch completed (1)
2025-11-01T19:50:28.893476Z node 25 :PERSQUEUE DEBUG: partition.cpp:3666: [72075186224037898][Partition][0][StateIdle] Topic 'rt3.dc2--account--topic2' partition 0 user user offset is set to 0 (startOffset 0) session 
2025-11-01T19:50:28.893506Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.893747Z node 25 :PERSQUEUE DEBUG: read.h:275: [72075186224037898][PQCacheProxy]CacheProxy. Passthrough write request to KV
2025-11-01T19:50:28.905467Z node 24 :PQ_READ_PROXY DEBUG: commit_offset_actor.cpp:231: CommitOffset, commit done.
{ 2025-11-01T19:50:28.904775Z node 25 :PERSQUEUE DEBUG: partition.cpp:2116: [72075186224037898][Partition][0][StateIdle] Received TEvKeyValue::TEvResponse
2025-11-01T19:50:28.904895Z node 25 :PERSQUEUE DEBUG: partition_write.cpp:574: [72075186224037898][Partition][0][StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-01T19:50:28.904945Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
operation { ready: true status: SUCCESS result { type_url: "type.googleapis.com/Ydb.Topic.CommitOffsetResult" } } }
2025-11-01T19:50:28.904974Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.904997Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.905046Z node 25 :PERSQUEUE DEBUG: partition_compaction.cpp:183: [72075186224037898][Partition][0][StateIdle] No data for blobs compaction
2025-11-01T19:50:28.905091Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:181: Answer ok topic: 'topic2-mirrored-from-dc2' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-01T19:50:28.910801Z node 25 :PERSQUEUE DEBUG: pq_impl.cpp:2746: [PQ: 72075186224037898] server disconnected, pipe [24:7567846742791233764:2628] destroyed
2025-11-01T19:50:28.919021Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.919067Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.919087Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.925748Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.925788Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.925807Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.934961Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.935008Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.935029Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.957862Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.957901Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.957923Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.967375Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.967420Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.967441Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:28.974952Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:28.975004Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:28.975030Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.018970Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037898][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.019011Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037898][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.019033Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037898][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.023867Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037902][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.023903Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037902][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.023923Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037902][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.034989Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037896][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.035033Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037896][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.035055Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037896][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.046423Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:128: HandleClustersUpdate
2025-11-01T19:50:29.046452Z node 24 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:130: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-11-01T19:50:29.057849Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037894][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.057893Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037894][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.057914Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037894][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.071468Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037892][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.071513Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037892][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.071537Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037892][Partition][0][StateIdle] Try persist
2025-11-01T19:50:29.077024Z node 25 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:128: HandleClustersUpdate
2025-11-01T19:50:29.077064Z node 25 :PQ_METACACHE DEBUG: msgbus_server_pq_metacache.cpp:130: HandleClustersUpdate LocalCluster !LocalCluster.empty()
2025-11-01T19:50:29.077134Z node 25 :PERSQUEUE DEBUG: partition.cpp:2289: [72075186224037900][Partition][0][StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-01T19:50:29.077163Z node 25 :PERSQUEUE DEBUG: partition.cpp:2298: [72075186224037900][Partition][0][StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-01T19:50:29.077186Z node 25 :PERSQUEUE DEBUG: partition.cpp:2321: [72075186224037900][Partition][0][StateIdle] Try persist
