|
|
@ -16,6 +16,7 @@ |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
package org.apache.dolphinscheduler.service.log; |
|
|
|
package org.apache.dolphinscheduler.service.log; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.common.Constants; |
|
|
|
import org.apache.dolphinscheduler.remote.NettyRemotingClient; |
|
|
|
import org.apache.dolphinscheduler.remote.NettyRemotingClient; |
|
|
|
import org.apache.dolphinscheduler.remote.command.Command; |
|
|
|
import org.apache.dolphinscheduler.remote.command.Command; |
|
|
|
import org.apache.dolphinscheduler.remote.command.log.*; |
|
|
|
import org.apache.dolphinscheduler.remote.command.log.*; |
|
|
@ -78,7 +79,7 @@ public class LogClientService { |
|
|
|
Command response = this.client.sendSync(address, command, logRequestTimeout); |
|
|
|
Command response = this.client.sendSync(address, command, logRequestTimeout); |
|
|
|
if(response != null){ |
|
|
|
if(response != null){ |
|
|
|
RollViewLogResponseCommand rollReviewLog = FastJsonSerializer.deserialize( |
|
|
|
RollViewLogResponseCommand rollReviewLog = FastJsonSerializer.deserialize( |
|
|
|
command.getBody(), RollViewLogResponseCommand.class); |
|
|
|
response.getBody(), RollViewLogResponseCommand.class); |
|
|
|
return rollReviewLog.getMsg(); |
|
|
|
return rollReviewLog.getMsg(); |
|
|
|
} |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
} catch (Exception e) { |
|
|
|