Skip to content

Commit adf72a2

Browse files
committed
fix param deletion
1 parent 614a8dd commit adf72a2

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftStreamCopier.java

+3-5
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
import com.amazonaws.services.s3.AmazonS3;
88
import com.fasterxml.jackson.databind.ObjectMapper;
99
import io.airbyte.commons.lang.Exceptions;
10-
import io.airbyte.commons.string.Strings;
1110
import io.airbyte.db.jdbc.JdbcDatabase;
1211
import io.airbyte.integrations.destination.ExtendedNameTransformer;
1312
import io.airbyte.integrations.destination.jdbc.SqlOperations;
@@ -39,8 +38,7 @@ public RedshiftStreamCopier(final String stagingFolder,
3938
final S3DestinationConfig s3Config,
4039
final ExtendedNameTransformer nameTransformer,
4140
final SqlOperations sqlOperations) {
42-
super(stagingFolder, destSyncMode, schema, streamName, Strings.addRandomSuffix("", "", FILE_PREFIX_LENGTH) + "_" + streamName,
43-
client, db, s3Config, nameTransformer, sqlOperations);
41+
super(stagingFolder, destSyncMode, schema, streamName, client, db, s3Config, nameTransformer, sqlOperations);
4442
objectMapper = new ObjectMapper();
4543
}
4644

@@ -77,8 +75,8 @@ public void removeFileAndDropTmpTable() throws Exception {
7775
}
7876

7977
/**
80-
* Creates the contents of a manifest file given the `s3StagingFiles`. There must be at least one
81-
* entry in a manifest file otherwise it is not considered valid for the COPY command.
78+
* Creates the contents of a manifest file given the `s3StagingFiles`. There must be at least one entry in a manifest file otherwise it is not
79+
* considered valid for the COPY command.
8280
*
8381
* @return null if no stagingFiles exist otherwise the manifest body String
8482
*/

airbyte-integrations/connectors/destination-snowflake/src/main/java/io/airbyte/integrations/destination/snowflake/SnowflakeS3StreamCopier.java

+1-3
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
package io.airbyte.integrations.destination.snowflake;
66

77
import com.amazonaws.services.s3.AmazonS3;
8-
import io.airbyte.commons.string.Strings;
98
import io.airbyte.db.jdbc.JdbcDatabase;
109
import io.airbyte.integrations.destination.ExtendedNameTransformer;
1110
import io.airbyte.integrations.destination.jdbc.SqlOperations;
@@ -30,8 +29,7 @@ public SnowflakeS3StreamCopier(final String stagingFolder,
3029
final S3DestinationConfig s3Config,
3130
final ExtendedNameTransformer nameTransformer,
3231
final SqlOperations sqlOperations) {
33-
super(stagingFolder, destSyncMode, schema, streamName, Strings.addRandomSuffix("", "", FILE_PREFIX_LENGTH) + "_" + streamName,
34-
client, db, s3Config, nameTransformer, sqlOperations);
32+
super(stagingFolder, destSyncMode, schema, streamName, client, db, s3Config, nameTransformer, sqlOperations);
3533
}
3634

3735
@Override

0 commit comments

Comments
 (0)