diff --git a/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/OpenSearchLoggingHandlerIT.java b/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/OpenSearchLoggingHandlerIT.java index c1c689471fc82..4d029db812439 100644 --- a/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/OpenSearchLoggingHandlerIT.java +++ b/modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/OpenSearchLoggingHandlerIT.java @@ -66,12 +66,13 @@ public void tearDown() throws Exception { @TestLogging(value = "org.opensearch.transport.netty4.OpenSearchLoggingHandler:trace,org.opensearch.transport.TransportLogger:trace", reason = "to ensure we log network events on TRACE level") public void testLoggingHandler() { - final String writePattern = ".*\\[length: \\d+" + final String writePattern = "^.*\\[length: \\d+" + ", request id: \\d+" + ", type: request" - + ", version: .*" + + ", version: [^,]+" + + ", header size: \\d+B" + ", action: cluster:monitor/nodes/hot_threads\\[n\\]\\]" - + " WRITE: \\d+B"; + + " WRITE: \\d+B$"; final MockLogAppender.LoggingExpectation writeExpectation = new MockLogAppender.PatternSeenEventExpectation( "hot threads request", TransportLogger.class.getCanonicalName(), @@ -86,12 +87,12 @@ public void testLoggingHandler() { "*FLUSH*" ); - final String readPattern = ".*\\[length: \\d+" + final String readPattern = "^.*\\[length: \\d+" + ", request id: \\d+" + ", type: request" - + ", version: .*" + + ", version: [^,]+" + ", action: cluster:monitor/nodes/hot_threads\\[n\\]\\]" - + " READ: \\d+B"; + + " READ: \\d+B$"; final MockLogAppender.LoggingExpectation readExpectation = new MockLogAppender.PatternSeenEventExpectation( "hot threads request",