From c98f997f7480358bb8179c97418ef352af5bd07a Mon Sep 17 00:00:00 2001
From: Ryan Caudy <ryan@deephaven.io>
Date: Fri, 3 May 2024 13:25:04 -0400
Subject: [PATCH] Add logging when a ReplayTableBase has an error during
 refresh (#5454)

---
 .../engine/table/impl/replay/ReplayTableBase.java      | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/replay/ReplayTableBase.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/replay/ReplayTableBase.java
index fa4ae4ae0b1..a0700b7b9e4 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/replay/ReplayTableBase.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/replay/ReplayTableBase.java
@@ -7,12 +7,16 @@
 import io.deephaven.engine.table.ColumnSource;
 import io.deephaven.engine.table.impl.InstrumentedTableUpdateSource;
 import io.deephaven.engine.table.impl.QueryTable;
+import io.deephaven.internal.log.LoggerFactory;
+import io.deephaven.io.logger.Logger;
 import org.jetbrains.annotations.NotNull;
 
 import java.util.Map;
 
 public abstract class ReplayTableBase extends QueryTable implements Runnable {
 
+    private static final Logger log = LoggerFactory.getLogger(ReplayTableBase.class);
+
     private final SourceRefresher sourceRefresher;
 
     public ReplayTableBase(
@@ -41,5 +45,11 @@ private class SourceRefresher extends InstrumentedTableUpdateSource {
         protected void instrumentedRefresh() {
             ReplayTableBase.this.run();
         }
+
+        @Override
+        protected void onRefreshError(@NotNull final Exception error) {
+            log.error().append("Error refreshing ").append(ReplayTableBase.this).append(": ").append(error).endl();
+            super.onRefreshError(error);
+        }
     }
 }