Skip to content

Commit 34ecd83

Browse files
Fixes for state storage env vars (#22191)
The current env var checks for state storage do not properly exclude empty env vars, as is currently implemented for log storage. This means that it is impossible to configure S3 state storage using both kustomize and helm, as those define env vars for the minio state storage (even when they are empty) S3 state storage had two different env vars used for region * check for empty env vars * use consistent env var for STATE_STORAGE_S3_REGION --------- Co-authored-by: Davin Chia <[email protected]>
1 parent 48a5554 commit 34ecd83

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

airbyte-config/config-models/src/main/java/io/airbyte/config/EnvConfigs.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -281,17 +281,17 @@ private Optional<CloudStorageConfigs> getLogConfiguration() {
281281
}
282282

283283
private Optional<CloudStorageConfigs> getStateStorageConfiguration() {
284-
if (getEnv(STATE_STORAGE_GCS_BUCKET_NAME) != null) {
284+
if (getEnv(STATE_STORAGE_GCS_BUCKET_NAME) != null && !getEnv(STATE_STORAGE_GCS_BUCKET_NAME).isBlank()) {
285285
return Optional.of(CloudStorageConfigs.gcs(new GcsConfig(
286286
getEnvOrDefault(STATE_STORAGE_GCS_BUCKET_NAME, ""),
287287
getEnvOrDefault(STATE_STORAGE_GCS_APPLICATION_CREDENTIALS, ""))));
288-
} else if (getEnv(STATE_STORAGE_MINIO_ENDPOINT) != null) {
288+
} else if (getEnv(STATE_STORAGE_MINIO_ENDPOINT) != null && !getEnv(STATE_STORAGE_MINIO_ENDPOINT).isBlank()) {
289289
return Optional.of(CloudStorageConfigs.minio(new MinioConfig(
290290
getEnvOrDefault(STATE_STORAGE_MINIO_BUCKET_NAME, ""),
291291
getEnvOrDefault(STATE_STORAGE_MINIO_ACCESS_KEY, ""),
292292
getEnvOrDefault(STATE_STORAGE_MINIO_SECRET_ACCESS_KEY, ""),
293293
getEnvOrDefault(STATE_STORAGE_MINIO_ENDPOINT, ""))));
294-
} else if (getEnv(STATE_STORAGE_S3_REGION) != null) {
294+
} else if (getEnv(STATE_STORAGE_S3_REGION) != null && !getEnv(STATE_STORAGE_S3_REGION).isBlank()) {
295295
return Optional.of(CloudStorageConfigs.s3(new S3Config(
296296
getEnvOrDefault(STATE_STORAGE_S3_BUCKET_NAME, ""),
297297
getEnvOrDefault(STATE_STORAGE_S3_ACCESS_KEY, ""),

airbyte-server/src/main/resources/application.yml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ airbyte:
4343
s3:
4444
access-key: ${STATE_STORAGE_S3_ACCESS_KEY:}
4545
bucket: ${STATE_STORAGE_S3_BUCKET_NAME:}
46-
region: ${STATE_STORAGE_S3_BUCKET_REGION:}
46+
region: ${STATE_STORAGE_S3_REGION:}
4747
secret-access-key: ${STATE_STORAGE_S3_SECRET_ACCESS_KEY:}
4848
deployment-mode: ${DEPLOYMENT_MODE:OSS}
4949
flyway:
@@ -101,7 +101,7 @@ datasources:
101101
maximum-pool-size: 10
102102
minimum-idle: 0
103103
idle-timeout: 600000
104-
initialization-fail-timeout: -1 # Disable fail fast checking to avoid issues due to other pods not being started in time
104+
initialization-fail-timeout: -1 # Disable fail fast checking to avoid issues due to other pods not being started in time
105105
url: ${DATABASE_URL}
106106
driverClassName: org.postgresql.Driver
107107
username: ${DATABASE_USER}
@@ -139,11 +139,11 @@ flyway:
139139
config:
140140
enabled: false
141141
locations:
142-
- 'classpath:io/airbyte/db/instance/configs/migrations'
142+
- "classpath:io/airbyte/db/instance/configs/migrations"
143143
jobs:
144144
enabled: false
145145
locations:
146-
- 'classpath:io/airbyte/db/instance/jobs/migrations'
146+
- "classpath:io/airbyte/db/instance/jobs/migrations"
147147

148148
jooq:
149149
datasources:

airbyte-workers/src/main/resources/application.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ airbyte:
4343
s3:
4444
access-key: ${STATE_STORAGE_S3_ACCESS_KEY:}
4545
bucket: ${STATE_STORAGE_S3_BUCKET_NAME:}
46-
region: ${STATE_STORAGE_S3_BUCKET_REGION:}
46+
region: ${STATE_STORAGE_S3_REGION:}
4747
secret-access-key: ${STATE_STORAGE_S3_SECRET_ACCESS_KEY:}
4848
connector:
4949
specific-resource-defaults-enabled: ${CONNECTOR_SPECIFIC_RESOURCE_DEFAULTS_ENABLED:false}

0 commit comments

Comments
 (0)