Truncate logs

server/modules/elastalert/elastalert.go

@@ -572,7 +572,7 @@ func (e *ElastAlertEngine) startCommunityRuleImport() {
 			// there were errors, don't save the fingerprint.
 			// idempotency means we might fix it if we try again later.
 			log.WithFields(log.Fields{
-				"errors": errMap,
+				"errors": mutil.TruncateMap(errMap, 5),
 			}).Error("unable to sync all ElastAlert community detections")
 
 			if e.notify {
@@ -877,7 +877,7 @@ func (e *ElastAlertEngine) syncCommunityDetections(ctx context.Context, detectio
 		"updated":   results.Updated,
 		"removed":   results.Removed,
 		"unchanged": results.Unchanged,
-		"errors":    errMap,
+		"errors":    mutil.TruncateMap(errMap, 5),
 	}).Info("elastalert community diff")
 
 	return errMap, nil

server/modules/util/detengine_helpers.go

@@ -69,6 +69,23 @@ func readStateFile(iom IOManager, path string) (lastImport *uint64, err error) {
 	return &unix, nil
 }
 
+func TruncateMap(originalMap map[string]error, limit int) map[string]error {
+	if len(originalMap) <= limit {
+		return originalMap // Return the original map if it's already within the limit
+	}
+
+	truncatedMap := make(map[string]error, limit)
+	count := 0
+	for key, value := range originalMap {
+		if count >= limit {
+			break
+		}
+		truncatedMap[key] = value
+		count++
+	}
+	return truncatedMap
+}
+
 func WriteStateFile(iom IOManager, path string) {
 	unix := time.Now().Unix()
 	sUnix := strconv.FormatInt(unix, 10)