Skip to content

Commit b95e42e

Browse files
opensearch-trigger-bot[bot]opensearch-ci-botdbwiddis
authored
[AUTO] Increment version to 3.3.0-SNAPSHOT (#1212)
* Increment version to 3.3.0-SNAPSHOT Signed-off-by: opensearch-ci-bot <[email protected]> * Force slf4j version to match version catalog Signed-off-by: Daniel Widdis <[email protected]> * Replace deprecated AccessController Signed-off-by: Daniel Widdis <[email protected]> --------- Signed-off-by: opensearch-ci-bot <[email protected]> Signed-off-by: Daniel Widdis <[email protected]> Co-authored-by: opensearch-ci-bot <[email protected]> Co-authored-by: Daniel Widdis <[email protected]>
1 parent e7b731f commit b95e42e

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

build.gradle

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import java.nio.file.Paths
88

99
buildscript {
1010
ext {
11-
opensearch_version = System.getProperty("opensearch.version", "3.2.0-SNAPSHOT")
11+
opensearch_version = System.getProperty("opensearch.version", "3.3.0-SNAPSHOT")
1212
buildVersionQualifier = System.getProperty("build.version_qualifier", "")
1313
isSnapshot = "true" == System.getProperty("build.snapshot", "true")
1414
version_tokens = opensearch_version.tokenize('-')
@@ -263,6 +263,7 @@ dependencies {
263263
resolutionStrategy {
264264
// Some other plugin dependencies that don't use version catalog conflict here
265265
force("com.google.guava:guava:${versions.guava}")
266+
force("org.slf4j:slf4j-api:${versions.slf4j}")
266267

267268
if (System.getenv('REMOTE_METADATA_SDK_IMPL') == 'ddb-client') {
268269
// OpenSearch Java client brings in different versions of the below dependencies.

src/main/java/org/opensearch/flowframework/workflow/CreateConnectorStep.java

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,8 @@
2323
import org.opensearch.ml.common.connector.ConnectorAction.ActionType;
2424
import org.opensearch.ml.common.transport.connector.MLCreateConnectorInput;
2525
import org.opensearch.ml.common.transport.connector.MLCreateConnectorResponse;
26+
import org.opensearch.secure_sm.AccessController;
2627

27-
import java.security.AccessController;
28-
import java.security.PrivilegedActionException;
29-
import java.security.PrivilegedExceptionAction;
3028
import java.util.ArrayList;
3129
import java.util.Collections;
3230
import java.util.HashMap;
@@ -142,9 +140,9 @@ public void onFailure(Exception ex) {
142140
} catch (IllegalArgumentException iae) {
143141
logger.error("IllegalArgumentException in connector configuration", iae);
144142
throw new FlowFrameworkException("IllegalArgumentException in connector configuration", RestStatus.BAD_REQUEST);
145-
} catch (PrivilegedActionException pae) {
146-
logger.error("PrivilegedActionException in connector configuration", pae);
147-
throw new FlowFrameworkException("PrivilegedActionException in connector configuration", RestStatus.UNAUTHORIZED);
143+
} catch (Exception e) {
144+
logger.error("Exception in connector configuration", e);
145+
throw new FlowFrameworkException("Exception in connector configuration", RestStatus.UNAUTHORIZED);
148146
}
149147

150148
MLCreateConnectorInput mlInput = MLCreateConnectorInput.builder()
@@ -170,10 +168,10 @@ public String getName() {
170168
return NAME;
171169
}
172170

173-
private static Map<String, String> getParameterMap(Object parameterMap) throws PrivilegedActionException {
171+
private static Map<String, String> getParameterMap(Object parameterMap) throws Exception {
174172
Map<String, String> parameters = new HashMap<>();
175173
for (Entry<String, String> entry : getStringToStringMap(parameterMap, PARAMETERS_FIELD).entrySet()) {
176-
AccessController.doPrivileged((PrivilegedExceptionAction<Void>) () -> {
174+
AccessController.doPrivilegedChecked(() -> {
177175
parameters.put(entry.getKey(), entry.getValue());
178176
return null;
179177
});

0 commit comments

Comments
 (0)