From be1360e7d042db0cfa5730cf04be39666525404d Mon Sep 17 00:00:00 2001 From: Sanket Kedia Date: Thu, 12 Dec 2024 16:57:02 -0800 Subject: [PATCH] Remove some traces --- go/pkg/log/purging/main.go | 2 -- go/pkg/log/repository/log.go | 5 ----- 2 files changed, 7 deletions(-) diff --git a/go/pkg/log/purging/main.go b/go/pkg/log/purging/main.go index 9925e508925..ae3cbe5ec52 100644 --- a/go/pkg/log/purging/main.go +++ b/go/pkg/log/purging/main.go @@ -27,14 +27,12 @@ func PerformPurgingLoop(ctx context.Context, lg *repository.LogRepository) { log.Error("failed to purge records", zap.Error(err)) continue } - log.Info("purged records") case <-gcTicker.C: // TODO: Add a RPC to manually trigger garbage collection if err := lg.GarbageCollection(ctx); err != nil { log.Error("failed to garbage collect", zap.Error(err)) continue } - log.Info("garbage collected") } } } diff --git a/go/pkg/log/repository/log.go b/go/pkg/log/repository/log.go index fd79c6d6815..216c84c4bb1 100644 --- a/go/pkg/log/repository/log.go +++ b/go/pkg/log/repository/log.go @@ -149,7 +149,6 @@ func (r *LogRepository) UpdateCollectionCompactionOffsetPosition(ctx context.Con } func (r *LogRepository) PurgeRecords(ctx context.Context) (err error) { - trace_log.Info("Purging records from record_log table") err = r.queries.PurgeRecords(ctx) return } @@ -175,8 +174,6 @@ func (r *LogRepository) GarbageCollection(ctx context.Context) error { if err != nil { trace_log.Error("Error in getting collections to compact", zap.Error(err)) return err - } else { - trace_log.Info("GC Got collections to compact", zap.Int("collectionCount", len(collectionToCompact))) } if collectionToCompact == nil { return nil @@ -213,13 +210,11 @@ func (r *LogRepository) GarbageCollection(ctx context.Context) error { err = tx.Commit(ctx) } }() - trace_log.Info("Starting garbage collection", zap.Strings("collections", collectionsToGC)) err = queriesWithTx.DeleteRecords(ctx, collectionsToGC) if err != nil { trace_log.Error("Error in garbage collection", zap.Error(err)) return err } - trace_log.Info("Delete collections", zap.Strings("collections", collectionsToGC)) err = queriesWithTx.DeleteCollection(ctx, collectionsToGC) if err != nil { trace_log.Error("Error in deleting collection", zap.Error(err))