@@ -124,7 +124,7 @@ void FlusherRunner::PushToHttpSink(SenderQueueItem* item, bool withLimit) {
124124 && chrono::duration_cast<chrono::seconds>(chrono::system_clock::now () - item->mFirstEnqueTime ).count ()
125125 < INT32_FLAG (discard_send_fail_interval)) {
126126 item->mStatus = SendingStatus::IDLE;
127- LOG_DEBUG (sLogger ,
127+ LOG_TRACE (sLogger ,
128128 (" failed to build request" , " retry later" )(" item address" , item)(
129129 " config-flusher-dst" , QueueKeyManager::GetInstance ()->GetName (item->mQueueKey )));
130130 SenderQueueManager::GetInstance ()->DecreaseConcurrencyLimiterInSendingCnt (item->mQueueKey );
@@ -139,7 +139,7 @@ void FlusherRunner::PushToHttpSink(SenderQueueItem* item, bool withLimit) {
139139 }
140140
141141 req->mEnqueTime = item->mLastSendTime = chrono::system_clock::now ();
142- LOG_DEBUG (sLogger ,
142+ LOG_TRACE (sLogger ,
143143 (" send item to http sink, item address" , item)(" config-flusher-dst" ,
144144 QueueKeyManager::GetInstance ()->GetName (item->mQueueKey ))(
145145 " sending cnt" , ToString (mHttpSendingCnt .load () + 1 )));
@@ -161,7 +161,7 @@ void FlusherRunner::Run() {
161161 if (items.empty ()) {
162162 SenderQueueManager::GetInstance ()->Wait (1000 );
163163 } else {
164- LOG_DEBUG (sLogger , (" got items from sender queue, cnt" , items.size ()));
164+ LOG_TRACE (sLogger , (" got items from sender queue, cnt" , items.size ()));
165165 for (auto itr = items.begin (); itr != items.end (); ++itr) {
166166 ADD_COUNTER (mInItemDataSizeBytes , (*itr)->mData .size ());
167167 ADD_COUNTER (mInItemRawDataSizeBytes , (*itr)->mRawSize );
@@ -171,7 +171,7 @@ void FlusherRunner::Run() {
171171 }
172172
173173 for (auto itr = items.begin (); itr != items.end (); ++itr) {
174- LOG_DEBUG (
174+ LOG_TRACE (
175175 sLogger ,
176176 (" got item from sender queue, item address" ,
177177 *itr)(" config-flusher-dst" , QueueKeyManager::GetInstance ()->GetName ((*itr)->mQueueKey ))(
0 commit comments