diff --git a/muted-tests.yml b/muted-tests.yml
index e7c11a4c9cd1e..ce0c2a16965ef 100644
--- a/muted-tests.yml
+++ b/muted-tests.yml
@@ -315,15 +315,9 @@ tests:
 - class: org.elasticsearch.compute.lucene.read.ValuesSourceReaderOperatorTests
   method: testWithNulls
   issue: https://github.com/elastic/elasticsearch/issues/142434
-- class: org.elasticsearch.compute.operator.MMROperatorTests
-  method: testSimpleLargeInput
-  issue: https://github.com/elastic/elasticsearch/issues/142437
 - class: org.elasticsearch.xpack.esql.common.spatial.H3SphericalGeometryTests
   method: testIndexPoints
   issue: https://github.com/elastic/elasticsearch/issues/142439
-- class: org.elasticsearch.compute.operator.MMROperatorTests
-  method: testSimpleSmallInput
-  issue: https://github.com/elastic/elasticsearch/issues/142436
 - class: org.elasticsearch.xpack.esql.core.util.RemoteClusterUtilsTests
   method: testQualifyAndJoinIndices
   issue: https://github.com/elastic/elasticsearch/issues/142442
diff --git a/x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/MMROperatorTests.java b/x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/MMROperatorTests.java
index 7bbead4e0a4a6..07c18686d7f81 100644
--- a/x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/MMROperatorTests.java
+++ b/x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/MMROperatorTests.java
@@ -22,9 +22,6 @@
 import static org.hamcrest.Matchers.equalTo;
 
 public class MMROperatorTests extends OperatorTestCase {
-
-    public static double NULL_BLOCK_CHANCE = 0.05;
-
     static List<float[]> TEST_VECTORS = List.of(
         new float[] { 0.4f, 0.2f, 0.4f, 0.4f },
         new float[] { 0.4f, 0.2f, 0.3f, 0.3f },
@@ -53,13 +50,9 @@ protected int remaining() {
             @Override
             protected Page createPage(int positionOffset, int length) {
                 length = Integer.min(length, remaining());
+                currentPosition += length;
                 var blocks = new Block[1];
 
-                if (randomDouble() < NULL_BLOCK_CHANCE) {
-                    blocks[0] = blockFactory.newConstantNullBlock(length);
-                    return new Page(blocks);
-                }
-
                 float[] vectors = new float[length * 4];
                 int[] vectorPositions = new int[length + 1];
                 int vectorIndex = 0;
@@ -77,7 +70,7 @@ protected Page createPage(int positionOffset, int length) {
                     blocks[0] = blockFactory.newFloatArrayBlock(vectors, length, vectorPositions, new BitSet(), Block.MvOrdering.UNORDERED);
                 } catch (Exception e) {
                     throw new RuntimeException(e);
-                } finally {}
+                }
 
                 finish();
                 return new Page(blocks);