diff --git a/node/src/main/scala/com/wavesplatform/network/InvalidBlockStorage.scala b/node/src/main/scala/com/wavesplatform/network/InvalidBlockStorage.scala index 2bae04cd2d..5ad557f7ae 100644 --- a/node/src/main/scala/com/wavesplatform/network/InvalidBlockStorage.scala +++ b/node/src/main/scala/com/wavesplatform/network/InvalidBlockStorage.scala @@ -4,6 +4,7 @@ import com.google.common.cache.CacheBuilder import com.wavesplatform.common.state.ByteStr import com.wavesplatform.lang.ValidationError import com.wavesplatform.network.InvalidBlockStorageImpl.* +import com.wavesplatform.transaction.TxValidationError.BlockFromFuture import scala.concurrent.duration.FiniteDuration @@ -26,7 +27,11 @@ class InvalidBlockStorageImpl(settings: InvalidBlockStorageSettings) extends Inv .expireAfterWrite(settings.timeout.length, settings.timeout.unit) .build[ByteStr, ValidationError]() - override def add(blockId: ByteStr, validationError: ValidationError): Unit = cache.put(blockId, validationError) + override def add(blockId: ByteStr, validationError: ValidationError): Unit = + validationError match { + case _: BlockFromFuture => // ignore because it's a temporary error + case _ => cache.put(blockId, validationError) + } override def find(blockId: ByteStr): Option[ValidationError] = Option(cache.getIfPresent(blockId)) }