manager/manager/src/main/java/org/apache/doris/stack/service/construct/DataImportService.java [323:334]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        checkRequestBody(importReq.hasEmptyField());

        ClusterInfoEntity clusterInfo = clusterUserComponent.getUserCurrentClusterAndCheckAdmin(user);
        ManagerTableEntity tableEntity = tableRepository.findById(tableId).get();
        ManagerDatabaseEntity databaseEntity =
                databuildComponent.checkClusterDatabase(tableEntity.getDbId(), clusterInfo.getId());

        DataImportTaskEntity taskEntity = new DataImportTaskEntity(importReq, tableId, databaseEntity.getId(),
                user.getFirstName(), clusterInfo.getId());
        taskEntity.setImportType(HDFS_IMPORT_TYPE);

        String importSql = driver.importHdfsFile(databaseEntity.getName(), tableEntity.getName(), importReq);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



manager/manager/src/main/java/org/apache/doris/stack/service/construct/DataImportService.java [355:366]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        checkRequestBody(importReq.hasEmptyField());

        ClusterInfoEntity clusterInfo = clusterUserComponent.getUserCurrentClusterAndCheckAdmin(user);
        ManagerTableEntity tableEntity = tableRepository.findById(tableId).get();
        ManagerDatabaseEntity databaseEntity =
                databuildComponent.checkClusterDatabase(tableEntity.getDbId(), clusterInfo.getId());

        DataImportTaskEntity taskEntity = new DataImportTaskEntity(importReq, tableId, databaseEntity.getId(),
                user.getFirstName(), clusterInfo.getId());
        taskEntity.setImportType(HDFS_IMPORT_TYPE);

        String importSql = driver.importHdfsFile(databaseEntity.getName(), tableEntity.getName(), importReq);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -