diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java index 2245de5..22ed916 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java @@ -44,6 +44,9 @@ public class TaskInputInfoServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(TaskInputInfo::getNodeId, nodeId); TaskInputInfo taskInputInfo = taskInputInfoMapper.selectOne(queryWrapper); + if(taskInputInfo==null){ + return new TaskInputInfo(); + } String tableField = taskInputInfo.getTableField(); List structures = JSON.parseArray(tableField, Structure.class); taskInputInfo.setColumnList(structures);