diff --git a/nodes/decklink-out/src/decklink_out_node.cpp b/nodes/decklink-out/src/decklink_out_node.cpp
index 4278194..e51a641 100644
--- a/nodes/decklink-out/src/decklink_out_node.cpp
+++ b/nodes/decklink-out/src/decklink_out_node.cpp
@@ -239,12 +239,16 @@ void DeckLinkOutNode::process() {
         if (status == MXL_ERR_OUT_OF_RANGE_TOO_LATE || status == MXL_ERR_OUT_OF_RANGE_TOO_EARLY) {
             auto now = mxlGetTime();
             auto current_index = mxlTimestampToIndex(&flow_rate_, now);
-            read_index_ = current_index - 2;
-            if (grains_read_ == 0) {
-                spdlog::warn("DeckLink-out: realigned to source index {}", read_index_);
+            spdlog::warn("DeckLink-out: realigned from {} to {}", source_index, current_index - 2);
+            source_index = current_index - 2;
+
+            status = mxlFlowReaderGetGrain(*reader_, source_index, 5000000ULL, &grain_info, &payload);
+            if (status != MXL_STATUS_OK) {
+                return;
             }
+        } else {
+            return;
         }
-        return;
     }
 
     mxlFlowConfigInfo config{};