@Override
    @Transactional(rollbackFor = Throwable.class, isolation = Isolation.REPEATABLE_READ)
    public Integer addDataAddTask(DataAddTaskRequest request, String operator) {
        throw new BusinessException(String.format("not support data add task for type =%s", request.getSourceType()));
    }
If the stream source can only use one data type, return the data type that has been set.

@param streamSource stream source
@param streamDataType stream data type
@return serialization type
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java