{"record":{"id":"c52d0948cc3ead75","repo":"apache/seatunnel","slug":"unsupported-task-group-type-type","errorCode":null,"errorMessage":"Unsupported task group type: ${type}","messagePattern":"Unsupported task group type: (.+?)","errorType":"exception","errorClass":"IllegalArgumentException","httpStatus":null,"severity":"error","filePath":"seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskGroupUtils.java","lineNumber":42,"sourceCode":"\npublic class TaskGroupUtils {\n\n    public static TaskGroup createTaskGroup(\n            TaskGroupType type,\n            TaskGroupLocation taskGroupLocation,\n            String taskGroupName,\n            Collection<Task> tasks) {\n        switch (type) {\n            case DEFAULT:\n                return new TaskGroupDefaultImpl(taskGroupLocation, taskGroupName, tasks);\n            case INTERMEDIATE_BLOCKING_QUEUE:\n                return new TaskGroupWithIntermediateBlockingQueue(\n                        taskGroupLocation, taskGroupName, tasks);\n            case INTERMEDIATE_DISRUPTOR_QUEUE:\n                return new TaskGroupWithIntermediateDisruptor(\n                        taskGroupLocation, taskGroupName, tasks);\n            default:\n                throw new IllegalArgumentException(\"Unsupported task group type: \" + type);\n        }\n    }\n}\n","sourceCodeStart":24,"sourceCodeEnd":46,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskGroupUtils.java#L24-L46","documentation":"TaskGroupUtils.createTaskGroup dispatches on the configured TaskGroupType to instantiate the right queue-backed task group implementation. A type outside the supported set (e.g. not ALL_BLOCKING_QUEUE, INTERMEDIATE_BLOCKING_QUEUE, INTERMEDIATE_DISRUPTOR_QUEUE) throws this IllegalArgumentException.","triggerScenarios":"Calling createTaskGroup with a TaskGroupType value that has no case in the switch; engine config or plugin code requesting an unsupported task group type; enum drift between modules after an upgrade.","commonSituations":"Custom engine patches introducing new TaskGroupType constants without updating TaskGroupUtils; mixed worker/server jar versions; misconfigured task group type in custom deployment code.","solutions":["Use a supported TaskGroupType (ALL_BLOCKING_QUEUE, INTERMEDIATE_BLOCKING_QUEUE, INTERMEDIATE_DISRUPTOR_QUEUE)","Align all engine module versions so enum values match","If you added a new TaskGroupType, add the corresponding case in TaskGroupUtils.createTaskGroup","Check the code path that constructs TaskGroupLocation/type to see why an unsupported value was set"],"exampleFix":"// before\nTaskGroupType type = TaskGroupType.CUSTOM_QUEUE;\ntaskGroup = TaskGroupUtils.createTaskGroup(loc, name, tasks, type); // throws\n// after\nTaskGroupType type = TaskGroupType.INTERMEDIATE_BLOCKING_QUEUE;\ntaskGroup = TaskGroupUtils.createTaskGroup(loc, name, tasks, type);","handlingStrategy":"type-guard","validationCode":"if (type != TaskGroupType.ALL_BLOCKING_QUEUE && type != TaskGroupType.INTERMEDIATE_BLOCKING_QUEUE && type != TaskGroupType.INTERMEDIATE_DISRUPTOR_QUEUE) { throw new IllegalArgumentException(\"unsupported type: \" + type); }","typeGuard":"boolean isSupportedTaskGroupType(TaskGroupType t) { return t == TaskGroupType.ALL_BLOCKING_QUEUE || t == TaskGroupType.INTERMEDIATE_BLOCKING_QUEUE || t == TaskGroupType.INTERMEDIATE_DISRUPTOR_QUEUE; }","tryCatchPattern":"try { group = TaskGroupUtils.createTaskGroup(loc, name, tasks); } catch (IllegalArgumentException e) { if (e.getMessage().startsWith(\"Unsupported task group type\")) { log.error(\"fallback to default queue type\"); group = TaskGroupUtils.createTaskGroup(loc, name, tasks); /* default */ } else { throw e; } }","preventionTips":["Use only supported TaskGroupType constants","Keep TaskGroupUtils switch in sync with the enum","Pin consistent engine versions across the cluster"],"tags":["zeta-engine","task-group","unsupported-type","enum"],"backgroundTag":"unsupported-enum-value","analyzedSha":"cf67b549a7a6c35fa0beb12d83c62892427ea919","analyzedAt":"2026-09-10T21:44:55.265Z","contentChangedAt":"2026-09-10T21:44:55.265Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}