diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/threadlocal/InternalThreadLocalMap.java b/dubbo-common/src/main/java/org/apache/dubbo/common/threadlocal/InternalThreadLocalMap.java
index e683b28512..3f3dfe4141 100644
--- a/dubbo-common/src/main/java/org/apache/dubbo/common/threadlocal/InternalThreadLocalMap.java
+++ b/dubbo-common/src/main/java/org/apache/dubbo/common/threadlocal/InternalThreadLocalMap.java
@@ -55,6 +55,26 @@ public final class InternalThreadLocalMap {
         return slowGet();
     }
 
+    public static InternalThreadLocalMap getAndRemove() {
+        try {
+            Thread thread = Thread.currentThread();
+            if (thread instanceof InternalThread) {
+                return ((InternalThread) thread).threadLocalMap();
+            }
+            return slowThreadLocalMap.get();
+        } finally {
+            remove();
+        }
+    }
+
+    public static void set(InternalThreadLocalMap internalThreadLocalMap) {
+        Thread thread = Thread.currentThread();
+        if (thread instanceof InternalThread) {
+            ((InternalThread) thread).setThreadLocalMap(internalThreadLocalMap);
+        }
+        slowThreadLocalMap.set(internalThreadLocalMap);
+    }
+
     public static void remove() {
         Thread thread = Thread.currentThread();
         if (thread instanceof InternalThread) {
diff --git a/dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java b/dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java
index 1b99521c8d..2d4f734c88 100644
--- a/dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java
+++ b/dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java
@@ -18,6 +18,7 @@ package org.apache.dubbo.rpc.protocol.injvm;
 
 import org.apache.dubbo.common.URL;
 import org.apache.dubbo.common.constants.CommonConstants;
+import org.apache.dubbo.common.threadlocal.InternalThreadLocalMap;
 import org.apache.dubbo.common.threadpool.manager.ExecutorRepository;
 import org.apache.dubbo.common.utils.ArrayUtils;
 import org.apache.dubbo.common.utils.ReflectUtils;
@@ -129,7 +130,14 @@ public class InjvmInvoker<T> extends AbstractInvoker<T> {
             result.setExecutor(executor);
             return result;
         } else {
-            Result result = invoker.invoke(copiedInvocation);
+            Result result;
+            // clear thread local before child invocation, prevent context pollution
+            InternalThreadLocalMap originTL = InternalThreadLocalMap.getAndRemove();
+            try {
+                result = invoker.invoke(copiedInvocation);
+            } finally {
+                InternalThreadLocalMap.set(originTL);
+            }
             if (result.hasException()) {
                 AsyncRpcResult rpcResult = AsyncRpcResult.newDefaultAsyncResult(result.getException(), copiedInvocation);
                 rpcResult.setObjectAttachments(new HashMap<>(result.getObjectAttachments()));