diff --git a/src/main/java/io/cdap/plugin/successfactors/source/SuccessFactorsSource.java b/src/main/java/io/cdap/plugin/successfactors/source/SuccessFactorsSource.java index bd56c04..3d16288 100644 --- a/src/main/java/io/cdap/plugin/successfactors/source/SuccessFactorsSource.java +++ b/src/main/java/io/cdap/plugin/successfactors/source/SuccessFactorsSource.java @@ -169,12 +169,9 @@ private void attachFieldWithError(SuccessFactorsServiceException ose, FailureCol failureCollector.addFailure(errMsg, null). withConfigProperty(SuccessFactorsConnectorConfig.ASSERTION_TOKEN); } else { - failureCollector.addFailure(errMsg, null). - withConfigProperty(SuccessFactorsConnectorConfig.PRIVATE_KEY); - failureCollector.addFailure(errMsg, null). - withConfigProperty(SuccessFactorsConnectorConfig.USER_ID); - failureCollector.addFailure(errMsg, null). - withConfigProperty(SuccessFactorsConnectorConfig.TOKEN_URL); + failureCollector.addFailure(errMsg, null).withConfigProperty(SuccessFactorsConnectorConfig.PRIVATE_KEY); + failureCollector.addFailure(errMsg, null).withConfigProperty(SuccessFactorsConnectorConfig.USER_ID); + failureCollector.addFailure(errMsg, null).withConfigProperty(SuccessFactorsConnectorConfig.TOKEN_URL); } } break; diff --git a/src/main/java/io/cdap/plugin/successfactors/source/transport/SuccessFactorsTransporter.java b/src/main/java/io/cdap/plugin/successfactors/source/transport/SuccessFactorsTransporter.java index 7be9d2b..b3a397d 100644 --- a/src/main/java/io/cdap/plugin/successfactors/source/transport/SuccessFactorsTransporter.java +++ b/src/main/java/io/cdap/plugin/successfactors/source/transport/SuccessFactorsTransporter.java @@ -121,10 +121,8 @@ public SuccessFactorsResponseContainer callSuccessFactorsWithRetry(URL endpoint) * @throws IOException if all retries fail */ public Response retrySapTransportCall(URL endpoint, String mediaType) throws IOException { - AtomicInteger attemptCounter = new AtomicInteger(0); Callable fetchRecords = () -> { response = transport(endpoint, mediaType); - LOG.info("Response code in retry: {}", response.code()); if (response != null && response.code() >= HttpURLConnection.HTTP_INTERNAL_ERROR) { throw new RetryableException(); }