Complete the migration of the collector node project #43
Conversation
![github-advanced-security[bot]](https://avatars.githubusercontent.com/in/57789?s=60&v=4){kind=small}
| PROCESSOR_EXECUTOR.putIfAbsent(taskId, executorService); | ||
| PROCESSOR_TASK_MAP.putIfAbsent(taskId, collectorTask); | ||
|
|
||
| LOGGER.info("register collector processor task {}", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
| PROCESSOR_TASK_MAP.remove(taskId).stop(); | ||
| PROCESSOR_EXECUTOR.remove(taskId).shutdownNow(); | ||
|
|
||
| LOGGER.info("deregister collector processor task {}", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
| SINK_EXECUTOR.putIfAbsent(taskId, executorService); | ||
| SINK_TASK_MAP.putIfAbsent(taskId, collectorTask); | ||
|
|
||
| LOGGER.info("register collector sink task {}", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
| SINK_TASK_MAP.remove(taskId).stop(); | ||
| SINK_EXECUTOR.remove(taskId).shutdownNow(); | ||
|
|
||
| LOGGER.info("deregister collector sink task {}", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
| SOURCE_EXECUTOR.put(taskId, executorService); | ||
| SOURCE_TASK_MAP.putIfAbsent(taskId, collectorTask); | ||
|
|
||
| LOGGER.info("register collector source task {}", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
| .ifPresent( | ||
| executor -> { | ||
| executor.submit(collectorTask); | ||
| LOGGER.info("register success {}", collectorTask.getTaskId()); |
Check failure
Code scanning / CodeQL
Log Injection High
| recordExecution(collectorTask, executor); | ||
| }); | ||
| } else { | ||
| LOGGER.warn("task {} has existed", collectorTask.getTaskId()); |
Check failure
Code scanning / CodeQL
Log Injection High
| if (!validateIfAbsent(taskId)) { | ||
| eraseExecution(taskId); | ||
| } else { | ||
| LOGGER.warn("task {} has not existed", taskId); |
Check failure
Code scanning / CodeQL
Log Injection High
|
|
||
| final boolean stopResult = CollectorAgent.task().stopCollectorTask(stopPipeRequest.getTaskId()); | ||
| if (stopResult) { | ||
| LOGGER.info("Stop task: {} successful", stopPipeRequest.getTaskId()); |
Check failure
Code scanning / CodeQL
Log Injection High
| LOGGER.info("Stop task: {} successful", stopPipeRequest.getTaskId()); | ||
| return Response.ok().entity("stop task: " + stopPipeRequest.getTaskId() + " success").build(); | ||
| } | ||
| LOGGER.warn("Stop task: {} failed", stopPipeRequest.getTaskId()); |
Check failure
Code scanning / CodeQL
Log Injection High
2 participants
as the title