diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt
index 6ee6c0b4..7c7bb5b9 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt
@@ -73,10 +73,10 @@ abstract class AbstractHead @JvmOverloads constructor(
             completed = false
         }
         return source
-            .distinctUntilChanged {
-                it.hash
+            .filter {
+                log.debug("Filtering block $upstreamId block $it")
+                forkChoice.filter(it)
             }
-            .filter { forkChoice.filter(it) }
             .doFinally {
                 // close internal stream if upstream is finished, otherwise it gets stuck,
                 // but technically it should never happen during normal work, only when the Head