public String stopJob(FlinkInfo flinkInfo, StopWithSavepointRequest request) throws Exception {
        Configuration configuration = getFlinkConfiguration(flinkInfo.getEndpoint());
        return getFlinkClientService(configuration).stopJob(flinkInfo.getJobId(), request.isDrain(),
                request.getTargetDirectory());
    }
Stop the Flink job with the savepoint.
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java