public FileStoreInfo getFileStore(String fsKey) throws DdlException {
        try {
            return client.getFileStore(fsKey, serviceId);
        } catch (StarClientException e) {
            if (e.getCode() == StatusCode.NOT_EXIST) {
                return null;
            }
            throw new DdlException("Failed to get file store, error: " + e.getMessage());
        }
    }
@Test
    public void testGetFileStore() throws StarClientException, DdlException {
        S3FileStoreInfo s3FsInfo = S3FileStoreInfo.newBuilder()
                .setRegion("region").setEndpoint("endpoint").build();
        FileStoreInfo fsInfo = FileStoreInfo.newBuilder().setFsKey("test-fskey")
                .setFsName("test-fsname").setFsType(FileStoreType.S3).setS3FsInfo(s3FsInfo).build();
        new Expectations() {
            {
                client.getFileStore("test-fskey", "1");
                result = fsInfo;
                minTimes = 0;

                client.getFileStore("test-fskey", "2");
                result = new StarClientException(StatusCode.INVALID_ARGUMENT, "mocked exception");
            }
        };

        Deencapsulation.setField(starosAgent, "serviceId", "1");
        Assert.assertEquals("test-fskey", starosAgent.getFileStore("test-fskey").getFsKey());

        Deencapsulation.setField(starosAgent, "serviceId", "2");
        ExceptionChecker.expectThrowsWithMsg(DdlException.class,
                "Failed to get file store, error: INVALID_ARGUMENT:mocked exception",
                () -> starosAgent.getFileStore("test-fskey"));
    }