diff --git a/server/api-service/lowcoder-domain/src/main/java/org/lowcoder/domain/plugin/client/DatasourcePluginClient.java b/server/api-service/lowcoder-domain/src/main/java/org/lowcoder/domain/plugin/client/DatasourcePluginClient.java
index cae767e6f..aba0cacc0 100644
--- a/server/api-service/lowcoder-domain/src/main/java/org/lowcoder/domain/plugin/client/DatasourcePluginClient.java
+++ b/server/api-service/lowcoder-domain/src/main/java/org/lowcoder/domain/plugin/client/DatasourcePluginClient.java
@@ -138,7 +138,7 @@ public Mono<QueryExecutionResult> executeQuery(String pluginName, Object queryDs
                         String json = OBJECT_MAPPER.writeValueAsString(body);
 
                         boolean encryptionEnabled = !(commonConfig.getJsExecutor().getPassword().isEmpty() || commonConfig.getJsExecutor().getSalt().isEmpty());
-                        String payload;
+                        Object payload;
                         WebClient.RequestBodySpec requestSpec = WEB_CLIENT
                                 .post()
                                 .uri(nodeServerHelper.createUri(RUN_PLUGIN_QUERY))
@@ -148,7 +148,7 @@ public Mono<QueryExecutionResult> executeQuery(String pluginName, Object queryDs
                             payload = encryptionService.encryptStringForNodeServer(json);
                             requestSpec = requestSpec.header("X-Encrypted", "true");
                         } else {
-                            payload = json;
+                            payload = body;
                         }
 
                         return requestSpec