diff --git a/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/TransformTests.java b/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/TransformTests.java index 2fd158c7f76a7..9e6b5979baa64 100644 --- a/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/TransformTests.java +++ b/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/TransformTests.java @@ -42,7 +42,10 @@ public void testNodeAttributes() { Transform transform = createTransform(builder.build()); assertNotNull(transform.additionalSettings()); assertEquals(transformEnabled, Boolean.parseBoolean(transform.additionalSettings().get("node.attr.transform.node"))); - assertEquals(remoteEnabled, Boolean.parseBoolean(transform.additionalSettings().get("node.attr.transform.remote_connect"))); + assertEquals( + transformEnabled && remoteEnabled, + Boolean.parseBoolean(transform.additionalSettings().get("node.attr.transform.remote_connect")) + ); } public void testNodeAttributesDirectlyGiven() { diff --git a/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/transforms/TransformPersistentTasksExecutorTests.java b/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/transforms/TransformPersistentTasksExecutorTests.java index ba51b1c44227f..117bfc4d661da 100644 --- a/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/transforms/TransformPersistentTasksExecutorTests.java +++ b/x-pack/plugin/transform/src/test/java/org/elasticsearch/xpack/transform/transforms/TransformPersistentTasksExecutorTests.java @@ -85,7 +85,7 @@ public void testNodeAssignmentProblems() { assertNull(assignment.getExecutorNode()); assertThat( assignment.getExplanation(), - equalTo("Not starting transform [new-task-id], reasons [current-data-node-with-transform-disabled:transform not enabled]") + equalTo("Not starting transform [new-task-id], reasons [current-data-node-with-transform-disabled:not a transform node]") ); // dedicated transform node @@ -108,7 +108,7 @@ public void testNodeAssignmentProblems() { assignment.getExplanation(), equalTo( "Not starting transform [new-task-id], reasons [" - + "current-data-node-with-transform-disabled:transform not enabled" + + "current-data-node-with-transform-disabled:not a transform node" + "|" + "past-data-node-1:node has version: 7.5.0 but transform requires at least 7.7.0" + "]" @@ -154,7 +154,7 @@ public void testNodeAssignmentProblems() { + "current-data-node-with-0-tasks-transform-remote-disabled:" + "transform requires a remote connection but remote is disabled" + "|" - + "current-data-node-with-transform-disabled:transform not enabled" + + "current-data-node-with-transform-disabled:not a transform node" + "]" ) );