This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 2d4e416367f add AuthProvider while fetching segments to replace
(#16978)
2d4e416367f is described below
commit 2d4e416367fef64f33dd75eeeca82557d1d270c5
Author: Harsh Vardhan <[email protected]>
AuthorDate: Fri Oct 10 01:20:34 2025 +0530
add AuthProvider while fetching segments to replace (#16978)
---
.../org/apache/pinot/segment/local/utils/ConsistentDataPushUtils.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/ConsistentDataPushUtils.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/ConsistentDataPushUtils.java
index 0bdbf71f617..8d1cc9bde58 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/ConsistentDataPushUtils.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/ConsistentDataPushUtils.java
@@ -236,8 +236,9 @@ public class ConsistentDataPushUtils {
List<String> offlineSegments;
try {
controllerURI = new URI(pinotClusterSpec.getControllerURI());
+ AuthProvider authProvider =
AuthProviderUtils.makeAuthProvider(spec.getAuthToken());
Map<String, List<String>> segments =
- FILE_UPLOAD_DOWNLOAD_CLIENT.getSegments(controllerURI,
rawTableName, TableType.OFFLINE, true);
+ FILE_UPLOAD_DOWNLOAD_CLIENT.getSegments(controllerURI,
rawTableName, TableType.OFFLINE, true, authProvider);
offlineSegments = segments.get(TableType.OFFLINE.toString());
uriToOfflineSegments.put(controllerURI, offlineSegments);
} catch (URISyntaxException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
