Skip to content

Commit 01fe97a

Browse files
SbloodySSbloodyS
authored
Merge branch 'dev' into dev_wenjun_removeUnusedException
2 parents 0dd8ebb + b34fe46 commit 01fe97a

File tree

23 files changed

+305
-199
lines changed

23 files changed

+305
-199
lines changed

‎dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/task/TaskCreateRequest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@
1919

2020
import static org.apache.dolphinscheduler.common.constants.Constants.VERSION_FIRST;
2121

22-
import org.apache.dolphinscheduler.common.constants.Constants;
2322
import org.apache.dolphinscheduler.common.enums.Flag;
2423
import org.apache.dolphinscheduler.common.enums.Priority;
2524
import org.apache.dolphinscheduler.common.enums.TimeoutFlag;
2625
import org.apache.dolphinscheduler.dao.entity.TaskDefinition;
26+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
2727
import org.apache.dolphinscheduler.plugin.task.api.enums.TaskTimeoutStrategy;
2828

2929
import java.util.Date;
@@ -107,7 +107,7 @@ public TaskDefinition convert2TaskDefinition() {
107107
taskDefinition.setProjectCode(this.projectCode);
108108
taskDefinition.setTaskType(this.taskType);
109109
taskDefinition.setTaskParams(this.taskParams);
110-
taskDefinition.setWorkerGroup(this.workerGroup == null ? Constants.DEFAULT_WORKER_GROUP : this.workerGroup);
110+
taskDefinition.setWorkerGroup(WorkerGroupUtils.getWorkerGroupOrDefault(workerGroup));
111111
taskDefinition.setEnvironmentCode(this.environmentCode);
112112
taskDefinition.setFailRetryTimes(this.failRetryTimes);
113113
taskDefinition.setFailRetryInterval(this.failRetryInterval);

‎dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/WorkerGroupService.java

-8
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
package org.apache.dolphinscheduler.api.service;
1919

2020
import org.apache.dolphinscheduler.api.utils.Result;
21-
import org.apache.dolphinscheduler.dao.entity.TaskInstance;
2221
import org.apache.dolphinscheduler.dao.entity.User;
2322

2423
import java.util.List;
@@ -77,13 +76,6 @@ Map<String, Object> saveWorkerGroup(User loginUser, int id, String name, String
7776
*/
7877
Map<String, Object> getWorkerAddressList();
7978

80-
/**
81-
* Get task instance's worker group
82-
* @param taskInstance task instance
83-
* @return worker group
84-
*/
85-
String getTaskWorkerGroup(TaskInstance taskInstance);
86-
8779
/**
8880
* Query worker group by process definition codes
8981
* @param processDefinitionCodeList processDefinitionCodeList

‎dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@
3434
import static org.apache.dolphinscheduler.common.constants.CommandKeyConstants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE;
3535
import static org.apache.dolphinscheduler.common.constants.Constants.COPY_SUFFIX;
3636
import static org.apache.dolphinscheduler.common.constants.Constants.DATA_LIST;
37-
import static org.apache.dolphinscheduler.common.constants.Constants.DEFAULT_WORKER_GROUP;
3837
import static org.apache.dolphinscheduler.common.constants.Constants.GLOBAL_PARAMS;
3938
import static org.apache.dolphinscheduler.common.constants.Constants.IMPORT_SUFFIX;
4039
import static org.apache.dolphinscheduler.common.constants.Constants.LOCAL_PARAMS;
@@ -109,6 +108,7 @@
109108
import org.apache.dolphinscheduler.dao.repository.ProcessDefinitionDao;
110109
import org.apache.dolphinscheduler.dao.repository.ProcessDefinitionLogDao;
111110
import org.apache.dolphinscheduler.dao.repository.TaskDefinitionLogDao;
111+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
112112
import org.apache.dolphinscheduler.plugin.task.api.TaskPluginManager;
113113
import org.apache.dolphinscheduler.plugin.task.api.enums.SqlType;
114114
import org.apache.dolphinscheduler.plugin.task.api.enums.TaskTimeoutStrategy;
@@ -1390,7 +1390,7 @@ private TaskDefinitionLog buildNormalSqlTaskDefinition(String taskName, DataSour
13901390
taskDefinition.setFailRetryTimes(0);
13911391
taskDefinition.setFailRetryInterval(0);
13921392
taskDefinition.setTimeoutFlag(TimeoutFlag.CLOSE);
1393-
taskDefinition.setWorkerGroup(DEFAULT_WORKER_GROUP);
1393+
taskDefinition.setWorkerGroup(WorkerGroupUtils.getDefaultWorkerGroup());
13941394
taskDefinition.setTaskPriority(Priority.MEDIUM);
13951395
taskDefinition.setEnvironmentCode(-1);
13961396
taskDefinition.setTimeout(0);

‎dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProjectWorkerGroupRelationServiceImpl.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import org.apache.dolphinscheduler.dao.mapper.ScheduleMapper;
3333
import org.apache.dolphinscheduler.dao.mapper.TaskDefinitionMapper;
3434
import org.apache.dolphinscheduler.dao.mapper.WorkerGroupMapper;
35+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
3536

3637
import org.apache.commons.collections.CollectionUtils;
3738
import org.apache.commons.collections4.SetUtils;
@@ -118,7 +119,7 @@ public Result assignWorkerGroupsToProject(User loginUser, Long projectCode, List
118119
workerGroupMapper.queryAllWorkerGroup().stream().map(WorkerGroup::getName).collect(
119120
Collectors.toSet());
120121

121-
workerGroupNames.add(Constants.DEFAULT_WORKER_GROUP);
122+
workerGroupNames.add(WorkerGroupUtils.getDefaultWorkerGroup());
122123

123124
Set<String> assignedWorkerGroupNames = new HashSet<>(workerGroups);
124125

‎dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java

+3-24
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import org.apache.dolphinscheduler.dao.entity.ProcessInstance;
3333
import org.apache.dolphinscheduler.dao.entity.Schedule;
3434
import org.apache.dolphinscheduler.dao.entity.TaskDefinition;
35-
import org.apache.dolphinscheduler.dao.entity.TaskInstance;
3635
import org.apache.dolphinscheduler.dao.entity.User;
3736
import org.apache.dolphinscheduler.dao.entity.WorkerGroup;
3837
import org.apache.dolphinscheduler.dao.mapper.EnvironmentWorkerGroupRelationMapper;
@@ -41,6 +40,7 @@
4140
import org.apache.dolphinscheduler.dao.mapper.ScheduleMapper;
4241
import org.apache.dolphinscheduler.dao.mapper.TaskDefinitionMapper;
4342
import org.apache.dolphinscheduler.dao.mapper.WorkerGroupMapper;
43+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
4444
import org.apache.dolphinscheduler.registry.api.RegistryClient;
4545
import org.apache.dolphinscheduler.registry.api.enums.RegistryNodeType;
4646
import org.apache.dolphinscheduler.service.process.ProcessService;
@@ -357,12 +357,12 @@ private List<WorkerGroup> getWorkerGroups(List<Integer> ids) {
357357
workerGroups = workerGroupMapper.queryAllWorkerGroup();
358358
}
359359
boolean containDefaultWorkerGroups = workerGroups.stream()
360-
.anyMatch(workerGroup -> Constants.DEFAULT_WORKER_GROUP.equals(workerGroup.getName()));
360+
.anyMatch(workerGroup -> WorkerGroupUtils.isWorkerGroupEmpty(workerGroup.getName()));
361361
if (!containDefaultWorkerGroups) {
362362
// there doesn't exist a default WorkerGroup, we will add all worker to the default worker group.
363363
Set<String> activeWorkerNodes = registryClient.getServerNodeSet(RegistryNodeType.WORKER);
364364
WorkerGroup defaultWorkerGroup = new WorkerGroup();
365-
defaultWorkerGroup.setName(Constants.DEFAULT_WORKER_GROUP);
365+
defaultWorkerGroup.setName(WorkerGroupUtils.getDefaultWorkerGroup());
366366
defaultWorkerGroup.setAddrList(String.join(Constants.COMMA, activeWorkerNodes));
367367
defaultWorkerGroup.setCreateTime(new Date());
368368
defaultWorkerGroup.setUpdateTime(new Date());
@@ -431,27 +431,6 @@ public Map<String, Object> getWorkerAddressList() {
431431
return result;
432432
}
433433

434-
@Override
435-
public String getTaskWorkerGroup(TaskInstance taskInstance) {
436-
if (taskInstance == null) {
437-
return null;
438-
}
439-
440-
String workerGroup = taskInstance.getWorkerGroup();
441-
442-
if (StringUtils.isNotEmpty(workerGroup)) {
443-
return workerGroup;
444-
}
445-
int processInstanceId = taskInstance.getProcessInstanceId();
446-
ProcessInstance processInstance = processService.findProcessInstanceById(processInstanceId);
447-
448-
if (processInstance != null) {
449-
return processInstance.getWorkerGroup();
450-
}
451-
log.info("task : {} will use default worker group", taskInstance.getId());
452-
return Constants.DEFAULT_WORKER_GROUP;
453-
}
454-
455434
@Override
456435
public Map<Long, String> queryWorkerGroupByProcessDefinitionCodes(List<Long> processDefinitionCodeList) {
457436
List<Schedule> processDefinitionScheduleList =

‎dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/ExecuteFunctionServiceTest.java

+16-13
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@
6767
import org.apache.dolphinscheduler.dao.mapper.TaskGroupQueueMapper;
6868
import org.apache.dolphinscheduler.dao.mapper.TenantMapper;
6969
import org.apache.dolphinscheduler.dao.repository.ProcessInstanceDao;
70+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
7071
import org.apache.dolphinscheduler.registry.api.enums.RegistryNodeType;
7172
import org.apache.dolphinscheduler.service.command.CommandService;
7273
import org.apache.dolphinscheduler.service.process.ProcessService;
@@ -271,7 +272,7 @@ public void testNoComplement() {
271272
null, null,
272273
null, null, null,
273274
RunMode.RUN_MODE_SERIAL,
274-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 10, null, null,
275+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 10, null, null,
275276
Constants.DRY_RUN_FLAG_NO,
276277
Constants.TEST_FLAG_NO,
277278
ComplementDependentMode.OFF_MODE, null,
@@ -298,7 +299,7 @@ public void testComplementWithStartNodeList() {
298299
null, "123456789,987654321",
299300
null, null, null,
300301
RunMode.RUN_MODE_SERIAL,
301-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, null,
302+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, null,
302303
Constants.DRY_RUN_FLAG_NO,
303304
Constants.TEST_FLAG_NO,
304305
ComplementDependentMode.OFF_MODE, null,
@@ -323,7 +324,7 @@ public void testComplementWithOldStartNodeList() {
323324
null, "1123456789,987654321",
324325
null, null, null,
325326
RunMode.RUN_MODE_SERIAL,
326-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, 0,
327+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, 0,
327328
Constants.DRY_RUN_FLAG_NO,
328329
Constants.TEST_FLAG_NO,
329330
ComplementDependentMode.OFF_MODE, null,
@@ -354,14 +355,14 @@ public void testComplementWithDependentMode() {
354355
dependentProcessDefinition.setProcessDefinitionCode(2);
355356
dependentProcessDefinition.setProcessDefinitionVersion(1);
356357
dependentProcessDefinition.setTaskDefinitionCode(1);
357-
dependentProcessDefinition.setWorkerGroup(Constants.DEFAULT_WORKER_GROUP);
358+
dependentProcessDefinition.setWorkerGroup(WorkerGroupUtils.getDefaultWorkerGroup());
358359
dependentProcessDefinition.setTaskParams(
359360
"{\"localParams\":[],\"resourceList\":[],\"dependence\":{\"relation\":\"AND\",\"dependTaskList\":[{\"relation\":\"AND\",\"dependItemList\":[{\"depTaskCode\":2,\"status\":\"SUCCESS\"}]}]},\"conditionResult\":{\"successNode\":[1],\"failedNode\":[1]}}");
360361
Mockito.when(processService.queryDependentProcessDefinitionByProcessDefinitionCode(processDefinitionCode))
361362
.thenReturn(Lists.newArrayList(dependentProcessDefinition));
362363

363364
Map<Long, String> processDefinitionWorkerGroupMap = new HashMap<>();
364-
processDefinitionWorkerGroupMap.put(1L, Constants.DEFAULT_WORKER_GROUP);
365+
processDefinitionWorkerGroupMap.put(1L, WorkerGroupUtils.getDefaultWorkerGroup());
365366
Mockito.when(workerGroupService.queryWorkerGroupByProcessDefinitionCodes(Lists.newArrayList(1L)))
366367
.thenReturn(processDefinitionWorkerGroupMap);
367368

@@ -370,7 +371,7 @@ public void testComplementWithDependentMode() {
370371
command.setCommandType(CommandType.COMPLEMENT_DATA);
371372
command.setCommandParam(
372373
"{\"StartNodeList\":\"1\",\"complementStartDate\":\"2020-01-01 00:00:00\",\"complementEndDate\":\"2020-01-31 23:00:00\"}");
373-
command.setWorkerGroup(Constants.DEFAULT_WORKER_GROUP);
374+
command.setWorkerGroup(WorkerGroupUtils.getDefaultWorkerGroup());
374375
command.setProcessDefinitionCode(processDefinitionCode);
375376
command.setExecutorId(1);
376377

@@ -383,7 +384,7 @@ public void testComplementWithDependentMode() {
383384
childDependent.setProcessDefinitionCode(3);
384385
childDependent.setProcessDefinitionVersion(1);
385386
childDependent.setTaskDefinitionCode(4);
386-
childDependent.setWorkerGroup(Constants.DEFAULT_WORKER_GROUP);
387+
childDependent.setWorkerGroup(WorkerGroupUtils.getDefaultWorkerGroup());
387388
childDependent.setTaskParams(
388389
"{\"localParams\":[],\"resourceList\":[],\"dependence\":{\"relation\":\"AND\",\"dependTaskList\":[{\"relation\":\"AND\",\"dependItemList\":[{\"depTaskCode\":3,\"status\":\"SUCCESS\"}]}]},\"conditionResult\":{\"successNode\":[1],\"failedNode\":[1]}}");
389390
Mockito.when(processService.queryDependentProcessDefinitionByProcessDefinitionCode(
@@ -409,7 +410,8 @@ public void testDateError() {
409410
null, null,
410411
null, null, null,
411412
RunMode.RUN_MODE_SERIAL,
412-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, 2, Constants.DRY_RUN_FLAG_NO,
413+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, 2,
414+
Constants.DRY_RUN_FLAG_NO,
413415
Constants.TEST_FLAG_NO,
414416
ComplementDependentMode.OFF_MODE, null,
415417
false,
@@ -434,7 +436,7 @@ public void testSerial() {
434436
null, null,
435437
null, null, null,
436438
RunMode.RUN_MODE_SERIAL,
437-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, null,
439+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, null,
438440
Constants.DRY_RUN_FLAG_NO,
439441
Constants.TEST_FLAG_NO,
440442
ComplementDependentMode.OFF_MODE, null,
@@ -460,7 +462,8 @@ public void testParallelWithOutSchedule() {
460462
null, null,
461463
null, null, null,
462464
RunMode.RUN_MODE_PARALLEL,
463-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, 2, Constants.DRY_RUN_FLAG_NO,
465+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, 2,
466+
Constants.DRY_RUN_FLAG_NO,
464467
Constants.TEST_FLAG_NO,
465468
ComplementDependentMode.OFF_MODE, null,
466469
false,
@@ -486,7 +489,7 @@ public void testParallelWithSchedule() {
486489
null, null,
487490
null, null, null,
488491
RunMode.RUN_MODE_PARALLEL,
489-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, 15,
492+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, 15,
490493
Constants.DRY_RUN_FLAG_NO,
491494
Constants.TEST_FLAG_NO,
492495
ComplementDependentMode.OFF_MODE, null,
@@ -514,7 +517,7 @@ public void testNoMasterServers() {
514517
null,
515518
RunMode.RUN_MODE_PARALLEL,
516519
Priority.LOW,
517-
Constants.DEFAULT_WORKER_GROUP,
520+
WorkerGroupUtils.getDefaultWorkerGroup(),
518521
tenantCode,
519522
100L,
520523
110,
@@ -553,7 +556,7 @@ public void testOfTestRun() {
553556
null, null,
554557
null, null, 0,
555558
RunMode.RUN_MODE_PARALLEL,
556-
Priority.LOW, Constants.DEFAULT_WORKER_GROUP, tenantCode, 100L, 110, null, 15,
559+
Priority.LOW, WorkerGroupUtils.getDefaultWorkerGroup(), tenantCode, 100L, 110, null, 15,
557560
Constants.DRY_RUN_FLAG_NO,
558561
Constants.TEST_FLAG_YES,
559562
ComplementDependentMode.OFF_MODE, null,

‎dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/ProcessDefinitionServiceTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@
7272
import org.apache.dolphinscheduler.dao.repository.ProcessDefinitionDao;
7373
import org.apache.dolphinscheduler.dao.repository.ProcessDefinitionLogDao;
7474
import org.apache.dolphinscheduler.dao.repository.TaskDefinitionLogDao;
75+
import org.apache.dolphinscheduler.dao.utils.WorkerGroupUtils;
7576
import org.apache.dolphinscheduler.service.alert.ListenerEventAlertManager;
7677
import org.apache.dolphinscheduler.service.process.ProcessService;
7778
import org.apache.dolphinscheduler.spi.enums.DbType;
@@ -1143,7 +1144,7 @@ private Schedule getSchedule() {
11431144
schedule.setProcessInstancePriority(Priority.MEDIUM);
11441145
schedule.setWarningType(WarningType.NONE);
11451146
schedule.setWarningGroupId(1);
1146-
schedule.setWorkerGroup(Constants.DEFAULT_WORKER_GROUP);
1147+
schedule.setWorkerGroup(WorkerGroupUtils.getDefaultWorkerGroup());
11471148
return schedule;
11481149
}
11491150

‎dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/WorkerGroupServiceTest.java

-44
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.apache.dolphinscheduler.common.enums.AuthorizationType;
3131
import org.apache.dolphinscheduler.common.enums.UserType;
3232
import org.apache.dolphinscheduler.dao.entity.ProcessInstance;
33-
import org.apache.dolphinscheduler.dao.entity.TaskInstance;
3433
import org.apache.dolphinscheduler.dao.entity.User;
3534
import org.apache.dolphinscheduler.dao.entity.WorkerGroup;
3635
import org.apache.dolphinscheduler.dao.mapper.EnvironmentWorkerGroupRelationMapper;
@@ -65,8 +64,6 @@
6564
@MockitoSettings(strictness = Strictness.LENIENT)
6665
public class WorkerGroupServiceTest {
6766

68-
private static final Logger logger = LoggerFactory.getLogger(WorkerGroupServiceTest.class);
69-
7067
private static final Logger baseServiceLogger = LoggerFactory.getLogger(BaseServiceImpl.class);
7168

7269
private static final Logger serviceLogger = LoggerFactory.getLogger(WorkerGroupService.class);
@@ -288,47 +285,6 @@ public void testQueryAllGroupWithDefault() {
288285
Assertions.assertEquals("default", workerGroups.toArray()[0]);
289286
}
290287

291-
@Test
292-
public void giveNull_whenGetTaskWorkerGroup_expectNull() {
293-
String nullWorkerGroup = workerGroupService.getTaskWorkerGroup(null);
294-
Assertions.assertNull(nullWorkerGroup);
295-
}
296-
297-
@Test
298-
public void giveCorrectTaskInstance_whenGetTaskWorkerGroup_expectTaskWorkerGroup() {
299-
TaskInstance taskInstance = new TaskInstance();
300-
taskInstance.setId(1);
301-
taskInstance.setWorkerGroup("cluster1");
302-
303-
String workerGroup = workerGroupService.getTaskWorkerGroup(taskInstance);
304-
Assertions.assertEquals("cluster1", workerGroup);
305-
}
306-
307-
@Test
308-
public void giveNullWorkerGroup_whenGetTaskWorkerGroup_expectProcessWorkerGroup() {
309-
TaskInstance taskInstance = new TaskInstance();
310-
taskInstance.setId(1);
311-
taskInstance.setProcessInstanceId(1);
312-
ProcessInstance processInstance = new ProcessInstance();
313-
processInstance.setId(1);
314-
processInstance.setWorkerGroup("cluster1");
315-
Mockito.when(processService.findProcessInstanceById(1)).thenReturn(processInstance);
316-
317-
String workerGroup = workerGroupService.getTaskWorkerGroup(taskInstance);
318-
Assertions.assertEquals("cluster1", workerGroup);
319-
}
320-
321-
@Test
322-
public void giveNullTaskAndProcessWorkerGroup_whenGetTaskWorkerGroup_expectDefault() {
323-
TaskInstance taskInstance = new TaskInstance();
324-
taskInstance.setId(1);
325-
taskInstance.setProcessInstanceId(1);
326-
Mockito.when(processService.findProcessInstanceById(1)).thenReturn(null);
327-
328-
String defaultWorkerGroup = workerGroupService.getTaskWorkerGroup(taskInstance);
329-
Assertions.assertEquals(Constants.DEFAULT_WORKER_GROUP, defaultWorkerGroup);
330-
}
331-
332288
/**
333289
* get Group
334290
*/

‎dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/Constants.java

-5
Original file line numberDiff line numberDiff line change
@@ -508,14 +508,9 @@ private Constants() {
508508
* session timeout
509509
*/
510510
public static final int SESSION_TIME_OUT = 7200;
511-
public static final int MAX_FILE_SIZE = 1024 * 1024 * 1024;
512511
public static final String UDF = "UDF";
513512
public static final String CLASS = "class";
514513

515-
/**
516-
* default worker group
517-
*/
518-
public static final String DEFAULT_WORKER_GROUP = "default";
519514
/**
520515
* authorize writable perm
521516
*/

0 commit comments

Comments
 (0)