@Override
    public ExecutionMode getExecutionMode() {
        return jobType == JobType.STREAMING ? ExecutionMode.STREAMING : ExecutionMode.BATCH;
    }
@Test
    void testGetExecutionMode() {
        DefaultJobInfo batchJob = createDefaultJobInfo(JobType.BATCH);
        assertThat(batchJob.getExecutionMode()).isEqualTo(JobInfo.ExecutionMode.BATCH);

        DefaultJobInfo streamingJob = createDefaultJobInfo(JobType.STREAMING);
        assertThat(streamingJob.getExecutionMode()).isEqualTo(JobInfo.ExecutionMode.STREAMING);
    }