Skip to content

Commit e42cff3

Browse files
committed
Remove logs from monitor
1 parent 325f7e6 commit e42cff3

File tree

14 files changed

+8
-728
lines changed

14 files changed

+8
-728
lines changed

assemble/conf/log4j2-service.properties

-10
Original file line numberDiff line numberDiff line change
@@ -67,14 +67,6 @@ appender.audit.policies.size.size=512MB
6767
appender.audit.strategy.type = DefaultRolloverStrategy
6868
appender.audit.strategy.max = 10
6969

70-
appender.monitor.type = AccumuloMonitor
71-
appender.monitor.name = MonitorLog
72-
appender.monitor.filter.threshold.type = ThresholdFilter
73-
appender.monitor.filter.threshold.level = warn
74-
#appender.monitor.async = true
75-
#appender.monitor.maxThreads = 2
76-
#appender.monitor.queueSize = 1024
77-
7870
logger.zookeeper.name = org.apache.zookeeper
7971
logger.zookeeper.level = error
8072

@@ -90,5 +82,3 @@ logger.accumulo.level = debug
9082
rootLogger.level = info
9183
rootLogger.appenderRef.console.ref = STDERR
9284
rootLogger.appenderRef.rolling.ref = LogFiles
93-
rootLogger.appenderRef.monitor.ref = MonitorLog
94-

server/monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java

-6
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,6 @@
8181
import org.apache.accumulo.monitor.rest.compactions.external.ExternalCompactionInfo;
8282
import org.apache.accumulo.monitor.rest.compactions.external.RunningCompactions;
8383
import org.apache.accumulo.monitor.rest.compactions.external.RunningCompactorDetails;
84-
import org.apache.accumulo.monitor.util.logging.RecentLogs;
8584
import org.apache.accumulo.server.AbstractServer;
8685
import org.apache.accumulo.server.HighlyAvailableService;
8786
import org.apache.accumulo.server.ServerContext;
@@ -615,7 +614,6 @@ public static class CompactionStats {
615614
private final Map<HostAndPort,ScanStats> tserverScans = new HashMap<>();
616615
private final Map<HostAndPort,ScanStats> sserverScans = new HashMap<>();
617616
private final Map<HostAndPort,CompactionStats> allCompactions = new HashMap<>();
618-
private final RecentLogs recentLogs = new RecentLogs();
619617
private final ExternalCompactionInfo ecInfo = new ExternalCompactionInfo();
620618

621619
private long scansFetchedNanos = System.nanoTime();
@@ -1038,10 +1036,6 @@ public boolean isActiveService() {
10381036
return monitorInitialized.get();
10391037
}
10401038

1041-
public RecentLogs recentLogs() {
1042-
return recentLogs;
1043-
}
1044-
10451039
public Optional<HostAndPort> getCoordinatorHost() {
10461040
return coordinatorHost;
10471041
}

server/monitor/src/main/java/org/apache/accumulo/monitor/rest/logs/LogResource.java

-75
This file was deleted.

server/monitor/src/main/java/org/apache/accumulo/monitor/rest/logs/SanitizedLogEvent.java

-67
This file was deleted.

server/monitor/src/main/java/org/apache/accumulo/monitor/rest/logs/SingleLogEvent.java

-38
This file was deleted.

server/monitor/src/main/java/org/apache/accumulo/monitor/rest/status/StatusInformation.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,6 @@ public class StatusInformation {
3131
public String tServerStatus = null;
3232
public String coordinatorStatus = null;
3333

34-
public Integer logNumber = 0;
35-
public boolean logsHaveError = false;
3634
public Integer problemNumber = 0;
3735

3836
public StatusInformation() {}
@@ -44,18 +42,14 @@ public StatusInformation() {}
4442
* @param gcStatus Status for the GC
4543
* @param tServerStatus Status for the tserver
4644
* @param coordinatorStatus Status for the Compaction Coordinator
47-
* @param logNumber Number of log reports
48-
* @param logsHaveError Check if log reports include errors
4945
* @param problemNumber Number of problems per table
5046
*/
5147
public StatusInformation(String managerStatus, String gcStatus, String tServerStatus,
52-
String coordinatorStatus, Integer logNumber, boolean logsHaveError, Integer problemNumber) {
48+
String coordinatorStatus, Integer problemNumber) {
5349
this.managerStatus = managerStatus;
5450
this.gcStatus = gcStatus;
5551
this.tServerStatus = tServerStatus;
5652
this.coordinatorStatus = coordinatorStatus;
57-
this.logNumber = logNumber;
58-
this.logsHaveError = logsHaveError;
5953
this.problemNumber = problemNumber;
6054

6155
}

server/monitor/src/main/java/org/apache/accumulo/monitor/rest/status/StatusResource.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public StatusInformation getTables() {
9797
}
9898

9999
return new StatusInformation(managerStatus.toString(), gcStatus.toString(),
100-
tServerStatus.toString(), coordinatorStatus.toString(), monitor.recentLogs().numEvents(),
101-
monitor.recentLogs().eventsIncludeErrors(), monitor.getProblemSummary().entrySet().size());
100+
tServerStatus.toString(), coordinatorStatus.toString(),
101+
monitor.getProblemSummary().entrySet().size());
102102
}
103103
}

0 commit comments

Comments
 (0)