diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java index c257403bc..36e5f2826 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java @@ -197,8 +197,8 @@ public class TransientServiceImpl implements TransientService { cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG; datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT; try ( - InputStream cfgStream = obsUtil.fileDownload(cfgPath); - InputStream datStream = obsUtil.fileDownload(datPath) + InputStream cfgStream = obsUtil.downloadStream(cfgPath); + InputStream datStream = obsUtil.downloadStream(datPath) ) { if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { throw new BusinessException(EventResponseEnum.ANALYSEWAVE_NOT_FOUND);