diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataSourceService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataSourceService.java index d3a76ab26b..80394fef8d 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataSourceService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataSourceService.java @@ -580,8 +580,8 @@ public class DataSourceService extends BaseService{ datasourceUserMapper.deleteByDatasourceId(datasourceId); putMsg(result, Status.SUCCESS); } catch (Exception e) { - logger.error("delete datasource fail",e); - throw new RuntimeException("delete datasource fail"); + logger.error("delete datasource error",e); + throw new RuntimeException("delete datasource error"); } return result; } 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 8ea0ffed70..1419ed8258 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 @@ -536,12 +536,9 @@ public class ProcessInstanceService extends BaseDAGService { nodeValueSb.append(ipSb); } - try { - logger.info("delete task queue node : {}",nodeValueSb.toString()); - tasksQueue.removeNode(org.apache.dolphinscheduler.common.Constants.DOLPHINSCHEDULER_TASKS_QUEUE, nodeValueSb.toString()); - }catch (Exception e){ - logger.error("delete task queue node : {}", nodeValueSb.toString()); - } + logger.info("delete task queue node : {}",nodeValueSb.toString()); + tasksQueue.removeNode(org.apache.dolphinscheduler.common.Constants.DOLPHINSCHEDULER_TASKS_QUEUE, nodeValueSb.toString()); + } } diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ResourcesService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ResourcesService.java index ecf30519eb..ce60892734 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ResourcesService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ResourcesService.java @@ -153,8 +153,7 @@ public class ResourcesService extends BaseService { result.setData(resultMap); } catch (Exception e) { logger.error("resource already exists, can't recreate ", e); - putMsg(result, Status.CREATE_RESOURCE_ERROR); - return result; + throw new RuntimeException("resource already exists, can't recreate"); } // fail upload @@ -248,8 +247,7 @@ public class ResourcesService extends BaseService { result.setData(resultMap); } catch (Exception e) { logger.error(Status.UPDATE_RESOURCE_ERROR.getMsg(), e); - putMsg(result, Status.UPDATE_RESOURCE_ERROR); - return result; + throw new RuntimeException(Status.UPDATE_RESOURCE_ERROR.getMsg()); } // if name unchanged, return directly without moving on HDFS if (originResourceName.equals(name)) { diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/SchedulerService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/SchedulerService.java index 67384ac14b..042e16f9f9 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/SchedulerService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/SchedulerService.java @@ -97,9 +97,16 @@ public class SchedulerService extends BaseService { * @throws IOException ioexception */ @Transactional(rollbackFor = Exception.class) - public Map insertSchedule(User loginUser, String projectName, Integer processDefineId, String schedule, WarningType warningType, - int warningGroupId, FailureStrategy failureStrategy, - String receivers, String receiversCc, Priority processInstancePriority, int workerGroupId) throws IOException { + public Map insertSchedule(User loginUser, String projectName, + Integer processDefineId, + String schedule, + WarningType warningType, + int warningGroupId, + FailureStrategy failureStrategy, + String receivers, + String receiversCc, + Priority processInstancePriority, + int workerGroupId) throws IOException { Map result = new HashMap(5); @@ -183,10 +190,18 @@ public class SchedulerService extends BaseService { * @throws IOException ioexception */ @Transactional(rollbackFor = Exception.class) - public Map updateSchedule(User loginUser, String projectName, Integer id, String scheduleExpression, WarningType warningType, - int warningGroupId, FailureStrategy failureStrategy, - String receivers, String receiversCc, ReleaseState scheduleStatus, - Priority processInstancePriority, int workerGroupId) throws IOException { + public Map updateSchedule(User loginUser, + String projectName, + Integer id, + String scheduleExpression, + WarningType warningType, + int warningGroupId, + FailureStrategy failureStrategy, + String receivers, + String receiversCc, + ReleaseState scheduleStatus, + Priority processInstancePriority, + int workerGroupId) throws IOException { Map result = new HashMap(5); Project project = projectMapper.queryByName(projectName); @@ -277,7 +292,10 @@ public class SchedulerService extends BaseService { * @return publish result code */ @Transactional(rollbackFor = Exception.class) - public Map setScheduleState(User loginUser, String projectName, Integer id, ReleaseState scheduleStatus) { + public Map setScheduleState(User loginUser, + String projectName, + Integer id, + ReleaseState scheduleStatus) { Map result = new HashMap(5); diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java index 1c55b565a8..90a5fa60ff 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UdfFuncService.java @@ -298,7 +298,7 @@ public class UdfFuncService extends BaseService{ * @param id udf function id * @return delete result code */ - @Transactional(value = "transactionManager",rollbackFor = Exception.class) + @Transactional(rollbackFor = Exception.class) public Result delete(int id) { Result result = new Result(); diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java index 64d8f46fc2..6fdc233455 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java @@ -20,6 +20,8 @@ import com.alibaba.druid.pool.DruidDataSource; import com.baomidou.mybatisplus.core.MybatisConfiguration; import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor; import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean; +import org.apache.commons.configuration.ConfigurationException; +import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.dolphinscheduler.common.Constants; import org.apache.ibatis.mapping.Environment; import org.apache.ibatis.session.SqlSession; @@ -30,6 +32,7 @@ import org.mybatis.spring.SqlSessionTemplate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.annotation.Bean; +import org.springframework.stereotype.Service; import javax.sql.DataSource; diff --git a/dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java b/dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java index ca7644fedf..3311ac9a5c 100644 --- a/dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java +++ b/dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java @@ -42,474 +42,474 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall; comments = "Source: scheduler.proto") public final class LogViewServiceGrpc { - private LogViewServiceGrpc() {} + private LogViewServiceGrpc() {} - public static final String SERVICE_NAME = "schduler.LogViewService"; + public static final String SERVICE_NAME = "schduler.LogViewService"; - // Static method descriptors that strictly reflect the proto. - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getRollViewLogMethod()} instead. - public static final io.grpc.MethodDescriptor METHOD_ROLL_VIEW_LOG = getRollViewLogMethod(); + // Static method descriptors that strictly reflect the proto. + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + @java.lang.Deprecated // Use {@link #getRollViewLogMethod()} instead. + public static final io.grpc.MethodDescriptor METHOD_ROLL_VIEW_LOG = getRollViewLogMethod(); - private static volatile io.grpc.MethodDescriptor getRollViewLogMethod; + private static volatile io.grpc.MethodDescriptor getRollViewLogMethod; - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - public static io.grpc.MethodDescriptor getRollViewLogMethod() { - io.grpc.MethodDescriptor getRollViewLogMethod; - if ((getRollViewLogMethod = LogViewServiceGrpc.getRollViewLogMethod) == null) { - synchronized (LogViewServiceGrpc.class) { + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + public static io.grpc.MethodDescriptor getRollViewLogMethod() { + io.grpc.MethodDescriptor getRollViewLogMethod; if ((getRollViewLogMethod = LogViewServiceGrpc.getRollViewLogMethod) == null) { - LogViewServiceGrpc.getRollViewLogMethod = getRollViewLogMethod = - io.grpc.MethodDescriptor.newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName( - "schduler.LogViewService", "rollViewLog")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.LogParameter.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.RetStrInfo.getDefaultInstance())) - .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("rollViewLog")) - .build(); - } - } + synchronized (LogViewServiceGrpc.class) { + if ((getRollViewLogMethod = LogViewServiceGrpc.getRollViewLogMethod) == null) { + LogViewServiceGrpc.getRollViewLogMethod = getRollViewLogMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName( + "schduler.LogViewService", "rollViewLog")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.LogParameter.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.RetStrInfo.getDefaultInstance())) + .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("rollViewLog")) + .build(); + } + } + } + return getRollViewLogMethod; } - return getRollViewLogMethod; - } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getViewLogMethod()} instead. - public static final io.grpc.MethodDescriptor METHOD_VIEW_LOG = getViewLogMethod(); - - private static volatile io.grpc.MethodDescriptor getViewLogMethod; - - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - public static io.grpc.MethodDescriptor getViewLogMethod() { - io.grpc.MethodDescriptor getViewLogMethod; - if ((getViewLogMethod = LogViewServiceGrpc.getViewLogMethod) == null) { - synchronized (LogViewServiceGrpc.class) { + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + @java.lang.Deprecated // Use {@link #getViewLogMethod()} instead. + public static final io.grpc.MethodDescriptor METHOD_VIEW_LOG = getViewLogMethod(); + + private static volatile io.grpc.MethodDescriptor getViewLogMethod; + + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + public static io.grpc.MethodDescriptor getViewLogMethod() { + io.grpc.MethodDescriptor getViewLogMethod; if ((getViewLogMethod = LogViewServiceGrpc.getViewLogMethod) == null) { - LogViewServiceGrpc.getViewLogMethod = getViewLogMethod = - io.grpc.MethodDescriptor.newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName( - "schduler.LogViewService", "viewLog")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.PathParameter.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.RetStrInfo.getDefaultInstance())) - .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("viewLog")) - .build(); - } - } + synchronized (LogViewServiceGrpc.class) { + if ((getViewLogMethod = LogViewServiceGrpc.getViewLogMethod) == null) { + LogViewServiceGrpc.getViewLogMethod = getViewLogMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName( + "schduler.LogViewService", "viewLog")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.PathParameter.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.RetStrInfo.getDefaultInstance())) + .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("viewLog")) + .build(); + } + } + } + return getViewLogMethod; } - return getViewLogMethod; - } - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - @java.lang.Deprecated // Use {@link #getGetLogBytesMethod()} instead. - public static final io.grpc.MethodDescriptor METHOD_GET_LOG_BYTES = getGetLogBytesMethod(); - - private static volatile io.grpc.MethodDescriptor getGetLogBytesMethod; - - @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") - public static io.grpc.MethodDescriptor getGetLogBytesMethod() { - io.grpc.MethodDescriptor getGetLogBytesMethod; - if ((getGetLogBytesMethod = LogViewServiceGrpc.getGetLogBytesMethod) == null) { - synchronized (LogViewServiceGrpc.class) { + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + @java.lang.Deprecated // Use {@link #getGetLogBytesMethod()} instead. + public static final io.grpc.MethodDescriptor METHOD_GET_LOG_BYTES = getGetLogBytesMethod(); + + private static volatile io.grpc.MethodDescriptor getGetLogBytesMethod; + + @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901") + public static io.grpc.MethodDescriptor getGetLogBytesMethod() { + io.grpc.MethodDescriptor getGetLogBytesMethod; if ((getGetLogBytesMethod = LogViewServiceGrpc.getGetLogBytesMethod) == null) { - LogViewServiceGrpc.getGetLogBytesMethod = getGetLogBytesMethod = - io.grpc.MethodDescriptor.newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName( - "schduler.LogViewService", "getLogBytes")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.PathParameter.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - org.apache.dolphinscheduler.rpc.RetByteInfo.getDefaultInstance())) - .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("getLogBytes")) - .build(); - } - } + synchronized (LogViewServiceGrpc.class) { + if ((getGetLogBytesMethod = LogViewServiceGrpc.getGetLogBytesMethod) == null) { + LogViewServiceGrpc.getGetLogBytesMethod = getGetLogBytesMethod = + io.grpc.MethodDescriptor.newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName( + "schduler.LogViewService", "getLogBytes")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.PathParameter.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + org.apache.dolphinscheduler.rpc.RetByteInfo.getDefaultInstance())) + .setSchemaDescriptor(new LogViewServiceMethodDescriptorSupplier("getLogBytes")) + .build(); + } + } + } + return getGetLogBytesMethod; } - return getGetLogBytesMethod; - } - - /** - * Creates a new async stub that supports all call types for the service - */ - public static LogViewServiceStub newStub(io.grpc.Channel channel) { - return new LogViewServiceStub(channel); - } - - /** - * Creates a new blocking-style stub that supports unary and streaming output calls on the service - */ - public static LogViewServiceBlockingStub newBlockingStub( - io.grpc.Channel channel) { - return new LogViewServiceBlockingStub(channel); - } - - /** - * Creates a new ListenableFuture-style stub that supports unary calls on the service - */ - public static LogViewServiceFutureStub newFutureStub( - io.grpc.Channel channel) { - return new LogViewServiceFutureStub(channel); - } - - /** - * 
-   **
-   *  log view service
-   *
- */ - public static abstract class LogViewServiceImplBase implements io.grpc.BindableService { /** - * 
-     **
-     *  roll view log
-     *
+ * Creates a new async stub that supports all call types for the service */ - public void rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request, - io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getRollViewLogMethod(), responseObserver); + public static LogViewServiceStub newStub(io.grpc.Channel channel) { + return new LogViewServiceStub(channel); } /** - * 
-     **
-     * view all log
-     *
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ - public void viewLog(org.apache.dolphinscheduler.rpc.PathParameter request, - io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getViewLogMethod(), responseObserver); + public static LogViewServiceBlockingStub newBlockingStub( + io.grpc.Channel channel) { + return new LogViewServiceBlockingStub(channel); } /** - * 
-     **
-     * get log bytes
-     *
+ * Creates a new ListenableFuture-style stub that supports unary calls on the service */ - public void getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request, - io.grpc.stub.StreamObserver responseObserver) { - asyncUnimplementedUnaryCall(getGetLogBytesMethod(), responseObserver); - } - - @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getRollViewLogMethod(), - asyncUnaryCall( - new MethodHandlers< - org.apache.dolphinscheduler.rpc.LogParameter, - org.apache.dolphinscheduler.rpc.RetStrInfo>( - this, METHODID_ROLL_VIEW_LOG))) - .addMethod( - getViewLogMethod(), - asyncUnaryCall( - new MethodHandlers< - org.apache.dolphinscheduler.rpc.PathParameter, - org.apache.dolphinscheduler.rpc.RetStrInfo>( - this, METHODID_VIEW_LOG))) - .addMethod( - getGetLogBytesMethod(), - asyncUnaryCall( - new MethodHandlers< - org.apache.dolphinscheduler.rpc.PathParameter, - org.apache.dolphinscheduler.rpc.RetByteInfo>( - this, METHODID_GET_LOG_BYTES))) - .build(); - } - } - - /** - * 
-   **
-   *  log view service
-   *
- */ - public static final class LogViewServiceStub extends io.grpc.stub.AbstractStub { - private LogViewServiceStub(io.grpc.Channel channel) { - super(channel); - } - - private LogViewServiceStub(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - super(channel, callOptions); - } - - @java.lang.Override - protected LogViewServiceStub build(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - return new LogViewServiceStub(channel, callOptions); + public static LogViewServiceFutureStub newFutureStub( + io.grpc.Channel channel) { + return new LogViewServiceFutureStub(channel); } /** * 
      **
-     *  roll view log
+     *  log view service
      *
*/ - public void rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request, + public static abstract class LogViewServiceImplBase implements io.grpc.BindableService { + + /** + * 
+         **
+         *  roll view log
+         *
+ */ + public void rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request, + io.grpc.stub.StreamObserver responseObserver) { + asyncUnimplementedUnaryCall(getRollViewLogMethod(), responseObserver); + } + + /** + * 
+         **
+         * view all log
+         *
+ */ + public void viewLog(org.apache.dolphinscheduler.rpc.PathParameter request, io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( - getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request, responseObserver); - } + asyncUnimplementedUnaryCall(getViewLogMethod(), responseObserver); + } - /** - * 
-     **
-     * view all log
-     *
- */ - public void viewLog(org.apache.dolphinscheduler.rpc.PathParameter request, - io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( - getChannel().newCall(getViewLogMethod(), getCallOptions()), request, responseObserver); + /** + * 
+         **
+         * get log bytes
+         *
+ */ + public void getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request, + io.grpc.stub.StreamObserver responseObserver) { + asyncUnimplementedUnaryCall(getGetLogBytesMethod(), responseObserver); + } + + @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { + return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) + .addMethod( + getRollViewLogMethod(), + asyncUnaryCall( + new MethodHandlers< + org.apache.dolphinscheduler.rpc.LogParameter, + org.apache.dolphinscheduler.rpc.RetStrInfo>( + this, METHODID_ROLL_VIEW_LOG))) + .addMethod( + getViewLogMethod(), + asyncUnaryCall( + new MethodHandlers< + org.apache.dolphinscheduler.rpc.PathParameter, + org.apache.dolphinscheduler.rpc.RetStrInfo>( + this, METHODID_VIEW_LOG))) + .addMethod( + getGetLogBytesMethod(), + asyncUnaryCall( + new MethodHandlers< + org.apache.dolphinscheduler.rpc.PathParameter, + org.apache.dolphinscheduler.rpc.RetByteInfo>( + this, METHODID_GET_LOG_BYTES))) + .build(); + } } /** * 
      **
-     * get log bytes
+     *  log view service
      *
*/ - public void getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request, - io.grpc.stub.StreamObserver responseObserver) { - asyncUnaryCall( - getChannel().newCall(getGetLogBytesMethod(), getCallOptions()), request, responseObserver); - } - } - - /** - * 
-   **
-   *  log view service
-   *
- */ - public static final class LogViewServiceBlockingStub extends io.grpc.stub.AbstractStub { - private LogViewServiceBlockingStub(io.grpc.Channel channel) { - super(channel); - } + public static final class LogViewServiceStub extends io.grpc.stub.AbstractStub { + private LogViewServiceStub(io.grpc.Channel channel) { + super(channel); + } - private LogViewServiceBlockingStub(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - super(channel, callOptions); - } + private LogViewServiceStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } - @java.lang.Override - protected LogViewServiceBlockingStub build(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - return new LogViewServiceBlockingStub(channel, callOptions); - } + @java.lang.Override + protected LogViewServiceStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new LogViewServiceStub(channel, callOptions); + } - /** - * 
-     **
-     *  roll view log
-     *
- */ - public org.apache.dolphinscheduler.rpc.RetStrInfo rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request) { - return blockingUnaryCall( - getChannel(), getRollViewLogMethod(), getCallOptions(), request); - } + /** + * 
+         **
+         *  roll view log
+         *
+ */ + public void rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request, + io.grpc.stub.StreamObserver responseObserver) { + asyncUnaryCall( + getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request, responseObserver); + } - /** - * 
-     **
-     * view all log
-     *
- */ - public org.apache.dolphinscheduler.rpc.RetStrInfo viewLog(org.apache.dolphinscheduler.rpc.PathParameter request) { - return blockingUnaryCall( - getChannel(), getViewLogMethod(), getCallOptions(), request); + /** + * 
+         **
+         * view all log
+         *
+ */ + public void viewLog(org.apache.dolphinscheduler.rpc.PathParameter request, + io.grpc.stub.StreamObserver responseObserver) { + asyncUnaryCall( + getChannel().newCall(getViewLogMethod(), getCallOptions()), request, responseObserver); + } + + /** + * 
+         **
+         * get log bytes
+         *
+ */ + public void getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request, + io.grpc.stub.StreamObserver responseObserver) { + asyncUnaryCall( + getChannel().newCall(getGetLogBytesMethod(), getCallOptions()), request, responseObserver); + } } /** * 
      **
-     * get log bytes
+     *  log view service
      *
*/ - public org.apache.dolphinscheduler.rpc.RetByteInfo getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request) { - return blockingUnaryCall( - getChannel(), getGetLogBytesMethod(), getCallOptions(), request); - } - } - - /** - * 
-   **
-   *  log view service
-   *
- */ - public static final class LogViewServiceFutureStub extends io.grpc.stub.AbstractStub { - private LogViewServiceFutureStub(io.grpc.Channel channel) { - super(channel); - } + public static final class LogViewServiceBlockingStub extends io.grpc.stub.AbstractStub { + private LogViewServiceBlockingStub(io.grpc.Channel channel) { + super(channel); + } - private LogViewServiceFutureStub(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - super(channel, callOptions); - } + private LogViewServiceBlockingStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } - @java.lang.Override - protected LogViewServiceFutureStub build(io.grpc.Channel channel, - io.grpc.CallOptions callOptions) { - return new LogViewServiceFutureStub(channel, callOptions); - } + @java.lang.Override + protected LogViewServiceBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new LogViewServiceBlockingStub(channel, callOptions); + } - /** - * 
-     **
-     *  roll view log
-     *
- */ - public com.google.common.util.concurrent.ListenableFuture rollViewLog( - org.apache.dolphinscheduler.rpc.LogParameter request) { - return futureUnaryCall( - getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request); - } + /** + * 
+         **
+         *  roll view log
+         *
+ */ + public org.apache.dolphinscheduler.rpc.RetStrInfo rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request) { + return blockingUnaryCall( + getChannel(), getRollViewLogMethod(), getCallOptions(), request); + } - /** - * 
-     **
-     * view all log
-     *
- */ - public com.google.common.util.concurrent.ListenableFuture viewLog( - org.apache.dolphinscheduler.rpc.PathParameter request) { - return futureUnaryCall( - getChannel().newCall(getViewLogMethod(), getCallOptions()), request); + /** + * 
+         **
+         * view all log
+         *
+ */ + public org.apache.dolphinscheduler.rpc.RetStrInfo viewLog(org.apache.dolphinscheduler.rpc.PathParameter request) { + return blockingUnaryCall( + getChannel(), getViewLogMethod(), getCallOptions(), request); + } + + /** + * 
+         **
+         * get log bytes
+         *
+ */ + public org.apache.dolphinscheduler.rpc.RetByteInfo getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request) { + return blockingUnaryCall( + getChannel(), getGetLogBytesMethod(), getCallOptions(), request); + } } /** * 
      **
-     * get log bytes
+     *  log view service
      *
*/ - public com.google.common.util.concurrent.ListenableFuture getLogBytes( - org.apache.dolphinscheduler.rpc.PathParameter request) { - return futureUnaryCall( - getChannel().newCall(getGetLogBytesMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_ROLL_VIEW_LOG = 0; - private static final int METHODID_VIEW_LOG = 1; - private static final int METHODID_GET_LOG_BYTES = 2; - - private static final class MethodHandlers implements - io.grpc.stub.ServerCalls.UnaryMethod, - io.grpc.stub.ServerCalls.ServerStreamingMethod, - io.grpc.stub.ServerCalls.ClientStreamingMethod, - io.grpc.stub.ServerCalls.BidiStreamingMethod { - private final LogViewServiceImplBase serviceImpl; - private final int methodId; - - MethodHandlers(LogViewServiceImplBase serviceImpl, int methodId) { - this.serviceImpl = serviceImpl; - this.methodId = methodId; - } + public static final class LogViewServiceFutureStub extends io.grpc.stub.AbstractStub { + private LogViewServiceFutureStub(io.grpc.Channel channel) { + super(channel); + } - @java.lang.Override - @java.lang.SuppressWarnings("unchecked") - public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { - switch (methodId) { - case METHODID_ROLL_VIEW_LOG: - serviceImpl.rollViewLog((org.apache.dolphinscheduler.rpc.LogParameter) request, - (io.grpc.stub.StreamObserver) responseObserver); - break; - case METHODID_VIEW_LOG: - serviceImpl.viewLog((org.apache.dolphinscheduler.rpc.PathParameter) request, - (io.grpc.stub.StreamObserver) responseObserver); - break; - case METHODID_GET_LOG_BYTES: - serviceImpl.getLogBytes((org.apache.dolphinscheduler.rpc.PathParameter) request, - (io.grpc.stub.StreamObserver) responseObserver); - break; - default: - throw new AssertionError(); - } - } + private LogViewServiceFutureStub(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } - @java.lang.Override - @java.lang.SuppressWarnings("unchecked") - public io.grpc.stub.StreamObserver invoke( - io.grpc.stub.StreamObserver responseObserver) { - switch (methodId) { - default: - throw new AssertionError(); - } - } - } + @java.lang.Override + protected LogViewServiceFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions) { + return new LogViewServiceFutureStub(channel, callOptions); + } - private static abstract class LogViewServiceBaseDescriptorSupplier - implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { - LogViewServiceBaseDescriptorSupplier() {} + /** + * 
+         **
+         *  roll view log
+         *
+ */ + public com.google.common.util.concurrent.ListenableFuture rollViewLog( + org.apache.dolphinscheduler.rpc.LogParameter request) { + return futureUnaryCall( + getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request); + } + + /** + * 
+         **
+         * view all log
+         *
+ */ + public com.google.common.util.concurrent.ListenableFuture viewLog( + org.apache.dolphinscheduler.rpc.PathParameter request) { + return futureUnaryCall( + getChannel().newCall(getViewLogMethod(), getCallOptions()), request); + } - @java.lang.Override - public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { - return org.apache.dolphinscheduler.rpc.SchdulerProto.getDescriptor(); + /** + * 
+         **
+         * get log bytes
+         *
+ */ + public com.google.common.util.concurrent.ListenableFuture getLogBytes( + org.apache.dolphinscheduler.rpc.PathParameter request) { + return futureUnaryCall( + getChannel().newCall(getGetLogBytesMethod(), getCallOptions()), request); + } } - @java.lang.Override - public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { - return getFileDescriptor().findServiceByName("LogViewService"); + private static final int METHODID_ROLL_VIEW_LOG = 0; + private static final int METHODID_VIEW_LOG = 1; + private static final int METHODID_GET_LOG_BYTES = 2; + + private static final class MethodHandlers implements + io.grpc.stub.ServerCalls.UnaryMethod, + io.grpc.stub.ServerCalls.ServerStreamingMethod, + io.grpc.stub.ServerCalls.ClientStreamingMethod, + io.grpc.stub.ServerCalls.BidiStreamingMethod { + private final LogViewServiceImplBase serviceImpl; + private final int methodId; + + MethodHandlers(LogViewServiceImplBase serviceImpl, int methodId) { + this.serviceImpl = serviceImpl; + this.methodId = methodId; + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { + switch (methodId) { + case METHODID_ROLL_VIEW_LOG: + serviceImpl.rollViewLog((org.apache.dolphinscheduler.rpc.LogParameter) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; + case METHODID_VIEW_LOG: + serviceImpl.viewLog((org.apache.dolphinscheduler.rpc.PathParameter) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; + case METHODID_GET_LOG_BYTES: + serviceImpl.getLogBytes((org.apache.dolphinscheduler.rpc.PathParameter) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; + default: + throw new AssertionError(); + } + } + + @java.lang.Override + @java.lang.SuppressWarnings("unchecked") + public io.grpc.stub.StreamObserver invoke( + io.grpc.stub.StreamObserver responseObserver) { + switch (methodId) { + default: + throw new AssertionError(); + } + } } - } - private static final class LogViewServiceFileDescriptorSupplier - extends LogViewServiceBaseDescriptorSupplier { - LogViewServiceFileDescriptorSupplier() {} - } + private static abstract class LogViewServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + LogViewServiceBaseDescriptorSupplier() {} - private static final class LogViewServiceMethodDescriptorSupplier - extends LogViewServiceBaseDescriptorSupplier - implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { - private final String methodName; + @java.lang.Override + public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { + return org.apache.dolphinscheduler.rpc.SchdulerProto.getDescriptor(); + } - LogViewServiceMethodDescriptorSupplier(String methodName) { - this.methodName = methodName; + @java.lang.Override + public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { + return getFileDescriptor().findServiceByName("LogViewService"); + } } - @java.lang.Override - public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { - return getServiceDescriptor().findMethodByName(methodName); + private static final class LogViewServiceFileDescriptorSupplier + extends LogViewServiceBaseDescriptorSupplier { + LogViewServiceFileDescriptorSupplier() {} } - } - private static volatile io.grpc.ServiceDescriptor serviceDescriptor; + private static final class LogViewServiceMethodDescriptorSupplier + extends LogViewServiceBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { + private final String methodName; - public static io.grpc.ServiceDescriptor getServiceDescriptor() { - io.grpc.ServiceDescriptor result = serviceDescriptor; - if (result == null) { - synchronized (LogViewServiceGrpc.class) { - result = serviceDescriptor; + LogViewServiceMethodDescriptorSupplier(String methodName) { + this.methodName = methodName; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { + return getServiceDescriptor().findMethodByName(methodName); + } + } + + private static volatile io.grpc.ServiceDescriptor serviceDescriptor; + + public static io.grpc.ServiceDescriptor getServiceDescriptor() { + io.grpc.ServiceDescriptor result = serviceDescriptor; if (result == null) { - serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new LogViewServiceFileDescriptorSupplier()) - .addMethod(getRollViewLogMethod()) - .addMethod(getViewLogMethod()) - .addMethod(getGetLogBytesMethod()) - .build(); - } - } + synchronized (LogViewServiceGrpc.class) { + result = serviceDescriptor; + if (result == null) { + serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) + .setSchemaDescriptor(new LogViewServiceFileDescriptorSupplier()) + .addMethod(getRollViewLogMethod()) + .addMethod(getViewLogMethod()) + .addMethod(getGetLogBytesMethod()) + .build(); + } + } + } + return result; } - return result; - } }