{"record":{"id":"84d9d90d068ddce6","repo":"apache/dolphinscheduler","slug":"not-supported","errorCode":null,"errorMessage":"Not supported","messagePattern":"Not supported","errorType":"exception","errorClass":"ServiceException","httpStatus":null,"severity":"error","filePath":"dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java","lineNumber":398,"sourceCode":"            throw new ServiceException(Status.TASK_GROUP_QUEUE_ALREADY_START);\n        }\n        taskGroupQueue.setForceStart(Flag.YES.getCode());\n        taskGroupQueue.setUpdateTime(new Date());\n        taskGroupQueueMapper.updateById(taskGroupQueue);\n    }\n\n    @Override\n    public void execStreamTaskInstance(User loginUser,\n                                       long projectCode,\n                                       long taskDefinitionCode,\n                                       int taskDefinitionVersion,\n                                       int warningGroupId,\n                                       String workerGroup,\n                                       String tenantCode,\n                                       Long environmentCode,\n                                       Map<String, String> startParams,\n                                       int dryRun) {\n        throw new ServiceException(\"Not supported\");\n    }\n}\n","sourceCodeStart":380,"sourceCodeEnd":401,"githubUrl":"https://github.com/apache/dolphinscheduler/blob/02eac45a1b6676e639fcbfb4be2243de5771b05d/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java#L380-L401","documentation":"execStreamTaskInstance in the API ExecutorServiceImpl is an unimplemented stub that always throws a plain ServiceException(\"Not supported\"). Stream task execution through this API entry point is not supported by this build; it exists only to satisfy the interface contract.","triggerScenarios":"Calling execStreamTaskInstance via ExecutorService (e.g. through the stream-task execution API path) with any parameters — every call throws unconditionally.","commonSituations":"A client SDK or route wired to the stream-task API on a deployment where stream tasks are not implemented; migrating code that used stream tasks in a different distribution.","solutions":["Use the standard (batch) workflow execution APIs instead of the stream-task entry point.","Run stream tasks through the supported execution path in your distribution, or upgrade to a version/distribution that implements stream task execution.","Remove calls to execStreamTaskInstance from integrations."],"exampleFix":"// before\nexecutorService.execStreamTaskInstance(loginUser, ...); // always throws\n// after\nexecutorService.execute(loginUser, projectCode, workflowCode, CommandTypeEnum.START_PROCESS, ...);","handlingStrategy":"fallback","validationCode":null,"typeGuard":null,"tryCatchPattern":"try { execStreamTaskInstance(...); } catch (ServiceException e) { if (\"Not supported\".equals(e.getMessage())) { /* fall back to standard workflow execution API */ } else throw e; }","preventionTips":["Do not call execStreamTaskInstance on distributions where it is a stub.","Use the standard batch workflow execution API.","Confirm stream-task support in your version before integrating."],"tags":["stream-task","not-implemented","dolphinscheduler"],"backgroundTag":"method-not-implemented","analyzedSha":"02eac45a1b6676e639fcbfb4be2243de5771b05d","analyzedAt":"2026-09-06T17:43:00.555Z","contentChangedAt":"2026-09-06T17:43:00.555Z","schemaVersion":2},"datasetVersion":"2026-09-14T05:17:10.506Z"}