Skip to content

Commit

Permalink
Merge branch '1352-s3-state-store-for-all-tables' into 1353-table-met…
Browse files Browse the repository at this point in the history
…rics-for-all-tables
  • Loading branch information
kr565370 authored Sep 28, 2023
2 parents 293bf13 + 90cd10b commit d70eae6
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,7 @@
import sleeper.statestore.dynamodb.DynamoDBStateStore;
import sleeper.statestore.dynamodb.DynamoDBStateStoreCreator;
import sleeper.statestore.s3.S3StateStore;
import sleeper.statestore.s3.S3StateStoreCreator;

import java.io.BufferedWriter;
import java.io.FileWriter;
Expand Down Expand Up @@ -518,7 +519,7 @@ private DynamoDBStateStore setupDynamoStateStore(TableProperties tableProperties

private S3StateStore setupS3StateStore(TableProperties tableProperties) throws IOException, StateStoreException {
// - CreateS3StateStore
createRevisionDynamoTable(instanceProperties.get(REVISION_TABLENAME));
new S3StateStoreCreator(instanceProperties, dynamoDBClient).create();
Configuration configuration = new Configuration();
configuration.set("fs.s3a.endpoint", localStackContainer.getEndpointOverride(LocalStackContainer.Service.S3).toString());
configuration.set("fs.s3a.aws.credentials.provider", "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider");
Expand Down

0 comments on commit d70eae6

Please sign in to comment.