This commit is contained in:
EricGao888 2024-05-29 15:24:44 +08:00
parent 0d2be37691
commit 56accb07cb
6 changed files with 16 additions and 10 deletions

View File

@ -184,6 +184,9 @@ public class AliyunServerlessSparkTask extends AbstractRemoteTask {
private Client buildAliyunServerlessSparkClient(String accessKeyId, String accessKeySecret, String regionId) throws Exception {
String endpoint = String.format("emr-serverless-spark.%s.aliyuncs.com", regionId);
log.info("[debug111] ak - {}", accessKeyId);
log.info("[debug111] sk - {}", accessKeySecret);
log.info("[debug111] region - {}", regionId);
Config config = new Config()
.setEndpoint(endpoint)
.setAccessKeyId(accessKeyId)

View File

@ -100,8 +100,8 @@ export default {
namespace_tips: 'Please input namespace',
access_key_id: 'Access Key Id',
access_key_id_tips: 'Please enter access key id',
access_Key_secret: 'Access Key Secret',
access_Key_secret_tips: 'Please enter access key secret',
access_key_secret: 'Access Key Secret',
access_key_secret_tips: 'Please enter access key secret',
region_id: 'Region Id',
region_id_tips: 'Please enter region id'
region_id_tips: 'Please enter Region Id'
}

View File

@ -930,10 +930,10 @@ export default {
engine_release_version_tips: "engine release version",
entry_point: "entry point",
entry_point_tips: "entry point",
entry_point_arguments: "",
entry_point_arguments_tip: "entry point arguments",
entry_point_arguments: "entry point arguments",
entry_point_arguments_tips: "entry point arguments",
spark_submit_parameters: "spark submit parameters",
spark_submit_parameters_tip: "spark submit parameters",
spark_submit_parameters_tips: "spark submit parameters",
is_production: "is production",
is_production_tips: "is production"
},

View File

@ -97,6 +97,8 @@ export default {
namespace_tips: '请输入namespace',
access_key_id: 'Access Key Id',
access_key_id_tips: '请输入access key id',
access_Key_secret: 'Access Key Secret',
access_Key_secret_tips: '请输入access key secret'
access_key_secret: 'Access Key Secret',
access_key_secret_tips: '请输入access key secret',
region_id: 'Region Id',
region_id_tips: '请输入Region Id'
}

View File

@ -901,9 +901,9 @@ export default {
entry_point: "entry point",
entry_point_tips: "entry point",
entry_point_arguments: "entry point arguments",
entry_point_arguments_tip: "entry point arguments",
entry_point_arguments_tips: "entry point arguments",
spark_submit_parameters: "spark submit parameters",
spark_submit_parameters_tip: "spark submit parameters",
spark_submit_parameters_tips: "spark submit parameters",
is_production: "is production",
is_production_tips: "is production"
},

View File

@ -358,6 +358,7 @@ export function formatParams(data: INodeData): {
taskParams.sparkSubmitParameters = data.sparkSubmitParameters
taskParams.isProduction = data.isProduction
taskParams.type = data.type
taskParams.datasource = data.datasource
}
if (data.taskType === 'K8S') {