diff --git a/ingest/ledger_change_reader.go b/ingest/ledger_change_reader.go
index cd0646dd2b..8b3668be16 100644
--- a/ingest/ledger_change_reader.go
+++ b/ingest/ledger_change_reader.go
@@ -121,7 +121,7 @@ func (c *compactingChangeReader) Close() error {
 }
 
 // NewCompactingChangeReader wraps a given ChangeReader and returns a ChangeReader
-// which compacts all the the Changes extracted from the input.
+// which compacts all the Changes extracted from the input.
 func NewCompactingChangeReader(input ChangeReader, config ChangeCompactorConfig) ChangeReader {
 	return &compactingChangeReader{
 		input:  input,
diff --git a/ingest/ledgerbackend/ledger_buffer.go b/ingest/ledgerbackend/ledger_buffer.go
index daa15b7e6f..e6fef1b19f 100644
--- a/ingest/ledgerbackend/ledger_buffer.go
+++ b/ingest/ledgerbackend/ledger_buffer.go
@@ -159,7 +159,7 @@ func (lb *ledgerBuffer) worker(ctx context.Context) {
 				// When we store an object we still maintain the ledger buffer invariant because
 				// at this point the current task is finished and we add 1 ledger object to the priority queue.
 				// Thus, the number of tasks decreases by 1 and the priority queue length increases by 1.
-				// This keeps the overall total the same (<= BufferSize). As long as the the ledger buffer invariant
+				// This keeps the overall total the same (<= BufferSize). As long as the ledger buffer invariant
 				// was maintained in the previous state, it is still maintained during this state transition.
 				lb.storeObject(ledgerObject, sequence)
 				break