Skip to content

Commit 1b1af8f

Browse files
committed
schemeshard: fix log messages on some ProgressState
1 parent a1e26c7 commit 1b1af8f

7 files changed

+8
-8
lines changed

ydb/core/tx/schemeshard/olap/operations/alter_table.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ class TPropose: public TSubOperationState {
145145
TTabletId ssId = context.SS->SelfTabletId();
146146

147147
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
148-
DebugHint() << " HandleReply ProgressState"
148+
DebugHint() << " ProgressState"
149149
<< " at tablet: " << ssId);
150150

151151
TTxState* txState = context.SS->FindTxSafe(OperationId, TTxState::TxAlterColumnTable);

ydb/core/tx/schemeshard/olap/operations/create_table.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ class TPropose: public TSubOperationState {
403403
TTabletId ssId = context.SS->SelfTabletId();
404404

405405
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
406-
DebugHint() << " HandleReply ProgressState"
406+
DebugHint() << " ProgressState"
407407
<< " at tablet: " << ssId);
408408

409409
TTxState* txState = context.SS->FindTx(OperationId);

ydb/core/tx/schemeshard/schemeshard__operation_common_pq.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -401,7 +401,7 @@ bool TConfigureParts::ProgressState(TOperationContext& context) {
401401

402402
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
403403
DebugHint()
404-
<< " HandleReply ProgressState"
404+
<< " ProgressState"
405405
<< ", at schemeshard: " << ssId);
406406

407407
TTxState* txState = context.SS->FindTx(OperationId);

ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -333,7 +333,7 @@ class TPropose: public TSubOperationState {
333333
TTabletId ssId = context.SS->SelfTabletId();
334334

335335
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
336-
DebugHint() << " HandleReply ProgressState"
336+
DebugHint() << " ProgressState"
337337
<< " at tablet: " << ssId);
338338

339339
TTxState* txState = context.SS->FindTx(OperationId);

ydb/core/tx/schemeshard/schemeshard__operation_finalize_build_index.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ class TPropose: public TSubOperationState {
166166
continue;
167167

168168
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
169-
DebugHint() << " HandleReply ProgressState"
169+
DebugHint() << " HandleReply TEvOperationPlan"
170170
<< " at tablet: " << ssId
171171
<< " terminating build column process at column "
172172
<< column.second.Name);
@@ -191,7 +191,7 @@ class TPropose: public TSubOperationState {
191191
TTabletId ssId = context.SS->SelfTabletId();
192192

193193
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
194-
DebugHint() << " HandleReply ProgressState"
194+
DebugHint() << " ProgressState"
195195
<< " at tablet: " << ssId);
196196

197197
TTxState* txState = context.SS->FindTx(OperationId);

ydb/core/tx/schemeshard/schemeshard__operation_initiate_build_index.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ class TPropose: public TSubOperationState {
190190
TTabletId ssId = context.SS->SelfTabletId();
191191

192192
LOG_INFO_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
193-
DebugHint() << " HandleReply ProgressState"
193+
DebugHint() << " ProgressState"
194194
<< " at tablet: " << ssId);
195195

196196
TTxState* txState = context.SS->FindTx(OperationId);

ydb/core/tx/schemeshard/schemeshard_impl.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5883,7 +5883,7 @@ void TSchemeShard::Handle(TEvPersQueue::TEvProposeTransactionResult::TPtr& ev, c
58835883
const TSubTxId partId = Operations.at(txId)->FindRelatedPartByTabletId(tabletId, ctx);
58845884
if (partId == InvalidSubTxId) {
58855885
LOG_WARN_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
5886-
"Got TEvProposeTransactionResult but partId is unknown"
5886+
"Got TEvPersQueue::TEvProposeTransactionResult but partId is unknown"
58875887
<< ", for txId: " << txId
58885888
<< ", tabletId: " << tabletId
58895889
<< ", at schemeshard: " << TabletID());

0 commit comments

Comments
 (0)