diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/SourceMapper.java b/modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/SourceMapper.java
index 310de6381f..66c618e1b8 100644
--- a/modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/SourceMapper.java
+++ b/modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/SourceMapper.java
@@ -149,7 +149,7 @@ public final void onEvent(Object eventObject, Object[] transportProperties, Stri
                     for (Object property : transportProperties) {
                         if (property == null) {
                             log.error("Dropping event " + eventObject.toString() + " belonging to stream " +
-                                    sourceHandler.getInputHandler().getStreamId()
+                                    streamDefinition.getId()
                                     + " as it contains null transport properties and system "
                                     + "is configured to not allow null transport properties. You can "
                                     + "configure it via source mapper if the respective "