@VisibleForTesting
    public Path getBasePath() {
        return this.basePath;
    }
@Test
    void testBasePath() throws IOException {
        JobID jobID = JobID.generate();
        String rootPath = "/dstl-root-path";
        Path oriBasePath = new Path(rootPath);

        ChangelogStorageMetricGroup metrics =
                new ChangelogStorageMetricGroup(createUnregisteredTaskManagerJobMetricGroup());

        StateChangeFsUploader uploader =
                new StateChangeFsUploader(
                        jobID,
                        oriBasePath,
                        oriBasePath.getFileSystem(),
                        false,
                        4096,
                        metrics,
                        TaskChangelogRegistry.NO_OP);

        assertThat(uploader.getBasePath().getPath())
                .isEqualTo(
                        String.format(
                                "%s/%s/%s",
                                rootPath, jobID.toHexString(), StateChangeFsUploader.PATH_SUB_DIR));
    }