diff --git a/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformIT.java b/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformIT.java
index 687f54e85ae93..871402551dd81 100644
--- a/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformIT.java
+++ b/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformIT.java
@@ -590,6 +590,7 @@ public void testContinuousTransformRethrottle() throws Exception {
         deleteTransform(config.getId());
     }
 
+    @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/108561")
     public void testStartTransform_GivenTimeout_Returns408() throws Exception {
         String indexName = "start-transform-timeout-index";
         String transformId = "start-transform-timeout";
diff --git a/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformNodeStatsIT.java b/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformNodeStatsIT.java
index c9385cb2d6224..04483873a2aff 100644
--- a/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformNodeStatsIT.java
+++ b/x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformNodeStatsIT.java
@@ -21,7 +21,6 @@
 import java.util.Map;
 
 import static org.hamcrest.Matchers.equalTo;
-import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.greaterThanOrEqualTo;
 import static org.hamcrest.Matchers.hasKey;
 import static org.hamcrest.Matchers.is;
@@ -60,7 +59,7 @@ public void testTransformNodeStats() throws Exception {
         assertThat(
             "Response was: " + response,
             (int) XContentMapValues.extractValue(response, "total", "scheduler", "registered_transform_count"),
-            is(greaterThan(0))
+            is(equalTo(1))
         );
         for (String nodeId : nodesInfo.keySet()) {
             assertThat(response, hasKey(nodeId));