This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new efd5439f3df [Fix](test) Fix test_cold_data_compaction_fault_injection
(#48708)
efd5439f3df is described below
commit efd5439f3df7d6bf2e77ae92c46c61023339b83d
Author: abmdocrt <[email protected]>
AuthorDate: Thu Mar 6 12:10:56 2025 +0800
[Fix](test) Fix test_cold_data_compaction_fault_injection (#48708)
---
.../org/apache/doris/regression/suite/Suite.groovy | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
index 125961475de..c252dfeedd7 100644
---
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
+++
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -17,6 +17,12 @@
package org.apache.doris.regression.suite
+import com.amazonaws.auth.AWSStaticCredentialsProvider
+import com.amazonaws.auth.BasicAWSCredentials
+import com.amazonaws.client.builder.AwsClientBuilder
+import com.amazonaws.services.s3.AmazonS3
+import com.amazonaws.services.s3.AmazonS3ClientBuilder
+
import static java.util.concurrent.TimeUnit.SECONDS
import com.google.common.base.Strings
@@ -96,6 +102,8 @@ class Suite implements GroovyInterceptable {
final List<Future> lazyCheckFutures = new Vector<>()
static Boolean isTrinoConnectorDownloaded = false
+ private AmazonS3 s3Client = null
+
Suite(String name, String group, SuiteContext context, SuiteCluster
cluster) {
this.name = name
this.group = group
@@ -984,6 +992,16 @@ class Suite implements GroovyInterceptable {
return s3Url
}
+ synchronized AmazonS3 getS3Client() {
+ if (s3Client == null) {
+ def credentials = new BasicAWSCredentials(getS3AK(), getS3SK())
+ def endpointConfiguration = new
AwsClientBuilder.EndpointConfiguration(getS3Endpoint(), getS3Region())
+ s3Client =
AmazonS3ClientBuilder.standard().withEndpointConfiguration(endpointConfiguration)
+ .withCredentials(new
AWSStaticCredentialsProvider(credentials)).build()
+ }
+ return s3Client
+ }
+
String getJdbcPassword() {
String sk = context.config.otherConfigs.get("jdbcPassword");
return sk
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
