diff --git a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
index 2d55630..fdaba0e 100644
--- a/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
+++ b/nifi-hzyadev-bundle/hzya-nifi-Zsyh-cbs-processors/src/main/java/com/hzya/frame/ZsyhCbsProcessor.java
@@ -24,6 +24,7 @@ import org.apache.nifi.processor.util.StandardValidators;
 import org.bouncycastle.jce.provider.BouncyCastleProvider;
 
 import java.io.IOException;
+import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
 import java.security.Security;
 import java.util.*;
@@ -115,9 +116,11 @@ public class ZsyhCbsProcessor extends AbstractProcessor {
         List<JsonNode> allRecords = new ArrayList<>();
 
         try {
-            //读取初始FlowFile内容，作为后续分页请求的模板
-            String initialRequestJson = IOUtils.toString(session.read(flowFile), StandardCharsets.UTF_8);
-            ObjectNode requestTemplate = (ObjectNode) objectMapper.readTree(initialRequestJson);
+            ObjectNode requestTemplate;
+            try (InputStream in = session.read(flowFile)) {
+                String initialRequestJson = IOUtils.toString(in, StandardCharsets.UTF_8);
+                requestTemplate = (ObjectNode) objectMapper.readTree(initialRequestJson);
+            }
 
             // 获取初始页码
             int currentPage = requestTemplate.has("currentPage") ? requestTemplate.get("currentPage").asInt() : 1;