diff --git a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/pom.xml b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/pom.xml index a38d87b30e..a1cab035d8 100644 --- a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/pom.xml +++ b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/pom.xml @@ -74,13 +74,6 @@ 1.10.0-SNAPSHOT test - - org.apache.nifi - nifi-standard-processors - 1.10.0-SNAPSHOT - test - test-jar - org.eclipse.jetty jetty-server diff --git a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/test/java/org/apache/nifi/processors/livy/ExecuteSparkInteractiveTestBase.java b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/test/java/org/apache/nifi/processors/livy/ExecuteSparkInteractiveTestBase.java index f0076e7853..18fbdebe75 100644 --- a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/test/java/org/apache/nifi/processors/livy/ExecuteSparkInteractiveTestBase.java +++ b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/test/java/org/apache/nifi/processors/livy/ExecuteSparkInteractiveTestBase.java @@ -112,6 +112,7 @@ class ExecuteSparkInteractiveTestBase { runner.run(); List waitingFlowfiles = runner.getFlowFilesForRelationship(ExecuteSparkInteractive.REL_WAIT); while (!waitingFlowfiles.isEmpty()) { + runner.assertTransferCount(ExecuteSparkInteractive.REL_FAILURE, 0); Thread.sleep(1000); runner.clearTransferState(); runner.enqueue(code);