[incubator-dolphinscheduler] branch dev updated: [fix-#3962][api] Avoid ClassCastException for LoggerService.queryLog(). (#3963)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new e9479e4  [fix-#3962][api] Avoid ClassCastException for 
LoggerService.queryLog(). (#3963)
e9479e4 is described below

commit e9479e4a039078c73a8582f1dc4bd982426cf83c
Author: t1mon <178317...@qq.com>
AuthorDate: Mon Oct 26 18:26:42 2020 +0800

    [fix-#3962][api] Avoid ClassCastException for LoggerService.queryLog(). 
(#3963)
---
 .../apache/dolphinscheduler/api/service/ProcessInstanceService.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ProcessInstanceService.java
 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ProcessInstanceService.java
index c8d3c74..739fa19 100644
--- 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ProcessInstanceService.java
+++ 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ProcessInstanceService.java
@@ -305,10 +305,10 @@ public class ProcessInstanceService extends BaseService {
     private void addDependResultForTaskList(List<TaskInstance> 
taskInstanceList) throws IOException {
         for (TaskInstance taskInstance : taskInstanceList) {
             if 
(taskInstance.getTaskType().equalsIgnoreCase(TaskType.DEPENDENT.toString())) {
-                Result logResult = loggerService.queryLog(
+                Result<String> logResult = loggerService.queryLog(
                         taskInstance.getId(), 0, 4098);
                 if (logResult.getCode() == Status.SUCCESS.ordinal()) {
-                    String log = (String) logResult.getData();
+                    String log = logResult.getData();
                     Map<String, DependResult> resultMap = 
parseLogForDependentResult(log);
                     
taskInstance.setDependentResult(JSONUtils.toJsonString(resultMap));
                 }