ehcanadian
10/16/2019, 5:51 AMexecuteMapReduceScript: function (scriptId, deploymentId, duplicateIfRunning, params) {
var mrTask = task.create({
taskType: task.TaskType.MAP_REDUCE,
scriptId: scriptId
});
if (deploymentId)
mrTask.deploymentId = deploymentId;
try {
if (params) {
mrTask.params = params;
log.debug('PARAMS', params);
}
var mrTaskId = mrTask.submit();
} catch (e) {
log.error('TASK FAILED', e);
if (e.name === 'MAP_REDUCE_ALREADY_RUNNING' && duplicateIfRunning) {
if (this.duplicateMapReduceDeployment(scriptId))
mrTask.submit();
}
}
if (mrTaskId)
log.debug('MAP/REDUCE', 'Task ID: ' + mrTaskId + ' Submitted task (' + mrTask.deploymentId + ')');
return mrTaskId;
},