aws-lib/src/main/java/com/streamsets/pipeline/stage/common/s3/S3ConnectionBaseConfig.java
public void init(
      Stage.Context context,
      String configPrefix,
      ProxyConfig proxyConfig,
      List<Stage.ConfigIssue> issues,
      int maxErrorRetries
  ) {
    this.maxErrorRetries = maxErrorRetries;
    commonPrefix = AWSUtil.normalizePrefix(commonPrefix, delimiter);
    try {
      createConnection(context, configPrefix, proxyConfig, issues, maxErrorRetries);
    } catch (StageException ex) {
      LOG.debug(Errors.S3_SPOOLDIR_20.getMessage(), ex.toString(), ex);
      issues.add(
          context.createConfigIssue(
              Groups.S3.name(),
              configPrefix + S3ConnectionBaseConfig.AWS_CONFIG_PREFIX + "awsAccessKeyId",
              Errors.S3_SPOOLDIR_20,
              ex.toString()
          )
      );
    }
  }
public void init(
      Stage.Context context,
      String configPrefix,
      ProxyConfig proxyConfig,
      List<Stage.ConfigIssue> issues,
      int maxErrorRetries
  ) {
    this.maxErrorRetries = maxErrorRetries;
    commonPrefix = AWSUtil.normalizePrefix(commonPrefix, delimiter);
    try {
      createConnection(context, configPrefix, proxyConfig, issues, maxErrorRetries);
    } catch (StageException ex) {
      LOG.debug(Errors.S3_SPOOLDIR_20.getMessage(), ex.toString(), ex);
      issues.add(
          context.createConfigIssue(
              Groups.S3.name(),
              configPrefix + S3ConnectionBaseConfig.AWS_CONFIG_PREFIX + "awsAccessKeyId",
              Errors.S3_SPOOLDIR_20,
              ex.toString()
          )
      );
    }
  }
public void init ( Stage . Context context , String configPrefix , ProxyConfig proxyConfig , List < Stage . ConfigIssue > issues , int maxErrorRetries ) { this . maxErrorRetries = maxErrorRetries ; commonPrefix = AWSUtil . normalizePrefix ( commonPrefix , delimiter ) ; try { createConnection ( context , configPrefix , proxyConfig , issues , maxErrorRetries ) ; } catch ( StageException ex ) { LOG . debug ( Errors . S3_SPOOLDIR_20 . getMessage ( ) , ex . toString ( ) , ex ) ; issues . add ( context . createConfigIssue ( Groups . S3 . name ( ) , configPrefix + S3ConnectionBaseConfig . AWS_CONFIG_PREFIX + "awsAccessKeyId" , Errors . S3_SPOOLDIR_20 , ex . toString ( ) ) ) ; } }
/* Max Error retries >=0 are set in ClientConfig for S3Client, < 0 will use default (3)
/ * Max Error retries > = 0 are set in ClientConfig for S3Client < 0 will use default ( 3 )