diff --git a/service/history/replication/raw_task_converter.go b/service/history/replication/raw_task_converter.go
index 5a090ad8a80..fa1867e427d 100644
--- a/service/history/replication/raw_task_converter.go
+++ b/service/history/replication/raw_task_converter.go
@@ -108,11 +108,13 @@ func (c *SourceTaskConverterImpl) Convert(
 	if err != nil {
 		return nil, err
 	}
-	rawTaskInfo, err := c.serializer.ParseReplicationTaskInfo(task)
-	if err != nil {
-		return nil, err
+	if replicationTask != nil {
+		rawTaskInfo, err := c.serializer.ParseReplicationTaskInfo(task)
+		if err != nil {
+			return nil, err
+		}
+		replicationTask.RawTaskInfo = rawTaskInfo
 	}
-	replicationTask.RawTaskInfo = rawTaskInfo
 	return replicationTask, nil
 }