emiliosetiadarma commented on code in PR #6262: URL: https://github.com/apache/nifi/pull/6262#discussion_r934792629
########## nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/test/java/org/apache/nifi/cluster/coordination/http/replication/TestThreadPoolRequestReplicator.java: ########## @@ -352,26 +353,20 @@ protected NodeResponse replicateRequest(final PreparedRequest request, final Nod } }; - try { - // set the user + final Exception exception = assertThrows(Exception.class, () -> { final Authentication authentication = new NiFiAuthenticationToken(new NiFiUserDetails(StandardNiFiUser.ANONYMOUS)); SecurityContextHolder.getContext().setAuthentication(authentication); final AsyncClusterResponse clusterResponse = replicator.replicate(nodeIds, HttpMethod.POST, new URI("http://localhost:80/processors/1"), new ProcessorEntity(), new HashMap<>(), true, true); clusterResponse.awaitMergedResponse(); - - Assert.fail("Expected to get an IllegalClusterStateException but did not"); - } catch (final IllegalClusterStateException e) { - // Expected - } catch (final Exception e) { - Assert.fail(e.toString()); - } finally { - replicator.shutdown(); - } + }); + assertTrue(exception instanceof IllegalClusterStateException); + replicator.shutdown(); } - @Test(timeout = 5000) + @Test + @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS) Review Comment: Making the changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@nifi.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org