[nifi] branch main updated: NIFI-11976 Removed error log check in TestListenTCPRecord

[mattyb149]

This is an automated email from the ASF dual-hosted git repository.

mattyb149 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 016834efaa NIFI-11976 Removed error log check in TestListenTCPRecord
016834efaa is described below

commit 016834efaaeb19abb593816d2683f8eb3f358204
Author: exceptionfactory <exceptionfact...@apache.org>
AuthorDate: Tue Aug 22 09:12:34 2023 -0500

    NIFI-11976 Removed error log check in TestListenTCPRecord
    
    Signed-off-by: Matt Burgess <mattyb...@apache.org>
    
    This closes #7635
---
 .../org/apache/nifi/processors/standard/TestListenTCPRecord.java    | 6 ------
 1 file changed, 6 deletions(-)

diff --git 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenTCPRecord.java
 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenTCPRecord.java
index be38dc32e1..500501e5bf 100644
--- 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenTCPRecord.java
+++ 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenTCPRecord.java
@@ -26,7 +26,6 @@ import org.apache.nifi.serialization.RecordSetWriterFactory;
 import org.apache.nifi.serialization.record.MockRecordWriter;
 import org.apache.nifi.ssl.RestrictedSSLContextService;
 import org.apache.nifi.ssl.SSLContextService;
-import org.apache.nifi.util.LogMessage;
 import org.apache.nifi.util.MockFlowFile;
 import org.apache.nifi.util.TestRunner;
 import org.apache.nifi.util.TestRunners;
@@ -45,11 +44,9 @@ import java.io.OutputStream;
 import java.net.Socket;
 import java.nio.charset.StandardCharsets;
 import java.util.List;
-import java.util.Optional;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 public class TestListenTCPRecord {
@@ -236,9 +233,6 @@ public class TestListenTCPRecord {
         while (getSuccessCount() < expectedTransferred) {
             runner.run(1, false, false);
             iterations++;
-
-            final Optional<LogMessage> firstErrorMessage = 
runner.getLogger().getErrorMessages().stream().findFirst();
-            assertNull(firstErrorMessage.orElse(null));
         }
         LOGGER.info("Completed after iterations [{}]", iterations);
     }