Add logging when a ReplayTableBase has an error during refresh (#5454)

deephaven · May 3, 2024 · c98f997 · c98f997
1 parent 061943d
commit c98f997
Showing 1 changed file with 10 additions and 0 deletions.
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
@@ -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);
+        }
     }
 }