This is an automated email from the ASF dual-hosted git repository.
hutran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 2d7fa74 [GOBBLIN-1298] return jsonElement instead of null for last
element in resultChainingIterator
2d7fa74 is described below
commit 2d7fa74129ae9e95002133d4058ccfab7db4f754
Author: Wenqin Wang <[email protected]>
AuthorDate: Thu Oct 22 12:12:59 2020 -0700
[GOBBLIN-1298] return jsonElement instead of null for last element in
resultChainingIterator
Closes #3136 from wenqinduke/master
---
.../main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java
index cb77a2a..540886f 100644
---
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java
+++
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java
@@ -70,7 +70,6 @@ public class ResultChainingIterator implements
Iterator<JsonElement> {
if (!iter.hasNext()) {
// `jsonElement` has last record, print out total and isDeleted=true
records(soft deleted) total
log.info("====Total records: [{}] isDeleted=true records: [{}]====",
recordCount, isDeletedRecordCount);
- return null;
}
return jsonElement;
}