Skip to content

Commit 3b9d2b0

Browse files
authored
Fix credentials printing twice (#1682)
1 parent 7961fdd commit 3b9d2b0

File tree

3 files changed

+6
-34
lines changed

3 files changed

+6
-34
lines changed

extension/persistence/relational-jdbc/src/main/java/org/apache/polaris/extension/persistence/relational/jdbc/JdbcMetaStoreManagerFactory.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -135,17 +135,12 @@ public synchronized Map<String, PrincipalSecretsResult> bootstrapRealms(
135135

136136
for (String realm : realms) {
137137
RealmContext realmContext = () -> realm;
138-
if (!metaStoreManagerMap.containsKey(realmContext.getRealmIdentifier())) {
138+
if (!metaStoreManagerMap.containsKey(realm)) {
139139
initializeForRealm(realmContext, rootCredentialsSet, true);
140140
PrincipalSecretsResult secretsResult =
141141
bootstrapServiceAndCreatePolarisPrincipalForRealm(
142-
realmContext, metaStoreManagerMap.get(realmContext.getRealmIdentifier()));
143-
144-
if (rootCredentialsSet.credentials().containsKey(realm)) {
145-
LOGGER.info("Bootstrapped realm {} using preset credentials.", realm);
146-
}
147-
148-
results.put(realmContext.getRealmIdentifier(), secretsResult);
142+
realmContext, metaStoreManagerMap.get(realm));
143+
results.put(realm, secretsResult);
149144
}
150145
}
151146

polaris-core/src/main/java/org/apache/polaris/core/persistence/LocalPolarisMetaStoreManagerFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -113,12 +113,12 @@ public synchronized Map<String, PrincipalSecretsResult> bootstrapRealms(
113113

114114
for (String realm : realms) {
115115
RealmContext realmContext = () -> realm;
116-
if (!metaStoreManagerMap.containsKey(realmContext.getRealmIdentifier())) {
116+
if (!metaStoreManagerMap.containsKey(realm)) {
117117
initializeForRealm(realmContext, rootCredentialsSet);
118118
PrincipalSecretsResult secretsResult =
119119
bootstrapServiceAndCreatePolarisPrincipalForRealm(
120-
realmContext, metaStoreManagerMap.get(realmContext.getRealmIdentifier()));
121-
results.put(realmContext.getRealmIdentifier(), secretsResult);
120+
realmContext, metaStoreManagerMap.get(realm));
121+
results.put(realm, secretsResult);
122122
}
123123
}
124124

service/common/src/main/java/org/apache/polaris/service/persistence/InMemoryPolarisMetaStoreManagerFactory.java

Lines changed: 0 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import org.apache.polaris.core.context.RealmContext;
3333
import org.apache.polaris.core.persistence.LocalPolarisMetaStoreManagerFactory;
3434
import org.apache.polaris.core.persistence.PolarisMetaStoreManager;
35-
import org.apache.polaris.core.persistence.bootstrap.RootCredentials;
3635
import org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet;
3736
import org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult;
3837
import org.apache.polaris.core.persistence.transactional.TransactionalPersistence;
@@ -104,28 +103,6 @@ public Map<String, PrincipalSecretsResult> bootstrapRealms(
104103
Iterable<String> realms, RootCredentialsSet rootCredentialsSet) {
105104
Map<String, PrincipalSecretsResult> results = super.bootstrapRealms(realms, rootCredentialsSet);
106105
bootstrappedRealms.addAll(results.keySet());
107-
108-
Map<String, RootCredentials> presetCredentials = rootCredentialsSet.credentials();
109-
for (String realmId : realms) {
110-
if (presetCredentials.containsKey(realmId)) {
111-
// Credentials provided in the runtime env... no need to print
112-
continue;
113-
}
114-
115-
PrincipalSecretsResult principalSecrets = results.get(realmId);
116-
if (principalSecrets == null) {
117-
continue; // already bootstrapped (possible benign race)
118-
}
119-
120-
String msg =
121-
String.format(
122-
"realm: %1s root principal credentials: %2s:%3s",
123-
realmId,
124-
principalSecrets.getPrincipalSecrets().getPrincipalClientId(),
125-
principalSecrets.getPrincipalSecrets().getMainSecret());
126-
System.out.println(msg);
127-
}
128-
129106
return results;
130107
}
131108
}

0 commit comments

Comments
 (0)