Skip to content

Commit b2de8f5

Browse files
committed
Remove unused config from SparkSessionBuilder
Tests pass without it.
1 parent 1361bd4 commit b2de8f5

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

integration-tests/src/main/java/org/apache/polaris/service/it/ext/SparkSessionBuilder.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -164,13 +164,9 @@ private void applySingleCatalogConfig(CatalogConfig catalog) {
164164

165165
// Add endpoint configuration
166166
Preconditions.checkNotNull(catalog.endpoints, "endpoints is required");
167-
builder
168-
.config(
169-
String.format("spark.sql.catalog.%s.uri", catalog.catalogName),
170-
catalog.endpoints.catalogApiEndpoint().toString())
171-
.config(
172-
String.format("spark.sql.catalog.%s.header.realm", catalog.catalogName),
173-
catalog.endpoints.realmId());
167+
builder.config(
168+
String.format("spark.sql.catalog.%s.uri", catalog.catalogName),
169+
catalog.endpoints.catalogApiEndpoint().toString());
174170

175171
// Add token configuration
176172
if (catalog.token != null) {

0 commit comments

Comments
 (0)