2025-11-05T13:43:34.290023Z node 8 :METADATA_PROVIDER WARN: fline=table_exists.cpp:54;actor=TTableExistsActor;event=undelivered;self_id=[8:7569236536993125150:2148];send_to=[0:7307199536658146131:7762515];
2025-11-05T13:43:34.290157Z node 8 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=scheme_cache_undelivered_message;
2025-11-05T13:43:34.299049Z node 8 :PQ_READ_PROXY DEBUG: Direct read cache: : Created
test_client.cpp: SetPath # /home/runner/.ya/build/build_root/4xc1/003f58/r3tmp/tmpotDof0/pdisk_1.dat
2025-11-05T13:43:34.306113Z node 8 :IMPORT WARN: Table profiles were not loaded
2025-11-05T13:43:34.306281Z node 8 :CONFIGS_DISPATCHER ERROR: Notification cookie mismatch for subscription [8:7569236536993125030:2081] 1762350214288737 != 1762350214288740
TServer::EnableGrpc on GrpcPort 16345, node 8
2025-11-05T13:43:34.319022Z node 8 :NET_CLASSIFIER WARN: distributable config is empty, broken or outdated, will use file: /home/runner/.ya/build/build_root/4xc1/003f58/r3tmp/yandex6InjsY.tmp
2025-11-05T13:43:34.319039Z node 8 :NET_CLASSIFIER WARN: will try to initialize from file: /home/runner/.ya/build/build_root/4xc1/003f58/r3tmp/yandex6InjsY.tmp
2025-11-05T13:43:34.323347Z INFO: TTestServer started on Port 27981 GrpcPort 16345
2025-11-05T13:43:34.325230Z node 8 :NET_CLASSIFIER WARN: successfully initialized from file: /home/runner/.ya/build/build_root/4xc1/003f58/r3tmp/yandex6InjsY.tmp
2025-11-05T13:43:34.325298Z node 8 :NET_CLASSIFIER ERROR: got bad distributable configuration
TClient is connected to server localhost:27981
PQClient connected to localhost:16345
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-05T13:43:34.393379Z node 8 :HIVE WARN: HIVE#72057594037968897 Node(8, (0,0,0,0)) VolatileState: Unknown -> Disconnected
2025-11-05T13:43:34.393444Z node 8 :HIVE WARN: HIVE#72057594037968897 Node(8, (0,0,0,0)) VolatileState: Disconnected -> Connecting
2025-11-05T13:43:34.393853Z node 8 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpAlterSubDomain, opId: 281474976715657:0, at schemeshard:  72057594046644480
waiting...
2025-11-05T13:43:34.394311Z node 8 :HIVE WARN: HIVE#72057594037968897 Node(8, (0,0,0,0)) VolatileState: Connecting -> Connected
2025-11-05T13:43:34.395500Z node 8 :FLAT_TX_SCHEMESHARD WARN: NotifyTxCompletion, unknown transaction, txId: 281474976715657, at schemeshard: 72057594046644480
waiting...
2025-11-05T13:43:34.402482Z node 8 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715659:0, at schemeshard:  72057594046644480
waiting...
waiting...
waiting...
2025-11-05T13:43:34.651186Z node 8 :KQP_COMPILE_ACTOR ERROR: Compilation failed, self: [8:7569236536993125798:2316], 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-05T13:43:34.651600Z node 8 :KQP_SESSION WARN: SessionId: ydb://session/3?node_id=8&id=ODJiZDVmNWYtMWM0MGMyNWYtNTQ1OTVkYi1lY2U1YzhmZA==, ActorId: [8:7569236536993125795:2314], ActorState: ExecuteState, TraceId: 01k9a44bfq3m840fpek4kzv1rg, ReplyQueryCompileError, status SCHEME_ERROR remove tx with tx_id: 
2025-11-05T13:43:34.651703Z node 8 :PERSQUEUE_CLUSTER_TRACKER ERROR: failed to list clusters: { Response { QueryIssues { message: "Type annotation" issue_code: 1030 severity: 1 issues { position { row: 3 column: 16 } message: "At function: KiReadTable!" end_position { row: 3 column: 16 } severity: 1 issues { position { row: 3 column: 16 } message: "Cannot find table \'db.[/Root/PQ/Config/V2/Cluster]\' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions." end_position { row: 3 column: 16 } issue_code: 2003 severity: 1 } } } TxMeta { } } YdbStatus: SCHEME_ERROR ConsumedRu: 1 }
2025-11-05T13:43:34.654007Z node 8 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715662:0, at schemeshard:  72057594046644480
2025-11-05T13:43:34.662482Z node 8 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715663:0, at schemeshard:  72057594046644480
2025-11-05T13:43:34.682983Z node 8 :FLAT_TX_SCHEMESHARD WARN: Operation part proposed ok, but propose itself is undo unsafe, suboperation type: ESchemeOpCreateTable, opId: 281474976715664:0, at schemeshard:  72057594046644480
=== Init DC: UPSERT INTO `/Root/PQ/Config/V2/Cluster` (name, balancer, local, enabled, weight) VALUES ("dc1", "localhost", true, true, 1000), ("dc2", "dc2.logbroker.yandex.net", false, true, 1000);
=== CheckClustersList. Subcribe to ClusterTracker from [8:7569236536993126071:2562] 
2025-11-05T13:43:35.295256Z node 8 :TX_CONVEYOR ERROR: fline=service.h:53;problem=unexpected event for task executor;ev_type=NActors::TEvents::TEvWakeup;
2025-11-05T13:43:39.289406Z node 8 :METADATA_PROVIDER ERROR: fline=table_exists.cpp:59;actor=TTableExistsActor;event=timeout;self_id=[8:7569236536993125150:2148];send_to=[0:7307199536658146131:7762515];
2025-11-05T13:43:39.289484Z node 8 :METADATA_PROVIDER ERROR: fline=accessor_snapshot_base.cpp:69;action=cannot detect path existence;path=//Root/.metadata/initialization/migrations;error=timeout;
=== CheckClustersList. Ok
2025-11-05T13:43:39.925642Z :WriteToTopic_Demo_29 INFO: TTopicSdkTestSetup started
2025-11-05T13:43:39.945010Z node 8 :PQ_READ_PROXY DEBUG: new create topic request
2025-11-05T13:43:39.961559Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvInterconnect::TEvNodeInfo
2025-11-05T13:43:39.961737Z node 8 :PERSQUEUE_READ_BALANCER INFO: [72075186224037893][] pipe [8:7569236558467962863:2742] connected; active server actors: 1
2025-11-05T13:43:39.961807Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-05T13:43:39.962651Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-11-05T13:43:39.962713Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-05T13:43:39.962766Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] doesn't have tx info
2025-11-05T13:43:39.962770Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] PlanStep 0, PlanTxId 0, ExecStep 0, ExecTxId 0
2025-11-05T13:43:39.962773Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] no config, start with empty partitions and default config
2025-11-05T13:43:39.962778Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Txs.size=0, PlannedTxs.size=0
2025-11-05T13:43:39.962785Z node 8 :PERSQUEUE NOTICE: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T13:43:39.962798Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037892] doesn't have tx writes info
2025-11-05T13:43:39.962832Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-05T13:43:39.962854Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] BALANCER INIT DONE for test-topic: (0, 72075186224037892) 
2025-11-05T13:43:39.963257Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [8:7569236558467962862:2741], now have 1 active actors on pipe
2025-11-05T13:43:39.963430Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } TxId: 281474976715671 Config { TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 } } }
2025-11-05T13:43:39.963468Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] Propose TxId 281474976715671, WriteId (empty maybe)
2025-11-05T13:43:39.963474Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state UNKNOWN
2025-11-05T13:43:39.963477Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State UNKNOWN
2025-11-05T13:43:39.963483Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] schedule TEvProposeTransactionResult(PREPARED)
2025-11-05T13:43:39.963486Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from UNKNOWN to PREPARING
2025-11-05T13:43:39.963497Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715671
2025-11-05T13:43:39.963551Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] save tx TxId: 281474976715671 State: PREPARED MinStep: 1762350220001 MaxStep: 18446744073709551615 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { }
2025-11-05T13:43:39.963575Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:39.963720Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [8:7569236558467962905:2423], now have 1 active actors on pipe
2025-11-05T13:43:39.963819Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] TEvClientConnected TabletId 72075186224037892, NodeId 8, Generation 1
2025-11-05T13:43:39.963822Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] TEvClientConnected TabletId 72057594046644480, NodeId 8, Generation 2
2025-11-05T13:43:39.963981Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:39.963989Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARING
2025-11-05T13:43:39.963991Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State PREPARING
2025-11-05T13:43:39.963994Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from PREPARING to PREPARED
2025-11-05T13:43:39.964667Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPersQueue::TEvProposeTransactionAttach TabletId: 72075186224037892 TxId: 281474976715671
2025-11-05T13:43:39.964681Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [8:7569236558467962916:2771], now have 1 active actors on pipe
2025-11-05T13:43:39.964698Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvTxProcessing::TEvPlanStep Transactions { TxId: 281474976715671 AckTo { RawX1: 0 RawX2: 0 } } Step: 1762350220008 MediatorID: 72057594046382081 TabletID: 72075186224037892
2025-11-05T13:43:39.964704Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PREPARED
2025-11-05T13:43:39.964706Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State PREPARED
2025-11-05T13:43:39.964710Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from PREPARED to PLANNING
2025-11-05T13:43:39.964714Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] PlanStep 1762350220008, PlanTxId 281474976715671
2025-11-05T13:43:39.964719Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715671
2025-11-05T13:43:39.964790Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] save tx TxId: 281474976715671 State: PLANNED MinStep: 1762350220001 MaxStep: 18446744073709551615 Step: 1762350220008 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { }
2025-11-05T13:43:39.964808Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:39.974641Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:39.974666Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state PLANNING
2025-11-05T13:43:39.974669Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State PLANNING
2025-11-05T13:43:39.974674Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from PLANNING to PLANNED
2025-11-05T13:43:39.974679Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxQueue.size 1
2025-11-05T13:43:39.974684Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] New ExecStep 1762350220008, ExecTxId 281474976715671
2025-11-05T13:43:39.974963Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from PLANNED to CALCULATING
2025-11-05T13:43:39.974985Z node 8 :PERSQUEUE DEBUG: [test-topic:0:Initializer] Start initializing step TInitConfigStep
2025-11-05T13:43:39.974995Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T13:43:39.975095Z node 8 :PERSQUEUE DEBUG: [test-topic:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T13:43:39.975206Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 0, State: StateInit] bootstrapping 0 [8:7569236558467962922:2426]
2025-11-05T13:43:39.975469Z node 8 :PERSQUEUE DEBUG: [test-topic:0:Initializer] Initializing completed.
2025-11-05T13:43:39.975485Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037892, Partition: 0, State: StateInit] init complete for topic 'test-topic' partition 0 generation 1 [8:7569236558467962922:2426]
2025-11-05T13:43:39.975494Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateInit] SYNC INIT topic test-topic partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T13:43:39.975659Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Process pending events. Count 1
2025-11-05T13:43:39.975671Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:39.975695Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.975703Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T13:43:39.975705Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.975707Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.975709Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T13:43:39.975718Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Topic 'test-topic' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T13:43:39.975792Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762350220008, TxId 281474976715671, Partition 0
2025-11-05T13:43:39.975802Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] Handle TEvProposePartitionConfigResult
2025-11-05T13:43:39.975805Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] Partition responses 1/1
2025-11-05T13:43:39.975807Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATING
2025-11-05T13:43:39.975809Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State CALCULATING
2025-11-05T13:43:39.975812Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671 State CALCULATING FrontTxId 281474976715671
2025-11-05T13:43:39.975815Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-11-05T13:43:39.975820Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from CALCULATING to CALCULATED
2025-11-05T13:43:39.975825Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715671
2025-11-05T13:43:39.975945Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] save tx TxId: 281474976715671 State: CALCULATED MinStep: 1762350220001 MaxStep: 18446744073709551615 Step: 1762350220008 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { Partition { PartitionId: 0 } }
2025-11-05T13:43:39.975988Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:39.976367Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:39.976376Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state CALCULATED
2025-11-05T13:43:39.976378Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State CALCULATED
2025-11-05T13:43:39.976381Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671 State CALCULATED FrontTxId 281474976715671
2025-11-05T13:43:39.976383Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from CALCULATED to WAIT_RS
2025-11-05T13:43:39.976394Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] Send TEvTxProcessing::TEvReadSet to 0 receivers. Wait TEvTxProcessing::TEvReadSet from 0 senders.
2025-11-05T13:43:39.976397Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] HaveParticipantsDecision 1
2025-11-05T13:43:39.976405Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from WAIT_RS to EXECUTING
2025-11-05T13:43:39.976408Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 0, Expected 1
2025-11-05T13:43:39.976414Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762350220008, TxId 281474976715671
2025-11-05T13:43:39.976419Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.976421Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.976454Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.976498Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:39.977042Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] Handle TEvPQ::TEvTxCommitDone Step 1762350220008, TxId 281474976715671, Partition 0
2025-11-05T13:43:39.977050Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTING
2025-11-05T13:43:39.977051Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State EXECUTING
2025-11-05T13:43:39.977054Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671 State EXECUTING FrontTxId 281474976715671
2025-11-05T13:43:39.977056Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T13:43:39.977056Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Received 1, Expected 1
2025-11-05T13:43:39.977061Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId: 281474976715671 send TEvPersQueue::TEvProposeTransactionResult(COMPLETE)
2025-11-05T13:43:39.977062Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:39.977064Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.977070Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] complete TxId 281474976715671
2025-11-05T13:43:39.977153Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 }
2025-11-05T13:43:39.977174Z node 8 :PERSQUEUE NOTICE: [PQ: 72075186224037892] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T13:43:39.977182Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] delete partitions for TxId 281474976715671
2025-11-05T13:43:39.977184Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from EXECUTING to EXECUTED
2025-11-05T13:43:39.977187Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] write key for TxId 281474976715671
2025-11-05T13:43:39.977237Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] save tx TxId: 281474976715671 State: EXECUTED MinStep: 1762350220001 MaxStep: 18446744073709551615 Step: 1762350220008 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "test-topic" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/test-topic" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { Partition { PartitionId: 0 } }
2025-11-05T13:43:39.977263Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:39.977458Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:39.977468Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state EXECUTED
2025-11-05T13:43:39.977470Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State EXECUTED
2025-11-05T13:43:39.977472Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671 State EXECUTED FrontTxId 281474976715671
2025-11-05T13:43:39.977474Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TPersQueue::SendEvReadSetAckToSenders
2025-11-05T13:43:39.977476Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from EXECUTED to WAIT_RS_ACKS
2025-11-05T13:43:39.977480Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] PredicateAcks: 0/0
2025-11-05T13:43:39.977481Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] HaveAllRecipientsReceive 1, AllSupportivePartitionsHaveBeenDeleted 1
2025-11-05T13:43:39.977483Z node 8 :PQ_TX DEBUG: [TxId: 281474976715671] PredicateAcks: 0/0
2025-11-05T13:43:39.977485Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] add an TxId 281474976715671 to the list for deletion
2025-11-05T13:43:39.977488Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] TxId 281474976715671 moved from WAIT_RS_ACKS to DELETING
2025-11-05T13:43:39.977491Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] delete key for TxId 281474976715671
2025-11-05T13:43:39.977499Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:39.977797Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-05T13:43:39.977853Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-11-05T13:43:39.977928Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:39.977934Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Try execute txs with state DELETING
2025-11-05T13:43:39.977936Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] TxId 281474976715671, State DELETING
2025-11-05T13:43:39.977938Z node 8 :PQ_TX INFO: [PQ: 72075186224037892] delete TxId 281474976715671
2025-11-05T13:43:39.981632Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: try to update token
2025-11-05T13:43:39.981892Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-11-05T13:43:39.981899Z :INFO: [/Root] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:16345
2025-11-05T13:43:39.989613Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "test-topic" message_group_id: "src" }
2025-11-05T13:43:39.989919Z node 8 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-11-05T13:43:39.989936Z node 8 :PQ_WRITE_PROXY DEBUG: new session created cookie 1
2025-11-05T13:43:39.993757Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId:  grpc read done: success: 1 data: init_request { topic: "test-topic" message_group_id: "src" }
2025-11-05T13:43:39.993822Z node 8 :PQ_WRITE_PROXY INFO: session request cookie: 1 topic: "test-topic" message_group_id: "src" from ipv6:[::1]:53050
2025-11-05T13:43:39.993827Z node 8 :PQ_WRITE_PROXY INFO: write session:  cookie=1 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:53050 proto=v1  topic=test-topic durationSec=0
2025-11-05T13:43:39.993833Z node 8 :PQ_WRITE_PROXY INFO: init check schema
2025-11-05T13:43:39.995109Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId:  describe result for acl check
2025-11-05T13:43:39.995158Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint64; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `//Root/.metadata/TopicPartitionsMapping` WHERE Hash == $Hash AND Topic == $Topic AND ProducerId == $SourceId;
2025-11-05T13:43:39.995164Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64; DECLARE $SeqNo AS Uint64;
UPSERT INTO `//Root/.metadata/TopicPartitionsMapping` (Hash, Topic, ProducerId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2025-11-05T13:43:39.995167Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `//Root/.metadata/TopicPartitionsMapping` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND ProducerId = $SourceId AND Partition = $Partition;
2025-11-05T13:43:39.995182Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [8:7569236558467962967:2434] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=0
2025-11-05T13:43:39.995192Z node 8 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 1 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-11-05T13:43:39.995563Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server connected, pipe [8:7569236558467962970:2434], now have 1 active actors on pipe
2025-11-05T13:43:39.995575Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037892, NodeId 8, Generation: 1
2025-11-05T13:43:39.995619Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'test-topic' requestId: <none>
2025-11-05T13:43:39.995627Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'test-topic' partition 0
2025-11-05T13:43:39.995663Z node 8 :PERSQUEUE INFO: new Cookie src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0 generated for partition 0 topic 'test-topic' owner src
2025-11-05T13:43:39.995688Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:39.995693Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.995704Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:39.995717Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2025-11-05T13:43:39.995750Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'test-topic' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:39.995793Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'test-topic' requestId: <none>
2025-11-05T13:43:39.995795Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] got client message batch for topic 'test-topic' partition 0
2025-11-05T13:43:39.995812Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'test-topic' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:39.995830Z node 8 :PQ_WRITE_PROXY INFO: session inited cookie: 1 partition: 0 MaxSeqNo: 0 sessionId: src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0
2025-11-05T13:43:39.996891Z :INFO: [/Root] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762350219996 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T13:43:39.996923Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0" topic: "test-topic"
2025-11-05T13:43:39.997051Z :INFO: [/Root] MessageGroupId [src] SessionId [src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0] Write session: close. Timeout = 0 ms
2025-11-05T13:43:39.997065Z :INFO: [/Root] MessageGroupId [src] SessionId [src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0] Write session will now close
2025-11-05T13:43:39.997072Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0] Write session: aborting
2025-11-05T13:43:39.997274Z :INFO: [/Root] MessageGroupId [src] SessionId [src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0] Write session: gracefully shut down, all writes complete
2025-11-05T13:43:39.997280Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0] Write session: destroy
2025-11-05T13:43:39.997729Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 1 sessionId: src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0 grpc read done: success: 0 data: 
2025-11-05T13:43:39.997737Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0 grpc read failed
2025-11-05T13:43:39.997745Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0 grpc closed
2025-11-05T13:43:39.997749Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 1 sessionId: src|a7a87164-757ce9fa-4b57ec5b-26d14a15_0 is DEAD
2025-11-05T13:43:39.998009Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037892 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:39.998068Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892] server disconnected, pipe [8:7569236558467962970:2434] destroyed
2025-11-05T13:43:39.998080Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] TPartition::DropOwner.
2025-11-05T13:43:39.998088Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:39.998090Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.014485Z :WriteToTopic_Demo_29 INFO: Topic created
2025-11-05T13:43:40.026243Z node 8 :PQ_READ_PROXY DEBUG: new create topic request
2025-11-05T13:43:40.027882Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-05T13:43:40.027966Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-11-05T13:43:40.030427Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvInterconnect::TEvNodeInfo
2025-11-05T13:43:40.030562Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Registered with mediator time cast
2025-11-05T13:43:40.030695Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Transactions request. From tx_00000000000000000000, To tx_18446744073709551615
2025-11-05T13:43:40.030735Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] doesn't have tx info
2025-11-05T13:43:40.030743Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] PlanStep 0, PlanTxId 0, ExecStep 0, ExecTxId 0
2025-11-05T13:43:40.030746Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] no config, start with empty partitions and default config
2025-11-05T13:43:40.030750Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Txs.size=0, PlannedTxs.size=0
2025-11-05T13:43:40.030756Z node 8 :PERSQUEUE NOTICE: [PQ: 72075186224037894] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T13:43:40.030766Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894] doesn't have tx writes info
2025-11-05T13:43:40.074337Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.074357Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.078633Z node 8 :PERSQUEUE_READ_BALANCER INFO: [72075186224037895][] pipe [8:7569236562762930294:2807] connected; active server actors: 1
2025-11-05T13:43:40.078633Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930293:2806], now have 1 active actors on pipe
2025-11-05T13:43:40.078750Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] updating configuration. Deleted partitions []. Added partitions [0]
2025-11-05T13:43:40.078800Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } TxId: 281474976715672 Config { TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } Consumers { Name: "test-consumer" ReadFromTimestampsMs: 0 FormatVersion: 0 Codec { } ServiceType: "data-streams" Version: 0 } } }
2025-11-05T13:43:40.078868Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] Propose TxId 281474976715672, WriteId (empty maybe)
2025-11-05T13:43:40.078874Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state UNKNOWN
2025-11-05T13:43:40.078877Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State UNKNOWN
2025-11-05T13:43:40.078881Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] schedule TEvProposeTransactionResult(PREPARED)
2025-11-05T13:43:40.078886Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from UNKNOWN to PREPARING
2025-11-05T13:43:40.078896Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] write key for TxId 281474976715672
2025-11-05T13:43:40.078956Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] save tx TxId: 281474976715672 State: PREPARED MinStep: 1762350220022 MaxStep: 18446744073709551615 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { }
2025-11-05T13:43:40.078987Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.079352Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-11-05T13:43:40.079395Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] BALANCER INIT DONE for topic_A: (0, 72075186224037894) 
2025-11-05T13:43:40.079725Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930349:2449], now have 1 active actors on pipe
2025-11-05T13:43:40.079730Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.079742Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state PREPARING
2025-11-05T13:43:40.079744Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State PREPARING
2025-11-05T13:43:40.079748Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from PREPARING to PREPARED
2025-11-05T13:43:40.079776Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] TEvClientConnected TabletId 72057594046644480, NodeId 8, Generation 2
2025-11-05T13:43:40.079779Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] TEvClientConnected TabletId 72075186224037894, NodeId 8, Generation 1
2025-11-05T13:43:40.080255Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPersQueue::TEvProposeTransactionAttach TabletId: 72075186224037894 TxId: 281474976715672
2025-11-05T13:43:40.080269Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930358:2840], now have 1 active actors on pipe
2025-11-05T13:43:40.080288Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvTxProcessing::TEvPlanStep Transactions { TxId: 281474976715672 AckTo { RawX1: 0 RawX2: 0 } } Step: 1762350220127 MediatorID: 72057594046382081 TabletID: 72075186224037894
2025-11-05T13:43:40.080295Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state PREPARED
2025-11-05T13:43:40.080298Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State PREPARED
2025-11-05T13:43:40.080301Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from PREPARED to PLANNING
2025-11-05T13:43:40.080307Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] PlanStep 1762350220127, PlanTxId 281474976715672
2025-11-05T13:43:40.080312Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] write key for TxId 281474976715672
2025-11-05T13:43:40.080401Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] save tx TxId: 281474976715672 State: PLANNED MinStep: 1762350220022 MaxStep: 18446744073709551615 Step: 1762350220127 Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { }
2025-11-05T13:43:40.080426Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.080601Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.080609Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state PLANNING
2025-11-05T13:43:40.080610Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State PLANNING
2025-11-05T13:43:40.080613Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from PLANNING to PLANNED
2025-11-05T13:43:40.080616Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxQueue.size 1
2025-11-05T13:43:40.080620Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] New ExecStep 1762350220127, ExecTxId 281474976715672
2025-11-05T13:43:40.080777Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from PLANNED to CALCULATING
2025-11-05T13:43:40.080790Z node 8 :PERSQUEUE DEBUG: [topic_A:0:Initializer] Start initializing step TInitConfigStep
2025-11-05T13:43:40.080801Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateInit] HandleOnInit TEvPQ::TEvProposePartitionConfig
2025-11-05T13:43:40.080849Z node 8 :PERSQUEUE DEBUG: [topic_A:0:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T13:43:40.080937Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: 0, State: StateInit] bootstrapping 0 [8:7569236562762930365:2452]
2025-11-05T13:43:40.081128Z node 8 :PERSQUEUE DEBUG: [topic_A:0:Initializer] Initializing completed.
2025-11-05T13:43:40.081142Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: 0, State: StateInit] init complete for topic 'topic_A' partition 0 generation 1 [8:7569236562762930365:2452]
2025-11-05T13:43:40.081147Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateInit] SYNC INIT topic topic_A partitition 0 so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T13:43:40.081212Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Process pending events. Count 1
2025-11-05T13:43:40.081219Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.081236Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081250Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T13:43:40.081255Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081257Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081258Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Still pending for come commits
2025-11-05T13:43:40.081264Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Topic 'topic_A' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T13:43:40.081291Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPQ::TEvProposePartitionConfigResult Step 1762350220127, TxId 281474976715672, Partition 0
2025-11-05T13:43:40.081292Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] Handle TEvProposePartitionConfigResult
2025-11-05T13:43:40.081295Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] Partition responses 1/1
2025-11-05T13:43:40.081296Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state CALCULATING
2025-11-05T13:43:40.081297Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State CALCULATING
2025-11-05T13:43:40.081299Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672 State CALCULATING FrontTxId 281474976715672
2025-11-05T13:43:40.081301Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Received 1, Expected 1
2025-11-05T13:43:40.081303Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from CALCULATING to CALCULATED
2025-11-05T13:43:40.081306Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] write key for TxId 281474976715672
2025-11-05T13:43:40.081361Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] save tx TxId: 281474976715672 State: CALCULATED MinStep: 1762350220022 MaxStep: 18446744073709551615 Step: 1762350220127 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { Partition { PartitionId: 0 } }
2025-11-05T13:43:40.081376Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.081645Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.081653Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state CALCULATED
2025-11-05T13:43:40.081655Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State CALCULATED
2025-11-05T13:43:40.081657Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672 State CALCULATED FrontTxId 281474976715672
2025-11-05T13:43:40.081662Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from CALCULATED to WAIT_RS
2025-11-05T13:43:40.081674Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] Send TEvTxProcessing::TEvReadSet to 0 receivers. Wait TEvTxProcessing::TEvReadSet from 0 senders.
2025-11-05T13:43:40.081676Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] HaveParticipantsDecision 1
2025-11-05T13:43:40.081689Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from WAIT_RS to EXECUTING
2025-11-05T13:43:40.081695Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Received 0, Expected 1
2025-11-05T13:43:40.081705Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Handle TEvPQ::TEvTxCommit Step 1762350220127, TxId 281474976715672
2025-11-05T13:43:40.081709Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081711Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081736Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.081775Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.082216Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T13:43:40.082223Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] Handle TEvPQ::TEvTxCommitDone Step 1762350220127, TxId 281474976715672, Partition 0
2025-11-05T13:43:40.082225Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state EXECUTING
2025-11-05T13:43:40.082227Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State EXECUTING
2025-11-05T13:43:40.082227Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.082228Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672 State EXECUTING FrontTxId 281474976715672
2025-11-05T13:43:40.082229Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.082231Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Received 1, Expected 1
2025-11-05T13:43:40.082235Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId: 281474976715672 send TEvPersQueue::TEvProposeTransactionResult(COMPLETE)
2025-11-05T13:43:40.082246Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] complete TxId 281474976715672
2025-11-05T13:43:40.082297Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Apply new config PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 }
2025-11-05T13:43:40.082319Z node 8 :PERSQUEUE NOTICE: [PQ: 72075186224037894] disable metering: reason# billing is not enabled in BillingMeteringConfig
2025-11-05T13:43:40.082331Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] delete partitions for TxId 281474976715672
2025-11-05T13:43:40.082337Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from EXECUTING to EXECUTED
2025-11-05T13:43:40.082340Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] write key for TxId 281474976715672
2025-11-05T13:43:40.082393Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] save tx TxId: 281474976715672 State: EXECUTED MinStep: 1762350220022 MaxStep: 18446744073709551615 Step: 1762350220127 Predicate: true Kind: KIND_CONFIG TabletConfig { PartitionConfig { MaxCountInPartition: 2147483647 LifetimeSeconds: 3600 SourceIdLifetimeSeconds: 1382400 WriteSpeedInBytesPerSecond: 1048576 BurstSize: 1048576 TotalPartitions: 1 ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } ExplicitChannelProfiles { PoolKind: "test" } SourceIdMaxCounts: 6000000 } PartitionIds: 0 TopicName: "topic_A" Version: 0 RequireAuthWrite: true RequireAuthRead: true FormatVersion: 0 Codecs { } TopicPath: "/Root/topic_A" YcCloudId: "" YcFolderId: "" YdbDatabaseId: "" YdbDatabasePath: "/Root" Partitions { PartitionId: 0 Status: Active CreateVersion: 1 TabletId: 0 } ReadRuleGenerations: 0 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 } } BootstrapConfig { } SourceActor { RawX1: 7569236536993125374 RawX2: 34359740515 } Partitions { Partition { PartitionId: 0 } }
2025-11-05T13:43:40.082424Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.082918Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.082928Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state EXECUTED
2025-11-05T13:43:40.082930Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State EXECUTED
2025-11-05T13:43:40.082940Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672 State EXECUTED FrontTxId 281474976715672
2025-11-05T13:43:40.082943Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TPersQueue::SendEvReadSetAckToSenders
2025-11-05T13:43:40.082946Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from EXECUTED to WAIT_RS_ACKS
2025-11-05T13:43:40.082949Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] PredicateAcks: 0/0
2025-11-05T13:43:40.082951Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] HaveAllRecipientsReceive 1, AllSupportivePartitionsHaveBeenDeleted 1
2025-11-05T13:43:40.082952Z node 8 :PQ_TX DEBUG: [TxId: 281474976715672] PredicateAcks: 0/0
2025-11-05T13:43:40.082955Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] add an TxId 281474976715672 to the list for deletion
2025-11-05T13:43:40.082957Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715672 moved from WAIT_RS_ACKS to DELETING
2025-11-05T13:43:40.082963Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] delete key for TxId 281474976715672
2025-11-05T13:43:40.082972Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.083052Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037895
2025-11-05T13:43:40.083231Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037893][test-topic] Discovered subdomain [OwnerId: 72057594046644480, LocalPathId: 1] state, outOfSpace = 0 at RB 72075186224037893
2025-11-05T13:43:40.083251Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Registered with mediator time cast
2025-11-05T13:43:40.083280Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.083283Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Try execute txs with state DELETING
2025-11-05T13:43:40.083285Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxId 281474976715672, State DELETING
2025-11-05T13:43:40.083288Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] delete TxId 281474976715672
2025-11-05T13:43:40.083327Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037892] Registered with mediator time cast
2025-11-05T13:43:40.083884Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: try to update token
2025-11-05T13:43:40.084183Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-11-05T13:43:40.084193Z :INFO: [/Root] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:16345
2025-11-05T13:43:40.085750Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "topic_A" message_group_id: "src" }
2025-11-05T13:43:40.086018Z node 8 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-11-05T13:43:40.086029Z node 8 :PQ_WRITE_PROXY DEBUG: new session created cookie 2
2025-11-05T13:43:40.086135Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 2 sessionId:  grpc read done: success: 1 data: init_request { topic: "topic_A" message_group_id: "src" }
2025-11-05T13:43:40.086154Z node 8 :PQ_WRITE_PROXY INFO: session request cookie: 2 topic: "topic_A" message_group_id: "src" from ipv6:[::1]:53050
2025-11-05T13:43:40.086159Z node 8 :PQ_WRITE_PROXY INFO: write session:  cookie=2 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:53050 proto=v1  topic=topic_A durationSec=0
2025-11-05T13:43:40.086164Z node 8 :PQ_WRITE_PROXY INFO: init check schema
2025-11-05T13:43:40.086645Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId:  describe result for acl check
2025-11-05T13:43:40.086683Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint64; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `//Root/.metadata/TopicPartitionsMapping` WHERE Hash == $Hash AND Topic == $Topic AND ProducerId == $SourceId;
2025-11-05T13:43:40.086688Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64; DECLARE $SeqNo AS Uint64;
UPSERT INTO `//Root/.metadata/TopicPartitionsMapping` (Hash, Topic, ProducerId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2025-11-05T13:43:40.086690Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `//Root/.metadata/TopicPartitionsMapping` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND ProducerId = $SourceId AND Partition = $Partition;
2025-11-05T13:43:40.086703Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [8:7569236562762930400:2460] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=0
2025-11-05T13:43:40.086707Z node 8 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 2 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-11-05T13:43:40.086859Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 8, Generation: 1
2025-11-05T13:43:40.086875Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930403:2460], now have 1 active actors on pipe
2025-11-05T13:43:40.086883Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.086890Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.086925Z node 8 :PERSQUEUE INFO: new Cookie src|c6953d21-47ccf34d-e1a2734e-ee32e394_0 generated for partition 0 topic 'topic_A' owner src
2025-11-05T13:43:40.086945Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.086950Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.086981Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.086991Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2025-11-05T13:43:40.087012Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.087164Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.087172Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.087189Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.087207Z node 8 :PQ_WRITE_PROXY INFO: session inited cookie: 2 partition: 0 MaxSeqNo: 0 sessionId: src|c6953d21-47ccf34d-e1a2734e-ee32e394_0
2025-11-05T13:43:40.087434Z :INFO: [/Root] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762350220087 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T13:43:40.087461Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|c6953d21-47ccf34d-e1a2734e-ee32e394_0" topic: "topic_A"
2025-11-05T13:43:40.087573Z :INFO: [/Root] MessageGroupId [src] SessionId [src|c6953d21-47ccf34d-e1a2734e-ee32e394_0] Write session: close. Timeout = 0 ms
2025-11-05T13:43:40.087585Z :INFO: [/Root] MessageGroupId [src] SessionId [src|c6953d21-47ccf34d-e1a2734e-ee32e394_0] Write session will now close
2025-11-05T13:43:40.087592Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|c6953d21-47ccf34d-e1a2734e-ee32e394_0] Write session: aborting
2025-11-05T13:43:40.087762Z :INFO: [/Root] MessageGroupId [src] SessionId [src|c6953d21-47ccf34d-e1a2734e-ee32e394_0] Write session: gracefully shut down, all writes complete
2025-11-05T13:43:40.087768Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|c6953d21-47ccf34d-e1a2734e-ee32e394_0] Write session: destroy
2025-11-05T13:43:40.087900Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 2 sessionId: src|c6953d21-47ccf34d-e1a2734e-ee32e394_0 grpc read done: success: 0 data: 
2025-11-05T13:43:40.087910Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId: src|c6953d21-47ccf34d-e1a2734e-ee32e394_0 grpc read failed
2025-11-05T13:43:40.087917Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId: src|c6953d21-47ccf34d-e1a2734e-ee32e394_0 grpc closed
2025-11-05T13:43:40.087919Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 2 sessionId: src|c6953d21-47ccf34d-e1a2734e-ee32e394_0 is DEAD
2025-11-05T13:43:40.088152Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:40.088204Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server disconnected, pipe [8:7569236562762930403:2460] destroyed
2025-11-05T13:43:40.088212Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::DropOwner.
2025-11-05T13:43:40.088217Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.088218Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.100774Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-11-05T13:43:40.100998Z :INFO: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-11-05T13:43:40.101010Z :TRACE: [/Root] TRACE_EVENT DescribePartitionRequest  path=/Root/topic_A partition_id=0
2025-11-05T13:43:40.101041Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-11-05T13:43:40.101765Z node 8 :PQ_READ_PROXY DEBUG: new Describe partition request
2025-11-05T13:43:40.101810Z node 8 :PQ_READ_PROXY DEBUG: TDescribePartitionActor for request path: "/Root/topic_A"
include_location: true
2025-11-05T13:43:40.101824Z node 8 :PQ_READ_PROXY DEBUG: TDescribePartitionActor[8:7569236562762930412:2466]: Bootstrap
2025-11-05T13:43:40.102376Z node 8 :PQ_READ_PROXY DEBUG: DescribeTopicImpl [8:7569236562762930412:2466]: Request location
2025-11-05T13:43:40.102496Z node 8 :PERSQUEUE_READ_BALANCER INFO: [72075186224037895][topic_A] pipe [8:7569236562762930421:2467] connected; active server actors: 1
2025-11-05T13:43:40.102515Z node 8 :PERSQUEUE_READ_BALANCER DEBUG: [72075186224037895][topic_A] addPartitionToResponse tabletId 72075186224037894, partitionId 0, NodeId 8, Generation 1
2025-11-05T13:43:40.102534Z node 8 :PQ_READ_PROXY DEBUG: DescribeTopicImpl [8:7569236562762930412:2466]: Got location
2025-11-05T13:43:40.102576Z node 8 :PERSQUEUE_READ_BALANCER INFO: [72075186224037895][topic_A] pipe [8:7569236562762930421:2467] disconnected; active server actors: 1
2025-11-05T13:43:40.102581Z node 8 :PERSQUEUE_READ_BALANCER INFO: [72075186224037895][topic_A] pipe [8:7569236562762930421:2467] disconnected no session
2025-11-05T13:43:40.102904Z :INFO: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 8
    generation: 1
  }
}
2025-11-05T13:43:40.102920Z :TRACE: [/Root] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=8 pl_generation=1
2025-11-05T13:43:40.102928Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 8 exists in the endpoint pool.
2025-11-05T13:43:40.102935Z :TRACE: [/Root] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=8 Generation=1
2025-11-05T13:43:40.102939Z :INFO: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 8
2025-11-05T13:43:40.103194Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-11-05T13:43:40.103219Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-11-05T13:43:40.103222Z :TRACE: [/Root] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-11-05T13:43:40.103307Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-05T13:43:40.103377Z node 8 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-11-05T13:43:40.103388Z node 8 :PQ_WRITE_PROXY DEBUG: new session created cookie 3
2025-11-05T13:43:40.103540Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 3 sessionId:  grpc read done: success: 1 data: init_request { path: "topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } }
2025-11-05T13:43:40.103568Z node 8 :PQ_WRITE_PROXY INFO: session request cookie: 3 path: "topic_A" producer_id: "test-message_group_id" partition_with_generation { generation: 1 } from ipv6:[::1]:53050
2025-11-05T13:43:40.103572Z node 8 :PQ_WRITE_PROXY INFO: write session:  cookie=3 sessionId= userAgent="topic server" ip=ipv6:[::1]:53050 proto=topic  topic=topic_A durationSec=0
2025-11-05T13:43:40.103575Z node 8 :PQ_WRITE_PROXY INFO: init check schema
2025-11-05T13:43:40.103587Z node 8 :PQ_WRITE_PROXY INFO: session to partition: 0, generation: 1
2025-11-05T13:43:40.103859Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 3 sessionId:  describe result for acl check
2025-11-05T13:43:40.103908Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint64; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `//Root/.metadata/TopicPartitionsMapping` WHERE Hash == $Hash AND Topic == $Topic AND ProducerId == $SourceId;
2025-11-05T13:43:40.103914Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64; DECLARE $SeqNo AS Uint64;
UPSERT INTO `//Root/.metadata/TopicPartitionsMapping` (Hash, Topic, ProducerId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2025-11-05T13:43:40.103916Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `//Root/.metadata/TopicPartitionsMapping` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND ProducerId = $SourceId AND Partition = $Partition;
2025-11-05T13:43:40.103922Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [8:7569236562762930426:2469] (SourceId=test-message_group_id, PreferedPartition=0) ReplyResult: Partition=0, SeqNo=0
2025-11-05T13:43:40.103927Z node 8 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 3 sessionId:  partition: 0 expectedGeneration: 1
2025-11-05T13:43:40.104079Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930429:2469], now have 1 active actors on pipe
2025-11-05T13:43:40.104080Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 8, Generation: 1
2025-11-05T13:43:40.104094Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.104099Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.104131Z node 8 :PERSQUEUE INFO: new Cookie test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 generated for partition 0 topic 'topic_A' owner test-message_group_id
2025-11-05T13:43:40.104146Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.104150Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.104159Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.104176Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2025-11-05T13:43:40.104199Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.104256Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.104262Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.104294Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.104315Z node 8 :PQ_WRITE_PROXY INFO: session inited cookie: 3 partition: 0 MaxSeqNo: 0 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0
2025-11-05T13:43:40.105676Z :DEBUG: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-05T13:43:40.105699Z :INFO: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762350220105 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T13:43:40.105728Z :INFO: [/Root]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0"
2025-11-05T13:43:40.105732Z :TRACE: [/Root] TRACE_EVENT InitResponse  partition_id=0 session_id=test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0
2025-11-05T13:43:40.105805Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=1, txId=01k9a44gsy74wm6dpztx5z15gp, WriteCount=1, AckCount=0
2025-11-05T13:43:40.111546Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-11-05T13:43:40.117508Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-05T13:43:40.117523Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-11-05T13:43:40.139410Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 grpc read done: success: 1 data:  write_request[data omitted]
2025-11-05T13:43:40.140921Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Start of a request to KQP for a WriteId. SessionId: ydb://session/3?node_id=8&id=OTM0N2U5N2QtOTQ3OTJjOTItM2M2NTU5OWYtNmY4YzkyNTA= TxId: 01k9a44gsy74wm6dpztx5z15gp
2025-11-05T13:43:40.141254Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 8, Generation: 1
2025-11-05T13:43:40.141276Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930432:2469], now have 1 active actors on pipe
2025-11-05T13:43:40.141876Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) End of the request to KQP for the WriteId. SessionId: ydb://session/3?node_id=8&id=OTM0N2U5N2QtOTQ3OTJjOTItM2M2NTU5OWYtNmY4YzkyNTA= TxId: 01k9a44gsy74wm6dpztx5z15gp Status: SUCCESS
2025-11-05T13:43:40.141899Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) SessionId: ydb://session/3?node_id=8&id=OTM0N2U5N2QtOTQ3OTJjOTItM2M2NTU5OWYtNmY4YzkyNTA= TxId: 01k9a44gsy74wm6dpztx5z15gp WriteId: {8, 281474976715673}
2025-11-05T13:43:40.141990Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.141999Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.142007Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] partition {0, {8, 281474976715673}, 100000} for WriteId {8, 281474976715673}
2025-11-05T13:43:40.142057Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvSubscribeLock for WriteId {8, 281474976715673}
2025-11-05T13:43:40.142077Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.142303Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvLongTxService::TEvLockStatus LockId: 281474976715673 LockNode: 8 Status: STATUS_SUBSCRIBED
2025-11-05T13:43:40.142309Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxWriteInfo: WriteId {8, 281474976715673}, TxId (empty maybe), Status STATUS_UNSPECIFIED
2025-11-05T13:43:40.142311Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] subscribed WriteId {8, 281474976715673}
2025-11-05T13:43:40.142504Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.142738Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitConfigStep
2025-11-05T13:43:40.142806Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T13:43:40.142881Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateInit] bootstrapping {0, {8, 281474976715673}, 100000} [8:7569236562762930438:2471]
2025-11-05T13:43:40.143188Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitDiskStatusStep
2025-11-05T13:43:40.143330Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitMetaStep
2025-11-05T13:43:40.143372Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitInfoRangeStep
2025-11-05T13:43:40.143408Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitDataRangeStep
2025-11-05T13:43:40.143422Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitDataStep
2025-11-05T13:43:40.143424Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Start initializing step TInitEndWriteTimestampStep
2025-11-05T13:43:40.143426Z node 8 :PERSQUEUE INFO: [topic_A:{0, {8, 281474976715673}, 100000}:TInitEndWriteTimestampStep] Initializing EndWriteTimestamp skipped because already initialized.
2025-11-05T13:43:40.143428Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715673}, 100000}:Initializer] Initializing completed.
2025-11-05T13:43:40.143434Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateInit] init complete for topic 'topic_A' partition {0, {8, 281474976715673}, 100000} generation 1 [8:7569236562762930438:2471]
2025-11-05T13:43:40.143441Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateInit] SYNC INIT topic topic_A partitition {0, {8, 281474976715673}, 100000} so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T13:43:40.143445Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Process pending events. Count 0
2025-11-05T13:43:40.143448Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.143451Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.143560Z node 8 :PERSQUEUE INFO: new Cookie test-message_group_id|d4d4542c-e503c3c0-28c8a22c-81cc8892_0 generated for partition {0, {8, 281474976715673}, 100000} topic 'topic_A' owner test-message_group_id
2025-11-05T13:43:40.143567Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.143571Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.143579Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.143588Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyOwnerOk. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.143602Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.143617Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Start of a request to KQP to save PartitionId. SessionId: ydb://session/3?node_id=8&id=OTM0N2U5N2QtOTQ3OTJjOTItM2M2NTU5OWYtNmY4YzkyNTA= TxId: 01k9a44gsy74wm6dpztx5z15gp
2025-11-05T13:43:40.143764Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) End of a request to KQP to save PartitionId. SessionId: ydb://session/3?node_id=8&id=OTM0N2U5N2QtOTQ3OTJjOTItM2M2NTU5OWYtNmY4YzkyNTA= TxId: 01k9a44gsy74wm6dpztx5z15gp Status: SUCCESS
2025-11-05T13:43:40.145738Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.145752Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.145796Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.145930Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.145934Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.145969Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Reserve bytes in transaction. Partition: 0, WriteId: { NodeId: 8 KeyId: 281474976715673 KafkaTransaction: false }, NeedSupportivePartition: 0
2025-11-05T13:43:40.145987Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 1
2025-11-05T13:43:40.146005Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2025-11-05T13:43:40.146133Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.146137Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.146147Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Write in transaction. Partition: 0, WriteId: { NodeId: 8 KeyId: 281474976715673 KafkaTransaction: false }, NeedSupportivePartition: 0
2025-11-05T13:43:40.146251Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 0 messageNo: 1 size: 511944
2025-11-05T13:43:40.146417Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 1 messageNo: 1 size: 511944
2025-11-05T13:43:40.146513Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 2 messageNo: 1 size: 511944
2025-11-05T13:43:40.146586Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 3 messageNo: 1 size: 511944
2025-11-05T13:43:40.146664Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 4 messageNo: 1 size: 511944
2025-11-05T13:43:40.146746Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 5 messageNo: 1 size: 511944
2025-11-05T13:43:40.146815Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 6 messageNo: 1 size: 511944
2025-11-05T13:43:40.146887Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 7 messageNo: 1 size: 511944
2025-11-05T13:43:40.146959Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 8 messageNo: 1 size: 511944
2025-11-05T13:43:40.147533Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 9 messageNo: 1 size: 511944
2025-11-05T13:43:40.147620Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 10 messageNo: 1 size: 511944
2025-11-05T13:43:40.147705Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 11 messageNo: 1 size: 511944
2025-11-05T13:43:40.148151Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 12 messageNo: 1 size: 511944
2025-11-05T13:43:40.148424Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 13 messageNo: 1 size: 344802
2025-11-05T13:43:40.148429Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 1 partNo : 13 messageNo: 1 size 344802 offset: -1
2025-11-05T13:43:40.148519Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.148530Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.148565Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 0
2025-11-05T13:43:40.148581Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 1
2025-11-05T13:43:40.148585Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 2
2025-11-05T13:43:40.148594Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 3
2025-11-05T13:43:40.148600Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 4
2025-11-05T13:43:40.148604Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 5
2025-11-05T13:43:40.148607Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 6
2025-11-05T13:43:40.148622Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 7
2025-11-05T13:43:40.148626Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 8
2025-11-05T13:43:40.148629Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 9
2025-11-05T13:43:40.148636Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 10
2025-11-05T13:43:40.148639Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 11
2025-11-05T13:43:40.148643Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 12
2025-11-05T13:43:40.148647Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob processing sourceId '\0test-message_group_id' seqNo 1 partNo 13
2025-11-05T13:43:40.154618Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715673}, 100000} part blob complete sourceId '\0test-message_group_id' seqNo 1 partNo 13 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 7001250 count 1 nextOffset 1 batches 14
2025-11-05T13:43:40.154654Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.154793Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Add new write blob: topic 'topic_A' partition {0, {8, 281474976715673}, 100000} compactOffset 0,1 HeadOffset 0 endOffset 0 curOffset 1 D0000100000_00000000000000000000_00000_0000000001_00013 size 7001240 WTime 1762350220152
2025-11-05T13:43:40.160789Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.160814Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough blob. Partition 100000 offset 0 partNo 0 count 1 size 7001240
2025-11-05T13:43:40.161554Z node 8 :PERSQUEUE DEBUG: Caching head blob in L1. Partition 100000 offset 0 count 1 size 7001240 actorID [8:7569236562762930337:2451]
2025-11-05T13:43:40.161589Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 7000382 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T13:43:40.161602Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161612Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 0, Offset: 0 is stored on disk
2025-11-05T13:43:40.161619Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161643Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 1, Offset: 0 is stored on disk
2025-11-05T13:43:40.161647Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161668Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 2, Offset: 0 is stored on disk
2025-11-05T13:43:40.161673Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161697Z node 8 :PERSQUEUE DEBUG: PQ Cache (L2). Adding blob. Tablet '72075186224037894' partition 100000 offset 0 partno 0 count 1 parts 13 size 7001240
2025-11-05T13:43:40.161713Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 3, Offset: 0 is stored on disk
2025-11-05T13:43:40.161717Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161723Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 4, Offset: 0 is stored on disk
2025-11-05T13:43:40.161727Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161733Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 5, Offset: 0 is stored on disk
2025-11-05T13:43:40.161737Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161741Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 6, Offset: 0 is stored on disk
2025-11-05T13:43:40.161744Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161748Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 7, Offset: 0 is stored on disk
2025-11-05T13:43:40.161752Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161756Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 8, Offset: 0 is stored on disk
2025-11-05T13:43:40.161759Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161764Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 9, Offset: 0 is stored on disk
2025-11-05T13:43:40.161767Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161773Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 10, Offset: 0 is stored on disk
2025-11-05T13:43:40.161776Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161781Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 11, Offset: 0 is stored on disk
2025-11-05T13:43:40.161788Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161792Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 12, Offset: 0 is stored on disk
2025-11-05T13:43:40.161798Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.161803Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715673}, 100000}, SeqNo: 1, partNo: 13, Offset: 0 is stored on disk
2025-11-05T13:43:40.161819Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.161822Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.161845Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 1  requestId: <none> cookie: 1
2025-11-05T13:43:40.161863Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2025-11-05T13:43:40.162436Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-05T13:43:40.162513Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written_in_tx { } } write_statistics { persisting_time { nanos: 13000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-05T13:43:40.162525Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=01k9a44gsy74wm6dpztx5z15gp, WriteCount=1, AckCount=1
2025-11-05T13:43:40.162816Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-11-05T13:43:40.166573Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930454:2873], now have 1 active actors on pipe
2025-11-05T13:43:40.166646Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7569236562762930451 RawX2: 4503633987111328 } TxId: 281474976715674 Data { Operations { PartitionId: 0 Path: "/Root/topic_A" SupportivePartition: 100000 } Op: Commit SendingShards: 72075186224037894 ReceivingShards: 72075186224037894 Immediate: true WriteId { NodeId: 8 KeyId: 281474976715673 } }
2025-11-05T13:43:40.166656Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] PartitionId {0, {8, 281474976715673}, 100000} for WriteId {8, 281474976715673}
2025-11-05T13:43:40.166663Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715674 has WriteId {8, 281474976715673}
2025-11-05T13:43:40.166667Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] immediate transaction
2025-11-05T13:43:40.166684Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Send TEvGetWriteInfoRequest for TxId (empty maybe)
2025-11-05T13:43:40.166695Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.166699Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] The Tx (empty maybe) is waiting for TEvGetWriteInfoResponse
2025-11-05T13:43:40.166701Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Still preprocessing - waiting for something
2025-11-05T13:43:40.166707Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Handle TEvPQ::TEvGetWriteInfoRequest
2025-11-05T13:43:40.166719Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Send TEvPQ::TEvGetWriteInfoResponse
2025-11-05T13:43:40.166723Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Handle TEvPQ::TEvGetWriteInfoResponse
2025-11-05T13:43:40.166726Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Received TEvGetWriteInfoResponse for TxId (empty maybe)
2025-11-05T13:43:40.166729Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.166737Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.166741Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::CommitWriteOperations TxId: (empty maybe)
2025-11-05T13:43:40.166760Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] t.WriteInfo->BodyKeys.size=1, t.WriteInfo->BlobsFromHead.size=0
2025-11-05T13:43:40.166766Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Head=Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0, NewHead=Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T13:43:40.166772Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] add key D0000100000_00000000000000000000_00000_0000000001_00013
2025-11-05T13:43:40.166791Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] PartitionedBlob.GetFormedBlobs().size=1
2025-11-05T13:43:40.166801Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] writing blob: topic 'topic_A' partition 0 old key D0000100000_00000000000000000000_00000_0000000001_00013 new key d0000000000_00000000000000000000_00000_0000000001_00013 size 7001240 WTime 1762350220166
2025-11-05T13:43:40.166811Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] schedule TEvPersQueue::TEvProposeTransactionResult(COMPLETE), reason=
2025-11-05T13:43:40.166817Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.166858Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.166863Z node 8 :PERSQUEUE DEBUG: CacheProxy. Rename blob from D0000100000_00000000000000000000_00000_0000000001_00013 to d0000000000_00000000000000000000_00000_0000000001_00013
2025-11-05T13:43:40.167270Z node 8 :PERSQUEUE DEBUG: Renaming head blob in L1. Old partition 100000 old offset 0 old count 1 new partition 0 new offset 0 new count 1 actorID [8:7569236562762930337:2451]
2025-11-05T13:43:40.167311Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 7000382
2025-11-05T13:43:40.167330Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Topic 'topic_A' partition 0 user test-consumer readTimeStamp for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 0 rrg 0
2025-11-05T13:43:40.167338Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Topic 'topic_A' partition 0 user test-consumer send read request for offset 0 initiated  queuesize 0 startOffset 0 ReadingTimestamp 1 rrg 0
2025-11-05T13:43:40.167342Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.167343Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.167660Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] read cookie 0 Topic 'topic_A' partition 0 user test-consumer offset 0 count 1 size 1024000 endOffset 1 max time lag 0ms effective offset 0
2025-11-05T13:43:40.167682Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] read cookie 0 added 1 blobs, size 7001240 count 1 last offset 1, current partition end offset: 1
2025-11-05T13:43:40.167687Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Reading cookie 0. Send blob request.
2025-11-05T13:43:40.167699Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] Handle TEvPQ::TEvTransactionCompleted WriteId {8, 281474976715673}
2025-11-05T13:43:40.167711Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvPQ::TEvDeletePartition to partition {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.167717Z node 8 :PERSQUEUE DEBUG: Got data from cache. Partition 0 offset 0 count 1 source 1 size 7001240 accessed 0 times before, last time 2025-11-05T13:43:40.000000Z
2025-11-05T13:43:40.167721Z node 8 :PERSQUEUE DEBUG: Reading cookie 0. All 1 blobs are from cache.
2025-11-05T13:43:40.167731Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvLongTxService::TEvLockStatus LockId: 281474976715673 LockNode: 8 Status: STATUS_NOT_FOUND
2025-11-05T13:43:40.167739Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxWriteInfo: WriteId {8, 281474976715673}, TxId 281474976715674, Status STATUS_SUBSCRIBED
2025-11-05T13:43:40.167741Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] there is already a transaction TxId 281474976715674 for WriteId {8, 281474976715673}
2025-11-05T13:43:40.167752Z node 8 :PERSQUEUE DEBUG: FormAnswer for 1 blobs
2025-11-05T13:43:40.167754Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Handle TEvPQ::TEvDeletePartition
2025-11-05T13:43:40.167772Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.167780Z node 8 :PERSQUEUE DEBUG: CacheProxy. Delete blobs from D0000100000(+) to D0000100001(-)
2025-11-05T13:43:40.167957Z node 8 :PERSQUEUE DEBUG: PQ Cache (L2). Renamed. old Tablet '72075186224037894' partition 100000 offset 0 partno 0 count 1 parts 13, new Tablet '72075186224037894' partition 0 offset 0 partno 0 count 1 parts 13
2025-11-05T13:43:40.167968Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512009 from pos 0 cbcount 1
2025-11-05T13:43:40.167969Z node 8 :PERSQUEUE DEBUG: PQ Cache (L2). Touched. Tablet '72075186224037894' partition 0 offset 0 partno 0 count 1 parts 13
2025-11-05T13:43:40.168112Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.168118Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.168125Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715673}, 100000}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.168224Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPQ::TEvDeletePartitionDone {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.168235Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] DeletePartition {0, {8, 281474976715673}, 100000}
2025-11-05T13:43:40.168242Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvUnsubscribeLock for WriteId {8, 281474976715673}
2025-11-05T13:43:40.168245Z node 8 :PQ_TX WARN: [PQ: 72075186224037894] Unknown transaction 281474976715674
2025-11-05T13:43:40.168258Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.168263Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.168398Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.168421Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.168574Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.168743Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.168898Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.169044Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.169181Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.169714Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.170215Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.170369Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.170519Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 0 size 512005 from pos 0 cbcount 1
2025-11-05T13:43:40.170649Z node 8 :PERSQUEUE DEBUG: FormAnswer processing batch offset 0 totakecount 1 count 1 size 344863 from pos 0 cbcount 1
2025-11-05T13:43:40.170694Z node 8 :PERSQUEUE DEBUG: Topic 'topic_A' partition 0 user test-consumer readTimeStamp done, result 1762350220148 queuesize 0 startOffset 0
2025-11-05T13:43:40.170990Z node 8 :PQ_READ_PROXY DEBUG: new create topic request
2025-11-05T13:43:40.171728Z node 8 :TX_PROXY ERROR: Actor# [8:7569236562762930471:2879] txid# 281474976715675, issues: { message: "Check failed: path: \'/Root/topic_A\', error: path exist, request accepts it (id: [OwnerId: 72057594046644480, LocalPathId: 10], type: EPathTypePersQueueGroup, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_pq.cpp:345" severity: 1 }
2025-11-05T13:43:40.172094Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: try to update token
2025-11-05T13:43:40.172340Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session: Do CDS request
2025-11-05T13:43:40.172347Z :INFO: [/Root] MessageGroupId [src] SessionId [] Start write session. Will connect to endpoint: localhost:16345
2025-11-05T13:43:40.173130Z :DEBUG: [/Root] MessageGroupId [src] SessionId [] Write session: send init request: init_request { topic: "topic_A" message_group_id: "src" }
2025-11-05T13:43:40.173242Z node 8 :PQ_WRITE_PROXY DEBUG: new grpc connection
2025-11-05T13:43:40.173253Z node 8 :PQ_WRITE_PROXY DEBUG: new session created cookie 4
2025-11-05T13:43:40.173437Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 4 sessionId:  grpc read done: success: 1 data: init_request { topic: "topic_A" message_group_id: "src" }
2025-11-05T13:43:40.173463Z node 8 :PQ_WRITE_PROXY INFO: session request cookie: 4 topic: "topic_A" message_group_id: "src" from ipv6:[::1]:53050
2025-11-05T13:43:40.173467Z node 8 :PQ_WRITE_PROXY INFO: write session:  cookie=4 sessionId= userAgent="pqv1 server" ip=ipv6:[::1]:53050 proto=v1  topic=topic_A durationSec=0
2025-11-05T13:43:40.173471Z node 8 :PQ_WRITE_PROXY INFO: init check schema
2025-11-05T13:43:40.173736Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 4 sessionId:  describe result for acl check
2025-11-05T13:43:40.173778Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper SelectQuery: --!syntax_v1
DECLARE $Hash AS Uint64; DECLARE $Topic AS Utf8; DECLARE $SourceId AS Utf8;
SELECT Partition, CreateTime, AccessTime, SeqNo FROM `//Root/.metadata/TopicPartitionsMapping` WHERE Hash == $Hash AND Topic == $Topic AND ProducerId == $SourceId;
2025-11-05T13:43:40.173784Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64; DECLARE $SeqNo AS Uint64;
UPSERT INTO `//Root/.metadata/TopicPartitionsMapping` (Hash, Topic, ProducerId, CreateTime, AccessTime, Partition, SeqNo) VALUES ($Hash, $Topic, $SourceId, $CreateTime, $AccessTime, $Partition, $SeqNo);
2025-11-05T13:43:40.173785Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TTableHelper UpdateAccessTimeQuery: --!syntax_v1
DECLARE $SourceId AS Utf8; DECLARE $Topic AS Utf8; DECLARE $Hash AS Uint64; DECLARE $Partition AS Uint32; DECLARE $CreateTime AS Uint64; DECLARE $AccessTime AS Uint64;
UPDATE `//Root/.metadata/TopicPartitionsMapping` SET AccessTime = $AccessTime WHERE Hash = $Hash AND Topic = $Topic AND ProducerId = $SourceId AND Partition = $Partition;
2025-11-05T13:43:40.173798Z node 8 :PQ_PARTITION_CHOOSER DEBUG: TPartitionChooser [8:7569236562762930482:2481] (SourceId=src, PreferedPartition=(NULL)) ReplyResult: Partition=0, SeqNo=0
2025-11-05T13:43:40.173803Z node 8 :PQ_WRITE_PROXY DEBUG: ProceedPartition. session cookie: 4 sessionId:  partition: 0 expectedGeneration: (NULL)
2025-11-05T13:43:40.173934Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 8, Generation: 1
2025-11-05T13:43:40.173950Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930485:2481], now have 1 active actors on pipe
2025-11-05T13:43:40.173964Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.173974Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.174002Z node 8 :PERSQUEUE INFO: new Cookie src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0 generated for partition 0 topic 'topic_A' owner src
2025-11-05T13:43:40.174015Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.174022Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.174034Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.174049Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::ReplyOwnerOk. Partition: 0
2025-11-05T13:43:40.174076Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.174115Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.174123Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.174144Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.174164Z node 8 :PQ_WRITE_PROXY INFO: session inited cookie: 4 partition: 0 MaxSeqNo: 0 sessionId: src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0
2025-11-05T13:43:40.174338Z :INFO: [/Root] MessageGroupId [src] SessionId [] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762350220174 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-05T13:43:40.174359Z :INFO: [/Root] MessageGroupId [src] SessionId [] Write session established. Init response: session_id: "src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0" topic: "topic_A"
2025-11-05T13:43:40.174442Z :INFO: [/Root] MessageGroupId [src] SessionId [src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0] Write session: close. Timeout = 0 ms
2025-11-05T13:43:40.174450Z :INFO: [/Root] MessageGroupId [src] SessionId [src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0] Write session will now close
2025-11-05T13:43:40.174454Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0] Write session: aborting
2025-11-05T13:43:40.174575Z :INFO: [/Root] MessageGroupId [src] SessionId [src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0] Write session: gracefully shut down, all writes complete
2025-11-05T13:43:40.174580Z :DEBUG: [/Root] MessageGroupId [src] SessionId [src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0] Write session: destroy
2025-11-05T13:43:40.174697Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 4 sessionId: src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0 grpc read done: success: 0 data: 
2025-11-05T13:43:40.174705Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 4 sessionId: src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0 grpc read failed
2025-11-05T13:43:40.174711Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 4 sessionId: src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0 grpc closed
2025-11-05T13:43:40.174713Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 4 sessionId: src|bbd4e0f7-a44f2e75-cb082a53-9372751f_0 is DEAD
2025-11-05T13:43:40.174722Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.174725Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.174937Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:40.174983Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server disconnected, pipe [8:7569236562762930485:2481] destroyed
2025-11-05T13:43:40.174993Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::DropOwner.
2025-11-05T13:43:40.174998Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.175003Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.177964Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] OnWrite: seqNo=2, txId=01k9a44gwg3j044cmb4f1g6k3g, WriteCount=1, AckCount=0
2025-11-05T13:43:40.178679Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-11-05T13:43:40.181313Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.181328Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.183966Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-05T13:43:40.189493Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-11-05T13:43:40.211910Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 grpc read done: success: 1 data:  write_request[data omitted]
2025-11-05T13:43:40.217015Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Start of a request to KQP for a WriteId. SessionId: ydb://session/3?node_id=8&id=MTdiN2UyNGYtMWJjMTdmOWYtOGQwZDBhOWItZjc1ZTBiOWU= TxId: 01k9a44gwg3j044cmb4f1g6k3g
2025-11-05T13:43:40.217149Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) TEvClientConnected Status OK, TabletId: 72075186224037894, NodeId 8, Generation: 1
2025-11-05T13:43:40.217175Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server connected, pipe [8:7569236562762930494:2469], now have 1 active actors on pipe
2025-11-05T13:43:40.217386Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) End of the request to KQP for the WriteId. SessionId: ydb://session/3?node_id=8&id=MTdiN2UyNGYtMWJjMTdmOWYtOGQwZDBhOWItZjc1ZTBiOWU= TxId: 01k9a44gwg3j044cmb4f1g6k3g Status: SUCCESS
2025-11-05T13:43:40.217395Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) SessionId: ydb://session/3?node_id=8&id=MTdiN2UyNGYtMWJjMTdmOWYtOGQwZDBhOWItZjc1ZTBiOWU= TxId: 01k9a44gwg3j044cmb4f1g6k3g WriteId: {8, 281474976715676}
2025-11-05T13:43:40.217444Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.217452Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.217459Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] partition {0, {8, 281474976715676}, 100001} for WriteId {8, 281474976715676}
2025-11-05T13:43:40.217500Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvSubscribeLock for WriteId {8, 281474976715676}
2025-11-05T13:43:40.217534Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.217567Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvLongTxService::TEvLockStatus LockId: 281474976715676 LockNode: 8 Status: STATUS_SUBSCRIBED
2025-11-05T13:43:40.217578Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxWriteInfo: WriteId {8, 281474976715676}, TxId (empty maybe), Status STATUS_UNSPECIFIED
2025-11-05T13:43:40.217581Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] subscribed WriteId {8, 281474976715676}
2025-11-05T13:43:40.217879Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.218078Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitConfigStep
2025-11-05T13:43:40.218201Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitInternalFieldsStep
2025-11-05T13:43:40.218306Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateInit] bootstrapping {0, {8, 281474976715676}, 100001} [8:7569236562762930500:2486]
2025-11-05T13:43:40.218560Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitDiskStatusStep
2025-11-05T13:43:40.218675Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitMetaStep
2025-11-05T13:43:40.218706Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitInfoRangeStep
2025-11-05T13:43:40.218740Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitDataRangeStep
2025-11-05T13:43:40.218758Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitDataStep
2025-11-05T13:43:40.218765Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Start initializing step TInitEndWriteTimestampStep
2025-11-05T13:43:40.218768Z node 8 :PERSQUEUE INFO: [topic_A:{0, {8, 281474976715676}, 100001}:TInitEndWriteTimestampStep] Initializing EndWriteTimestamp skipped because already initialized.
2025-11-05T13:43:40.218771Z node 8 :PERSQUEUE DEBUG: [topic_A:{0, {8, 281474976715676}, 100001}:Initializer] Initializing completed.
2025-11-05T13:43:40.218777Z node 8 :PERSQUEUE INFO: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateInit] init complete for topic 'topic_A' partition {0, {8, 281474976715676}, 100001} generation 1 [8:7569236562762930500:2486]
2025-11-05T13:43:40.218786Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateInit] SYNC INIT topic topic_A partitition {0, {8, 281474976715676}, 100001} so 0 endOffset 0 Head Offset 0 PartNo 0 PackedSize 0 count 0 nextOffset 0 batches 0
2025-11-05T13:43:40.218791Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Process pending events. Count 0
2025-11-05T13:43:40.218798Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.218801Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.218854Z node 8 :PERSQUEUE INFO: new Cookie test-message_group_id|4d7c81e8-6b10454c-d5749cf9-89571799_0 generated for partition {0, {8, 281474976715676}, 100001} topic 'topic_A' owner test-message_group_id
2025-11-05T13:43:40.218864Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.218872Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.218881Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.218892Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyOwnerOk. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.218914Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.218930Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Start of a request to KQP to save PartitionId. SessionId: ydb://session/3?node_id=8&id=MTdiN2UyNGYtMWJjMTdmOWYtOGQwZDBhOWItZjc1ZTBiOWU= TxId: 01k9a44gwg3j044cmb4f1g6k3g
2025-11-05T13:43:40.219062Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) End of a request to KQP to save PartitionId. SessionId: ydb://session/3?node_id=8&id=MTdiN2UyNGYtMWJjMTdmOWYtOGQwZDBhOWItZjc1ZTBiOWU= TxId: 01k9a44gwg3j044cmb4f1g6k3g Status: SUCCESS
2025-11-05T13:43:40.219088Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.219096Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.219119Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 0
2025-11-05T13:43:40.219160Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.219166Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.219189Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Reserve bytes in transaction. Partition: 0, WriteId: { NodeId: 8 KeyId: 281474976715676 KafkaTransaction: false }, NeedSupportivePartition: 0
2025-11-05T13:43:40.219222Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 0  requestId: <none> cookie: 2
2025-11-05T13:43:40.219240Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2025-11-05T13:43:40.219269Z node 8 :PERSQUEUE DEBUG: Handle TEvRequest topic: 'topic_A' requestId: <none>
2025-11-05T13:43:40.219285Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message batch for topic 'topic_A' partition 0
2025-11-05T13:43:40.219309Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Write in transaction. Partition: 0, WriteId: { NodeId: 8 KeyId: 281474976715676 KafkaTransaction: false }, NeedSupportivePartition: 0
2025-11-05T13:43:40.219383Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 0 messageNo: 1 size: 511944
2025-11-05T13:43:40.219444Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 1 messageNo: 1 size: 511944
2025-11-05T13:43:40.219508Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 2 messageNo: 1 size: 511944
2025-11-05T13:43:40.219573Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 3 messageNo: 1 size: 511944
2025-11-05T13:43:40.219642Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 4 messageNo: 1 size: 511944
2025-11-05T13:43:40.219713Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 5 messageNo: 1 size: 511944
2025-11-05T13:43:40.219803Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 6 messageNo: 1 size: 511944
2025-11-05T13:43:40.219871Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 7 messageNo: 1 size: 511944
2025-11-05T13:43:40.219960Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 8 messageNo: 1 size: 511944
2025-11-05T13:43:40.220376Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 9 messageNo: 1 size: 511944
2025-11-05T13:43:40.220780Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 10 messageNo: 1 size: 511944
2025-11-05T13:43:40.220853Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 11 messageNo: 1 size: 511944
2025-11-05T13:43:40.220925Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 12 messageNo: 1 size: 511944
2025-11-05T13:43:40.221007Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client PART message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 13 messageNo: 1 size: 344802
2025-11-05T13:43:40.221016Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] got client message topic: topic_A partition: 0 SourceId: '\0test-message_group_id' SeqNo: 2 partNo : 13 messageNo: 1 size 344802 offset: -1
2025-11-05T13:43:40.221125Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.221144Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.221175Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 0
2025-11-05T13:43:40.221197Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 1
2025-11-05T13:43:40.221206Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 2
2025-11-05T13:43:40.221209Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 3
2025-11-05T13:43:40.221212Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 4
2025-11-05T13:43:40.221216Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 5
2025-11-05T13:43:40.221219Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 6
2025-11-05T13:43:40.221222Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 7
2025-11-05T13:43:40.221225Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 8
2025-11-05T13:43:40.221228Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 9
2025-11-05T13:43:40.221232Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 10
2025-11-05T13:43:40.221237Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 11
2025-11-05T13:43:40.221244Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 12
2025-11-05T13:43:40.221248Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob processing sourceId '\0test-message_group_id' seqNo 2 partNo 13
2025-11-05T13:43:40.223074Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Topic 'topic_A' partition {0, {8, 281474976715676}, 100001} part blob complete sourceId '\0test-message_group_id' seqNo 2 partNo 13 FormedBlobsCount 0 NewHead: Offset 0 PartNo 0 PackedSize 7001250 count 1 nextOffset 1 batches 14
2025-11-05T13:43:40.223106Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.223242Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Add new write blob: topic 'topic_A' partition {0, {8, 281474976715676}, 100001} compactOffset 0,1 HeadOffset 0 endOffset 0 curOffset 1 D0000100001_00000000000000000000_00000_0000000001_00013 size 7001240 WTime 1762350220223
2025-11-05T13:43:40.229417Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.229628Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough blob. Partition 100001 offset 0 partNo 0 count 1 size 7001240
2025-11-05T13:43:40.230098Z node 8 :PERSQUEUE DEBUG: Caching head blob in L1. Partition 100001 offset 0 count 1 size 7001240 actorID [8:7569236562762930337:2451]
2025-11-05T13:43:40.230142Z node 8 :PERSQUEUE DEBUG: PQ Cache (L2). Adding blob. Tablet '72075186224037894' partition 100001 offset 0 partno 0 count 1 parts 13 size 7001240
2025-11-05T13:43:40.230157Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 7000382 WriteNewSizeFromSupportivePartitions# 0
2025-11-05T13:43:40.230181Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230205Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 0, Offset: 0 is stored on disk
2025-11-05T13:43:40.230229Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230243Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 1, Offset: 0 is stored on disk
2025-11-05T13:43:40.230248Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230259Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 2, Offset: 0 is stored on disk
2025-11-05T13:43:40.230267Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230273Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 3, Offset: 0 is stored on disk
2025-11-05T13:43:40.230282Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230288Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 4, Offset: 0 is stored on disk
2025-11-05T13:43:40.230292Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230297Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 5, Offset: 0 is stored on disk
2025-11-05T13:43:40.230311Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230319Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 6, Offset: 0 is stored on disk
2025-11-05T13:43:40.230324Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230335Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 7, Offset: 0 is stored on disk
2025-11-05T13:43:40.230338Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230342Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 8, Offset: 0 is stored on disk
2025-11-05T13:43:40.230347Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230354Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 9, Offset: 0 is stored on disk
2025-11-05T13:43:40.230361Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230370Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 10, Offset: 0 is stored on disk
2025-11-05T13:43:40.230380Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230386Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 11, Offset: 0 is stored on disk
2025-11-05T13:43:40.230389Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230394Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 12, Offset: 0 is stored on disk
2025-11-05T13:43:40.230401Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] TPartition::ReplyWrite. Partition: {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.230410Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Answering for message sourceid: '\0test-message_group_id', Topic: 'topic_A', Partition: {0, {8, 281474976715676}, 100001}, SeqNo: 2, partNo: 13, Offset: 0 is stored on disk
2025-11-05T13:43:40.230412Z node 8 :PERSQUEUE DEBUG: Answer ok topic: 'topic_A' partition: 0 messageNo: 1  requestId: <none> cookie: 2
2025-11-05T13:43:40.230436Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.230437Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NKikimr::TEvPersQueue::TEvResponse
2025-11-05T13:43:40.230443Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.230745Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-05T13:43:40.230802Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written_in_tx { } } write_statistics { persisting_time { nanos: 8000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-05T13:43:40.230814Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=01k9a44gwg3j044cmb4f1g6k3g, WriteCount=1, AckCount=1
2025-11-05T13:43:40.231115Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-11-05T13:43:40.232137Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPersQueue::TEvProposeTransaction SourceActor { RawX1: 7569236562762930513 RawX2: 4503633987111348 } TxId: 281474976715677 Data { Operations { PartitionId: 0 Path: "/Root/topic_A" SupportivePartition: 100001 } Op: Commit SendingShards: 72075186224037894 ReceivingShards: 72075186224037894 Immediate: true WriteId { NodeId: 8 KeyId: 281474976715676 } }
2025-11-05T13:43:40.232155Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] PartitionId {0, {8, 281474976715676}, 100001} for WriteId {8, 281474976715676}
2025-11-05T13:43:40.232164Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] TxId 281474976715677 has WriteId {8, 281474976715676}
2025-11-05T13:43:40.232169Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] immediate transaction
2025-11-05T13:43:40.232188Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Send TEvGetWriteInfoRequest for TxId (empty maybe)
2025-11-05T13:43:40.232198Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.232203Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] The Tx (empty maybe) is waiting for TEvGetWriteInfoResponse
2025-11-05T13:43:40.232205Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Still preprocessing - waiting for something
2025-11-05T13:43:40.232206Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Handle TEvPQ::TEvGetWriteInfoRequest
2025-11-05T13:43:40.232218Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Send TEvPQ::TEvGetWriteInfoResponse
2025-11-05T13:43:40.232229Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Handle TEvPQ::TEvGetWriteInfoResponse
2025-11-05T13:43:40.232232Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Received TEvGetWriteInfoResponse for TxId (empty maybe)
2025-11-05T13:43:40.232234Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.232243Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.232248Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::CommitWriteOperations TxId: (empty maybe)
2025-11-05T13:43:40.232259Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] t.WriteInfo->BodyKeys.size=1, t.WriteInfo->BlobsFromHead.size=0
2025-11-05T13:43:40.232266Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Head=Offset 1 PartNo 0 PackedSize 0 count 0 nextOffset 1 batches 0, NewHead=Offset 1 PartNo 0 PackedSize 0 count 0 nextOffset 1 batches 0
2025-11-05T13:43:40.232275Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] add key D0000100001_00000000000000000000_00000_0000000001_00013
2025-11-05T13:43:40.232294Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] PartitionedBlob.GetFormedBlobs().size=1
2025-11-05T13:43:40.232309Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] writing blob: topic 'topic_A' partition 0 old key D0000100001_00000000000000000000_00000_0000000001_00013 new key d0000000000_00000000000000000001_00000_0000000001_00013 size 7001240 WTime 1762350220231
2025-11-05T13:43:40.232325Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] schedule TEvPersQueue::TEvProposeTransactionResult(COMPLETE), reason=
2025-11-05T13:43:40.232336Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.232385Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.232394Z node 8 :PERSQUEUE DEBUG: CacheProxy. Rename blob from D0000100001_00000000000000000000_00000_0000000001_00013 to d0000000000_00000000000000000001_00000_0000000001_00013
2025-11-05T13:43:40.232742Z node 8 :PERSQUEUE DEBUG: Renaming head blob in L1. Old partition 100001 old offset 0 old count 1 new partition 0 new offset 1 new count 1 actorID [8:7569236562762930337:2451]
2025-11-05T13:43:40.232786Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::HandleWriteResponse writeNewSize# 0 WriteNewSizeFromSupportivePartitions# 7000382
2025-11-05T13:43:40.232802Z node 8 :PERSQUEUE DEBUG: PQ Cache (L2). Renamed. old Tablet '72075186224037894' partition 100001 offset 0 partno 0 count 1 parts 13, new Tablet '72075186224037894' partition 0 offset 1 partno 0 count 1 parts 13
2025-11-05T13:43:40.232805Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.232807Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.232818Z node 8 :PQ_TX INFO: [PQ: 72075186224037894] Handle TEvPQ::TEvTransactionCompleted WriteId {8, 281474976715676}
2025-11-05T13:43:40.232824Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvPQ::TEvDeletePartition to partition {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.232829Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Handle TEvPQ::TEvDeletePartition
2025-11-05T13:43:40.232842Z node 8 :PERSQUEUE DEBUG: CacheProxy. Passthrough write request to KV
2025-11-05T13:43:40.232853Z node 8 :PERSQUEUE DEBUG: CacheProxy. Delete blobs from D0000100001(+) to D0000100002(-)
2025-11-05T13:43:40.233036Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvLongTxService::TEvLockStatus LockId: 281474976715676 LockNode: 8 Status: STATUS_NOT_FOUND
2025-11-05T13:43:40.233047Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] TxWriteInfo: WriteId {8, 281474976715676}, TxId 281474976715677, Status STATUS_SUBSCRIBED
2025-11-05T13:43:40.233050Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] there is already a transaction TxId 281474976715677 for WriteId {8, 281474976715676}
2025-11-05T13:43:40.233094Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.233101Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: {0, {8, 281474976715676}, 100001}, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.233142Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] Handle TEvPQ::TEvDeletePartitionDone {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.233155Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] DeletePartition {0, {8, 281474976715676}, 100001}
2025-11-05T13:43:40.233162Z node 8 :PQ_TX DEBUG: [PQ: 72075186224037894] send TEvUnsubscribeLock for WriteId {8, 281474976715676}
2025-11-05T13:43:40.233168Z node 8 :PQ_TX WARN: [PQ: 72075186224037894] Unknown transaction 281474976715677
2025-11-05T13:43:40.233192Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Send TEvKeyValue::TEvRequest (WRITE_TX_COOKIE)
2025-11-05T13:43:40.233350Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] Handle TEvKeyValue::TEvResponse (WRITE_TX_COOKIE)
2025-11-05T13:43:40.246286Z :INFO: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-11-05T13:43:40.246294Z :INFO: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session will now close
2025-11-05T13:43:40.246304Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-11-05T13:43:40.246516Z :INFO: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-11-05T13:43:40.246524Z :DEBUG: [/Root]  TraceId []  SessionId [test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-11-05T13:43:40.255650Z node 8 :PQ_WRITE_PROXY DEBUG: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 grpc read done: success: 0 data: 
2025-11-05T13:43:40.255671Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 grpc read failed
2025-11-05T13:43:40.255684Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 grpc closed
2025-11-05T13:43:40.255689Z node 8 :PQ_WRITE_PROXY INFO: session v1 cookie: 3 sessionId: test-message_group_id|f12952d9-3d5446c9-ec7021b5-ede4a9b_0 is DEAD
2025-11-05T13:43:40.256258Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:40.256268Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:40.256272Z node 8 :PQ_WRITE_PROXY DEBUG: TPartitionWriter 72075186224037894 (partition=0) Received event: NActors::TEvents::TEvPoison
2025-11-05T13:43:40.256377Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] TPartition::DropOwner.
2025-11-05T13:43:40.256389Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.256392Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.256347Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server disconnected, pipe [8:7569236562762930429:2469] destroyed
2025-11-05T13:43:40.258507Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server disconnected, pipe [8:7569236562762930494:2469] destroyed
2025-11-05T13:43:40.258513Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894] server disconnected, pipe [8:7569236562762930432:2469] destroyed
2025-11-05T13:43:40.275036Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.275056Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037892, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
2025-11-05T13:43:40.282291Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state before ContinueProcessTxsAndUserActs: 0
2025-11-05T13:43:40.282310Z node 8 :PERSQUEUE DEBUG: [PQ: 72075186224037894, Partition: 0, State: StateIdle] Batching state after ContinueProcessTxsAndUserActs: 1
