diff --git a/src/sagemaker/feature_store/feature_group.py b/src/sagemaker/feature_store/feature_group.py
index 855e11488f..ae951825b7 100644
--- a/src/sagemaker/feature_store/feature_group.py
+++ b/src/sagemaker/feature_store/feature_group.py
@@ -365,12 +365,10 @@ def _run_multi_threaded(
         failed_indices = list()
         for future in as_completed(futures, timeout=timeout):
             start, end = futures[future]
-            result = future.result()
-            if result:
-                logger.error("Failed to ingest row %d to %d", start, end)
-            else:
+            failed_rows = future.result()
+            if not failed_rows:
                 logger.info("Successfully ingested row %d to %d", start, end)
-            failed_indices += result
+            failed_indices += failed_rows
 
         executor.shutdown(wait=False)