diff --git a/test/engine/setup/subscriber/sls.go b/test/engine/setup/subscriber/sls.go
index 00e456c70a..131bd2281e 100644
--- a/test/engine/setup/subscriber/sls.go
+++ b/test/engine/setup/subscriber/sls.go
@@ -273,11 +273,6 @@ func init() {
 		} else {
 			l.Project = config.TestConfig.Project
 		}
-		if v, ok := spec["logstore"]; ok {
-			l.Logstore = v.(string)
-		} else {
-			l.Logstore = config.TestConfig.Logstore
-		}
 		if v, ok := spec["query_endpoint"]; ok {
 			l.QueryEndpoint = v.(string)
 		} else {
@@ -288,6 +283,11 @@ func init() {
 		} else {
 			l.TelemetryType = "logs"
 		}
+		if v, ok := spec["logstore"]; ok {
+			l.Logstore = v.(string)
+		} else {
+			l.Logstore = config.TestConfig.GetLogstore(l.TelemetryType)
+		}
 		l.client = createSLSClient(config.TestConfig.AccessKeyID, config.TestConfig.AccessKeySecret, l.QueryEndpoint)
 		return l, nil
 	})