[incubator-gobblin] branch master updated: [GOBBLIN-1208] DSS-27156: Fix - restApiRetryLimit cannot be set to 0[]

[hutran]

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 1e4b798  [GOBBLIN-1208] DSS-27156: Fix - restApiRetryLimit cannot be 
set to 0[]
1e4b798 is described below

commit 1e4b79879ec74e5c7dddf87b8a3d4b528957a134
Author: Alex Li <al...@linkedin.com>
AuthorDate: Tue Jun 30 15:13:14 2020 -0700

    [GOBBLIN-1208] DSS-27156: Fix - restApiRetryLimit cannot be set to 0[]
    
    Closes #3053 from arekusuri/GOBBLIN-1208
---
 .../src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
 
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
index 22b5541..22e9ea0 100644
--- 
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
+++ 
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
@@ -427,7 +427,7 @@ public class SalesforceSource extends 
QueryBasedSource<JsonArray, JsonElement> {
   @SneakyThrows
   private JsonArray getRecordsForQuery(SalesforceConnector connector, String 
query) {
     RestApiProcessingException exception = null;
-    for (int i = 0; i < workUnitConf.restApiRetryLimit; i++) {
+    for (int i = 0; i < workUnitConf.restApiRetryLimit + 1; i++) {
       try {
         String soqlQuery = SalesforceExtractor.getSoqlUrl(query);
         List<Command> commands = 
RestApiConnector.constructGetCommand(connector.getFullUri(soqlQuery));