@VisibleForTesting
    Path getWorkingDir() {
        return workingDir;
    }
@Test
    void testGenerateWorkingDirCorrectly() throws IOException {
        final Configuration configuration = new Configuration();
        configuration.setString(HighAvailabilityOptions.HA_STORAGE_PATH, "file:///tmp/flink");
        configuration.setString(HighAvailabilityOptions.HA_CLUSTER_ID, "cluster_id");

        final JobID jobID = new JobID();
        FileSystemJobEventStore store = new FileSystemJobEventStore(jobID, configuration);
        assertThat(store.getWorkingDir().getPath())
                .isEqualTo(String.format("/tmp/flink/cluster_id/%s/job-events", jobID));
    }