diff --git a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceInstanceController.java b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceInstanceController.java index 21c5c17b..4c50caec 100644 --- a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceInstanceController.java +++ b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceInstanceController.java @@ -258,7 +258,9 @@ public class DeviceInstanceController implements .buffer(20) .publishOn(Schedulers.single()) .concatMap(list -> service.save(Flux.fromIterable(list))) - .map(ImportDeviceInstanceResult::success)); + .map(ImportDeviceInstanceResult::success)) + .onErrorResume(err -> Mono.just(ImportDeviceInstanceResult.error(err))) + ; } DataBufferFactory bufferFactory = new DefaultDataBufferFactory();