diff --git a/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java b/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java
index 1ffefe67d0..b627446fbe 100644
--- a/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java
+++ b/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java
@@ -159,7 +159,8 @@ public void processManualFlushRequest(String flowId, FlowThrottlingData throttli
         FlowResponse flowData;
         RerouteQueue rerouteQueue = getRerouteQueue(flowId);
         if (rerouteQueue.hasInProgress()) {
-            rerouteQueue.putToInProgress(null);
+            rerouteQueue.setInProgress(null);
+            rerouteQueue.setPending(null);
             flowData = new FlowResponse(FlowDto.builder()
                     .state(FlowState.IN_PROGRESS)
                     .statusInfo("Reroute has flushed").build());