This is an automated email from the ASF dual-hosted git repository.
sajjad 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 8767437931 Fix issue with auth AccessType in Schema resource (#9293)
8767437931 is described below
commit 8767437931d0523bec888af13ab040c26da2cec0
Author: Sajjad Moradi <[email protected]>
AuthorDate: Mon Aug 29 11:25:29 2022 -0700
Fix issue with auth AccessType in Schema resource (#9293)
---
.../pinot/controller/api/resources/PinotSchemaRestletResource.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
index 176d796660..4b2a465baa 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
@@ -253,7 +253,7 @@ public class PinotSchemaRestletResource {
Schema schema = schemaAndUnrecognizedProperties.getLeft();
String endpointUrl = request.getRequestURL().toString();
validateSchemaName(schema.getSchemaName());
- AccessControlUtils.validatePermission(schema.getSchemaName(),
AccessType.READ, httpHeaders, endpointUrl,
+ AccessControlUtils.validatePermission(schema.getSchemaName(),
AccessType.CREATE, httpHeaders, endpointUrl,
_accessControlFactory.create());
SuccessResponse successResponse = addSchema(schema, override);
return new ConfigSuccessResponse(successResponse.getStatus(),
schemaAndUnrecognizedProperties.getRight());
@@ -311,7 +311,7 @@ public class PinotSchemaRestletResource {
Schema schema = schemaAndUnrecognizedProps.getLeft();
String endpointUrl = request.getRequestURL().toString();
validateSchemaInternal(schema);
- AccessControlUtils.validatePermission(schema.getSchemaName(),
AccessType.CREATE, httpHeaders, endpointUrl,
+ AccessControlUtils.validatePermission(schema.getSchemaName(),
AccessType.READ, httpHeaders, endpointUrl,
_accessControlFactory.create());
ObjectNode response = schema.toJsonObject();
response.set("unrecognizedProperties",
JsonUtils.objectToJsonNode(schemaAndUnrecognizedProps.getRight()));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
