#vulnerable code 
                                @Test
    @SuppressWarnings("unchecked")
    public void integrationTest() throws Exception {
        String dataSource = "foo" + LINE_SEPARATOR + "" + LINE_SEPARATOR + "bar" + LINE_SEPARATOR + "" + LINE_SEPARATOR;

        JobReport jobReport = aNewJob()
                .reader(new StringRecordReader(dataSource))
                .filter(new EmptyRecordFilter())
                .processor(new RecordCollector())
                .call();

        assertThat(jobReport).isNotNull();
        assertThat(jobReport.getMetrics().getTotalCount()).isEqualTo(4);
        assertThat(jobReport.getMetrics().getFilteredCount()).isEqualTo(2);
        assertThat(jobReport.getMetrics().getSuccessCount()).isEqualTo(2);

        List<StringRecord> records = (List<StringRecord>) jobReport.getResult();
        assertThat(records).hasSize(2);
        assertThat(records.get(0).getPayload()).isEqualTo("foo");
        assertThat(records.get(1).getPayload()).isEqualTo("bar");
    } 
                            #location 19 
                            #vulnerability type NULL_DEREFERENCE
#fixed code
                                @Test
    @SuppressWarnings("unchecked")
    public void integrationTest() throws Exception {
        String dataSource = "foo" + LINE_SEPARATOR + "" + LINE_SEPARATOR + "bar" + LINE_SEPARATOR + "" + LINE_SEPARATOR;

        JobReport jobReport = aNewJob()
                .reader(new StringRecordReader(dataSource))
                .filter(new EmptyRecordFilter())
                .processor(new RecordCollector())
                .call();

        assertThat(jobReport).isNotNull();
        assertThat(jobReport.getMetrics().getTotalCount()).isEqualTo(4);
        assertThat(jobReport.getMetrics().getFilteredCount()).isEqualTo(2);
        assertThat(jobReport.getMetrics().getSuccessCount()).isEqualTo(2);

        List<StringRecord> records = (List<StringRecord>) jobReport.getResult();
        assertThat(records).extracting("payload").containsExactly("foo", "bar");
    }