NIFI-11976 Removed error log check in TestListenTCPRecord

Signed-off-by: Matt Burgess <mattyb149@apache.org>

This closes #7635
This commit is contained in:
exceptionfactory 2023-08-22 09:12:34 -05:00 committed by Matt Burgess
parent 25d775b965
commit 016834efaa
1 changed files with 0 additions and 6 deletions

View File

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