src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java
@@ -94,6 +94,7 @@ stationProtocol.setWeight(statusEntity.getWeight()); stationProtocol.setTaskWriteIdx(statusEntity.getTaskWriteIdx()); stationProtocol.setTaskBufferItems(statusEntity.getTaskBufferItems()); stationProtocol.setIoMode(statusEntity.getIoMode()); recentArrivalTracker.observe(statusEntity.getStationId(), statusEntity.getTaskNo(), statusEntity.isLoading()); }