diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheCornerCasesTest.java b/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheCornerCasesTest.java
index af1a3ec108..a736145d99 100644
--- a/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheCornerCasesTest.java
+++ b/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheCornerCasesTest.java
@@ -136,7 +136,7 @@ public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
         for (LoggingEvent logEvent : log) {
             String message = String.valueOf(logEvent.getMessage());
             if (message.contains(":")) {
-                message = message.split(": ")[1];
+                message = message.split(":")[1].trim();
             }
             logMessages.add(message);
         }
diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheExpiryAndReloadTestCase.java b/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheExpiryAndReloadTestCase.java
index a8aef5ba81..d9ba87281a 100644
--- a/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheExpiryAndReloadTestCase.java
+++ b/modules/siddhi-core/src/test/java/io/siddhi/core/query/table/cache/CacheExpiryAndReloadTestCase.java
@@ -67,7 +67,7 @@ public void expiryAndReloadTest0() throws InterruptedException, SQLException {
         for (LoggingEvent logEvent : log) {
             String message = String.valueOf(logEvent.getMessage());
             if (message.contains(":")) {
-                message = message.split(": ")[1];
+                message = message.split(":")[1].trim();
             }
             logMessages.add(message);
         }
@@ -155,7 +155,7 @@ public void expiryAndReloadTest1() throws InterruptedException, SQLException {
         for (LoggingEvent logEvent : log) {
             String message = String.valueOf(logEvent.getMessage());
             if (message.contains(":")) {
-                message = message.split(": ")[1];
+                message = message.split(":")[1].trim();
             }
             logMessages.add(message);
         }
@@ -244,7 +244,7 @@ public void expiryAndReloadTest2() throws InterruptedException, SQLException {
         for (LoggingEvent logEvent : log) {
             String message = String.valueOf(logEvent.getMessage());
             if (message.contains(":")) {
-                message = message.split(": ")[1];
+                message = message.split(":")[1].trim();
             }
             logMessages.add(message);
         }
@@ -334,7 +334,7 @@ public void expiryAndReloadTest3() throws InterruptedException, SQLException {
         for (LoggingEvent logEvent : log) {
             String message = String.valueOf(logEvent.getMessage());
             if (message.contains(":")) {
-                message = message.split(": ")[1];
+                message = message.split(":")[1].trim();
             }
             logMessages.add(message);
         }