conductor-oss-fixDynamicForkIssue: Fix groovy testcase failure

Author: saksham2105

core/src/main/java/com/netflix/conductor/core/execution/mapper/ForkJoinDynamicTaskMapper.java

@@ -227,15 +227,23 @@ public List<TaskModel> getMappedTasks(TaskMapperContext taskMapperContext)
                 }
 
                 for (TaskModel forkedTask : forkedTasks) {
-                    Map<String, Object> forkedTaskInput =
-                            tasksInput.get(forkedTask.getReferenceTaskName());
-                    if (forkedTask.getInputData() == null) {
-                        forkedTask.setInputData(new HashMap<>());
+                    try {
+                        Map<String, Object> forkedTaskInput =
+                                tasksInput.get(forkedTask.getReferenceTaskName());
+                        if (forkedTask.getInputData() == null) {
+                            forkedTask.setInputData(new HashMap<>());
+                        }
+                        if (forkedTaskInput == null) {
+                            forkedTaskInput = new HashMap<>();
+                        }
+                        forkedTask.getInputData().putAll(forkedTaskInput);
+                    } catch (Exception e) {
+                        String reason =
+                                String.format(
+                                        "Tasks could not be dynamically forked due to invalid input: %s",
+                                        e.getMessage());
+                        throw new TerminateWorkflowException(reason);
                     }
-                    if (forkedTaskInput == null) {
-                        forkedTaskInput = new HashMap<>();
-                    }
-                    forkedTask.getInputData().putAll(forkedTaskInput);
                 }
                 mappedTasks.addAll(forkedTasks);
                 // Get the last of the dynamic tasks so that the join can be performed once this