@Test
    void testInvalidData() {
        // Create a store.
        createStore(INVALID_DATA, REFERENCE_DATA, SAMPLE_XSLT);

        // Process the store sequentially.
        final List<ProcessorResult> results = processAll();

        // Check we have some raw events.
        final List<Meta> raw = metaService.find(FindMetaCriteria.createWithType(StreamTypeNames.RAW_EVENTS))
                .getValues();
        assertThat(raw.size())
                .isEqualTo(NO_OF_EVENT_FILES);

        // Check no output streams were written.
        final List<Meta> cooked = metaService.find(FindMetaCriteria.createWithType(StreamTypeNames.EVENTS))
                .getValues();
        assertThat(cooked.size())
                .isEqualTo(0);

        // Make sure we got 13 results.
        assertThat(results.size())
                .isEqualTo(13);

        // Make sure there were errors.
        int errors = 0;
        for (final ProcessorResult result : results) {
            errors += result.getMarkerCount(Severity.ERROR, Severity.FATAL_ERROR);
        }
        assertThat(errors)
                .isEqualTo(10);
    }
Tests that invalid streams are processed but errors are recorded against
them.
stroom-app/src/test/java/stroom/pipeline/task/TestTranslationTaskFactory.java