Skip to content

Commit 6a1bcd1

Browse files
georgeajitgeorgeajit
georgeajit
authored and
georgeajit
committed
Added console out debug statement
1 parent 169b51f commit 6a1bcd1

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

marklogic-client-api-functionaltests/src/test/java/com/marklogic/client/functionaltest/BulkIOCallersFnTest.java

+3
Original file line numberDiff line numberDiff line change
@@ -1109,6 +1109,8 @@ public void TestIngestEgressOnAnyDocument() throws Exception {
11091109
InputStream s10 = new ByteArrayInputStream(strContent[1].getBytes(StandardCharsets.UTF_8));
11101110

11111111
Stream<InputStream> input = Stream.of(s1, s2, s3, s4, s5, s6, s7, s8, s9, s10);
1112+
inputbulkCaller.setErrorListener(InerrorListener);
1113+
11121114
input.forEach(inputbulkCaller::accept);
11131115
inputbulkCaller.awaitCompletion();
11141116

@@ -1211,6 +1213,7 @@ public void TestIngestEgressOnAnyDocument() throws Exception {
12111213

12121214
// get the result
12131215
JsonNode resultDoc = resultsHandle.get();
1216+
System.out.println(resultDoc.asText());
12141217
int total = resultDoc.get("total").asInt();
12151218
assertTrue("No of Documents returned from egressed collection incorrect.", total == 5);
12161219

0 commit comments

Comments
 (0)