public JobRecord getJobRecord(long jobId) {
        return jobRecords.get().get(jobId);
    }
@Test
    public void test_getJobRecordFromClient() {
        HazelcastInstance client = createHazelcastClient();
        Pipeline p = Pipeline.create();
        p.readFrom(Sources.streamFromProcessor("source", ProcessorMetaSupplier.of(() -> new NoOutputSourceP())))
                .withoutTimestamps()
                .writeTo(Sinks.logger());
        Job job = instance.getJet().newJob(p, new JobConfig()
                .setProcessingGuarantee(ProcessingGuarantee.EXACTLY_ONCE)
                .setSnapshotIntervalMillis(100));
        JobRepository jobRepository = new JobRepository(client);
        assertTrueEventually(() -> assertNotNull(jobRepository.getJobRecord(job.getId())));
        client.shutdown();
    }