fix starting point

Signed-off-by: stefan.pingel@consensys.net <stefan.pingel@consensys.net>

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/manager/peertask/task/GetSyncReceiptsFromPeerTask.java

@@ -76,6 +76,7 @@ public GetSyncReceiptsFromPeerTask(
 
     isPoS = protocolSchedule.anyMatch((ps) -> ps.spec().isPoS());
   }
+
   @Override
   public int getRetriesWithOtherPeer() {
     return retries;

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/fastsync/FinishPosSyncStep.java

@@ -51,11 +51,12 @@ public FinishPosSyncStep(
       final ProtocolContext protocolContext,
       final EthContext ethContext,
       final BlockHeader pivotHeader,
-      final boolean transactionIndexingEnabled) {
+      final boolean transactionIndexingEnabled,
+      final long startingBlock) {
     this.protocolContext = protocolContext;
     this.blockchain = ethContext.getBlockchain();
     final long chainHeadBlockNumber = blockchain.getChainHeadBlockNumber();
-    this.nextLowestBlockNumber = (int) (chainHeadBlockNumber + 1);
+    this.nextLowestBlockNumber = startingBlock;
     if (chainHeadBlockNumber != 0) {
       final Optional<BlockHeader> chainHeadBlockHeader =
           blockchain.getBlockHeader(chainHeadBlockNumber);
@@ -67,6 +68,11 @@ public FinishPosSyncStep(
 
   @Override
   public void accept(final List<BlockHeader> blockHeaderRange) {
+    LOG.atInfo()
+        .setMessage("Next lowest block number: {}, lowest block number: {}")
+        .addArgument(nextLowestBlockNumber)
+        .addArgument(blockHeaderRange.getFirst().getNumber())
+        .log();
     final BlockHeaderRange newRange =
         new BlockHeaderRange(
             blockHeaderRange.getFirst(),

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/possync/PosSyncDownloadPipelineFactory.java

@@ -146,10 +146,10 @@ public Pipeline<SyncTargetNumberRange> createDownloadPipelineForSyncTarget(
     final int downloaderParallelism = syncConfig.getDownloaderParallelism();
     final int headerRequestSize = syncConfig.getDownloaderHeaderRequestSize();
 
+    final long startingBlock = getCommonAncestor(target) + 1;
     final PosSyncSource syncSource =
         new PosSyncSource(
-            getCommonAncestor(target)
-                + 1, // TODO remove the +1 when check in DefaultBlockChain is fixed
+            startingBlock, // TODO remove the +1 when check in DefaultBlockChain is fixed
             () -> fastSyncState.getPivotBlockHeader().get().getNumber(),
             headerRequestSize,
             false);
@@ -166,7 +166,8 @@ public Pipeline<SyncTargetNumberRange> createDownloadPipelineForSyncTarget(
             protocolContext,
             ethContext,
             fastSyncState.getPivotBlockHeader().get(),
-            syncConfig.getSnapSyncConfiguration().isSnapSyncTransactionIndexingEnabled());
+            syncConfig.getSnapSyncConfiguration().isSnapSyncTransactionIndexingEnabled(),
+            startingBlock);
 
     return PipelineBuilder.createPipelineFrom(
             "fetchCheckpoints",