Skip to content

Commit c0d6958

Browse files
committed
fixing some test cases
1 parent 9a8d697 commit c0d6958

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

src/test/java/kafka/connect/marklogic/TestMarkLogicAsyncWriter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ public void shouldWrite() throws ClientProtocolException, IOException, URISyntax
5858
qr = MAPPER.readValue(response.getEntity().getContent(), QuoteRequest.class);
5959
assertEquals("GS", qr.getSymbol());
6060
super.delete("/C5/A5/Q5.json");
61+
super.delete("/C4/A4/Q4.json");
6162
}
6263
}
6364

src/test/java/kafka/connect/marklogic/TestMarkLogicBufferedWriter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ public void shouldWrite() throws ClientProtocolException, IOException, URISyntax
5454
qr = MAPPER.readValue(response.getEntity().getContent(), QuoteRequest.class);
5555
assertEquals("GS", qr.getSymbol());
5656
super.delete("/C3/A3/Q3.json");
57+
super.delete("/C2/A2/Q2.json");
5758
}
5859

5960
}

src/test/java/kafka/connect/marklogic/sink/TestMarkLogicSincTask.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,5 +53,6 @@ public void shouldPut() throws ClientProtocolException, IOException, URISyntaxEx
5353
final HttpResponse response = super.get("/C1/A1/Q1.json");
5454
final QuoteRequest qr = MAPPER.readValue(response.getEntity().getContent(), QuoteRequest.class);
5555
assertEquals("APPL", qr.getSymbol());
56+
super.delete("/C1/A1/Q1.json");
5657
}
5758
}

0 commit comments

Comments
 (0)