diff --git a/lnst/Recipes/ENRT/MeasurementGenerators/BaseFlowMeasurementGenerator.py b/lnst/Recipes/ENRT/MeasurementGenerators/BaseFlowMeasurementGenerator.py
index 20a788564..7a4c51b00 100644
--- a/lnst/Recipes/ENRT/MeasurementGenerators/BaseFlowMeasurementGenerator.py
+++ b/lnst/Recipes/ENRT/MeasurementGenerators/BaseFlowMeasurementGenerator.py
@@ -147,16 +147,16 @@ def _create_perf_flows(
         for endpoint_pair in endpoint_pairs:
             client, server = endpoint_pair
             for i in range(self.params.perf_parallel_processes):
-                port = next(port_iter)
+                server_port = client_port = next(port_iter)
                 flows.append(
                     self._create_perf_flow(
                         perf_test,
                         client.device,
                         client.address,
-                        port,
+                        client_port if perf_test != "mptcp_stream" else None,
                         server.device,
                         server.address,
-                        port,
+                        server_port,
                         msg_size,
                         self.generator_cpupin(i),
                         self.receiver_cpupin(i),