diff --git a/sermant-plugins/sermant-mq-grayscale/mq-grayscale-rocketmq-plugin/src/main/java/io/sermant/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java b/sermant-plugins/sermant-mq-grayscale/mq-grayscale-rocketmq-plugin/src/main/java/io/sermant/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java
index 0e389c7e1..0de50bb9c 100644
--- a/sermant-plugins/sermant-mq-grayscale/mq-grayscale-rocketmq-plugin/src/main/java/io/sermant/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java
+++ b/sermant-plugins/sermant-mq-grayscale/mq-grayscale-rocketmq-plugin/src/main/java/io/sermant/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java
@@ -71,7 +71,7 @@ public ExecuteContext doAfter(ExecuteContext context) throws Exception {
     }
 
     private boolean isGrayTagChanged(ConcurrentMap<String, Object> map, RebalanceImpl balance,
-        List<Object> retrySubscriptionDatas) {
+            List<Object> retrySubscriptionDatas) {
         String topic = "";
         for (Object subscriptionData : map.values()) {
             String tempTopic = RocketMqReflectUtils.getTopic(subscriptionData);
@@ -86,8 +86,6 @@ private boolean isGrayTagChanged(ConcurrentMap<String, Object> map, RebalanceImp
 
     private void updateRetrySubscriptionData(Object subscriptionData, Collection<Object> retrySubscriptionDatas) {
         for (Object subData : retrySubscriptionDatas) {
-            String retryTopic = RocketMqReflectUtils.getTopic(subData);
-            String sqlSubstr = RocketMqReflectUtils.getSubString(subscriptionData);
             RocketMqReflectUtils.getTagsSet(subData).clear();
             RocketMqReflectUtils.getCodeSet(subData).clear();
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setExpressionType",
@@ -95,12 +93,14 @@ private void updateRetrySubscriptionData(Object subscriptionData, Collection<Obj
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setSubVersion",
                 new Class[]{long.class}, new Object[]{System.currentTimeMillis()});
             String originSubData = RocketMqReflectUtils.getSubString(subData);
+            String sqlSubstr = RocketMqReflectUtils.getSubString(subscriptionData);
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setSubString",
                 new Class[]{String.class}, new Object[]{sqlSubstr});
             String originTopic = RocketMqReflectUtils.getTopic(subscriptionData);
+            String retryTopic = RocketMqReflectUtils.getTopic(subData);
             LOGGER.warning(String.format(Locale.ENGLISH, "update retry topic [%s] SQL92 expression, "
                     + "originTopic: [%s], originSubStr: [%s], newSubStr: [%s]", retryTopic, originTopic,
-                originSubData, sqlSubstr));
+                    originSubData, sqlSubstr));
         }
     }