diff --git a/data-prepper-plugins/csv-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/csv/CsvProcessorTest.java b/data-prepper-plugins/csv-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/csv/CsvProcessorTest.java index cacfedb609..0e36d8ebea 100644 --- a/data-prepper-plugins/csv-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/csv/CsvProcessorTest.java +++ b/data-prepper-plugins/csv-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/csv/CsvProcessorTest.java @@ -117,6 +117,7 @@ void test_when_messageIsEmpty_then_notParsed() { @Test void test_when_delimiterIsTab_then_parsedCorrectly() { when(processorConfig.getDelimiter()).thenReturn("\t"); + csvProcessor = createObjectUnderTest(); Record eventUnderTest = createMessageEvent("1\t2\t3"); final List> editedEvents = (List>) csvProcessor.doExecute(Collections.singletonList(eventUnderTest)); @@ -293,6 +294,7 @@ void test_when_twoEventsAndNoHeaderSourceOnOne_then_ChooseUserColumns() { @Test void test_when_differentQuoteCharacter_then_parsesCorrectly() { when(processorConfig.getQuoteCharacter()).thenReturn("\'"); + csvProcessor = createObjectUnderTest(); final Record eventUnderTest = createMessageEvent("'1','2','3'"); final List> editedEvents = (List>) csvProcessor.doExecute(Collections.singletonList(eventUnderTest));