This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 9dfd6b2d5cd [fix](log) remove some invalid log (#40177)
9dfd6b2d5cd is described below
commit 9dfd6b2d5cd2af8e26aa5a7fb492a709b3a8e544
Author: hui lai <[email protected]>
AuthorDate: Fri Aug 30 17:57:47 2024 +0800
[fix](log) remove some invalid log (#40177)
introduced by https://github.com/apache/doris/pull/37903
---
.../org/apache/doris/load/StreamLoadRecordMgr.java | 28 ++++++++++------------
1 file changed, 13 insertions(+), 15 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
index 020b38158d1..7f1d33bd649 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
@@ -150,19 +150,16 @@ public class StreamLoadRecordMgr extends MasterDaemon {
}
public List<StreamLoadItem> getStreamLoadRecords() {
- LOG.info("test log: {}", streamLoadRecordHeap);
return new ArrayList<>(streamLoadRecordHeap);
}
public List<List<Comparable>> getStreamLoadRecordByDb(
long dbId, String label, boolean accurateMatch, StreamLoadState
state) {
LinkedList<List<Comparable>> streamLoadRecords = new
LinkedList<List<Comparable>>();
- LOG.info("test log: {}", dbId);
readLock();
try {
if (!dbIdToLabelToStreamLoadRecord.containsKey(dbId)) {
- LOG.info("test log: {}", dbId);
return streamLoadRecords;
}
@@ -205,7 +202,6 @@ public class StreamLoadRecordMgr extends MasterDaemon {
}
}
- LOG.info("test log: {}", streamLoadRecords);
return streamLoadRecords;
} finally {
readUnlock();
@@ -273,17 +269,19 @@ public class StreamLoadRecordMgr extends MasterDaemon {
TimeUtils.getDatetimeMsFormatWithTimeZone());
String finishTime =
TimeUtils.longToTimeString(streamLoadItem.getFinishTime(),
TimeUtils.getDatetimeMsFormatWithTimeZone());
- LOG.info("receive stream load record info from backend:
{}."
- + " label: {}, db: {}, tbl: {}, user: {},
user_ip: {},"
- + " status: {}, message: {}, error_url:
{},"
- + " total_rows: {}, loaded_rows: {},
filtered_rows: {}, unselected_rows: {},"
- + " load_bytes: {}, start_time: {},
finish_time: {}.",
- backend.getHost(), streamLoadItem.getLabel(),
streamLoadItem.getDb(),
- streamLoadItem.getTbl(), streamLoadItem.getUser(),
streamLoadItem.getUserIp(),
- streamLoadItem.getStatus(),
streamLoadItem.getMessage(), streamLoadItem.getUrl(),
- streamLoadItem.getTotalRows(),
streamLoadItem.getLoadedRows(),
- streamLoadItem.getFilteredRows(),
streamLoadItem.getUnselectedRows(),
- streamLoadItem.getLoadBytes(), startTime,
finishTime);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("receive stream load record info from
backend: {}."
+ + " label: {}, db: {}, tbl: {}, user:
{}, user_ip: {},"
+ + " status: {}, message: {},
error_url: {},"
+ + " total_rows: {}, loaded_rows: {},
filtered_rows: {}, unselected_rows: {},"
+ + " load_bytes: {}, start_time: {},
finish_time: {}.",
+ backend.getHost(), streamLoadItem.getLabel(),
streamLoadItem.getDb(),
+ streamLoadItem.getTbl(),
streamLoadItem.getUser(), streamLoadItem.getUserIp(),
+ streamLoadItem.getStatus(),
streamLoadItem.getMessage(), streamLoadItem.getUrl(),
+ streamLoadItem.getTotalRows(),
streamLoadItem.getLoadedRows(),
+ streamLoadItem.getFilteredRows(),
streamLoadItem.getUnselectedRows(),
+ streamLoadItem.getLoadBytes(), startTime,
finishTime);
+ }
AuditEvent auditEvent =
new
StreamLoadAuditEvent.AuditEventBuilder().setEventType(EventType.STREAM_LOAD_FINISH)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
