Skip to content

Commit f7097f8

Browse files
committed
reduce spammy logs in cdc service, tx manager, and rocksdb operations
1 parent c2439fc commit f7097f8

File tree

4 files changed

+5
-6
lines changed

4 files changed

+5
-6
lines changed

src/yb/cdc/cdc_service.cc

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2947,7 +2947,7 @@ Result<TabletCDCCheckpointInfo> CDCServiceImpl::PopulateCDCSDKTabletCheckPointIn
29472947

29482948
auto get_stream_metadata = GetStream(stream_id, RefreshStreamMapOption::kIfInitiatedState);
29492949
if (!get_stream_metadata.ok()) {
2950-
LOG(WARNING) << "Read invalid stream id: " << stream_id << " for tablet " << tablet_id << ": "
2950+
VLOG_WITH_FUNC(2) << "Read invalid stream id: " << stream_id << " for tablet " << tablet_id << ": "
29512951
<< get_stream_metadata.status();
29522952
break;
29532953
}
@@ -4713,8 +4713,7 @@ void CDCServiceImpl::RemoveXReplTabletMetrics(
47134713
}
47144714
auto tablet = tablet_peer->shared_tablet_maybe_null();
47154715
if (tablet == nullptr) {
4716-
YB_LOG_EVERY_N_SECS_OR_VLOG(WARNING, 300, 4)
4717-
<< "Could not find tablet for tablet peer: " << tablet_peer->tablet_id();
4716+
VLOG_WITH_FUNC(2) << "Could not find tablet for tablet peer: " << tablet_peer->tablet_id();
47184717
return;
47194718
}
47204719

src/yb/client/transaction_manager.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ class TransactionTableState {
111111
if (PickStatusTabletId(tablets, callback)) {
112112
return;
113113
}
114-
YB_LOG_EVERY_N_SECS(WARNING, 1) << "No local transaction status tablet found";
114+
YB_LOG_EVERY_N_SECS(WARNING, 10) << "No local transaction status tablet found";
115115
callback(RandomElement(tablets));
116116
}
117117

src/yb/rocksdb/db/db_impl.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2150,7 +2150,7 @@ Result<FileNumbersHolder> DBImpl::FlushMemTableToOutputFile(
21502150
*made_progress = 1;
21512151
}
21522152
VersionStorageInfo::LevelSummaryStorage tmp;
2153-
YB_LOG_EVERY_N_SECS(INFO, 1)
2153+
YB_LOG_EVERY_N_SECS(INFO, 10)
21542154
<< "[" << cfd->GetName() << "] Level summary: "
21552155
<< cfd->current()->storage_info()->LevelSummary(&tmp);
21562156
}

src/yb/rpc/reactor.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -635,7 +635,7 @@ void Reactor::ScanIdleConnections() {
635635
if (connection_delta > connection_keepalive_time_) {
636636
conn->Shutdown(STATUS_FORMAT(
637637
NetworkError, "Connection timed out after $0", ToSeconds(connection_delta)));
638-
LOG_WITH_PREFIX(INFO)
638+
VLOG(2)
639639
<< "DEBUG: Closing idle connection: " << conn->ToString()
640640
<< " - it has been idle for " << ToSeconds(connection_delta) << "s";
641641
VLOG(1) << "(delta: " << ToSeconds(connection_delta)

0 commit comments

Comments
 (0)