You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gobblin.apache.org by GitBox <gi...@apache.org> on 2020/09/11 22:32:01 UTC

[GitHub] [incubator-gobblin] sv2000 commented on a change in pull request #3076: [GOBBLIN-1230] add option to add spec executor configs to gaas job

sv2000 commented on a change in pull request #3076:
URL: https://github.com/apache/incubator-gobblin/pull/3076#discussion_r487317913



##########
File path: gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java
##########
@@ -17,10 +17,11 @@
 
 package org.apache.gobblin.service.monitoring;
 
-import org.apache.gobblin.annotation.Alpha;
-
 import lombok.Builder;
 import lombok.Getter;
+import lombok.Setter;
+
+import org.apache.gobblin.annotation.Alpha;

Review comment:
       We can remove this annotation.

##########
File path: gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlan.java
##########
@@ -82,7 +87,8 @@ public JobExecutionPlan createPlan(FlowSpec flowSpec, Config jobConfig, SpecExec
      * @param flowSpec input FlowSpec.
      * @return a {@link JobSpec} corresponding to the resolved job config.
      */
-    private static JobSpec buildJobSpec(FlowSpec flowSpec, Config jobConfig, Long flowExecutionId, Config sysConfig) throws URISyntaxException {
+    private static JobSpec buildJobSpec(FlowSpec flowSpec, Config jobConfig, Long flowExecutionId, Config sysConfig, Config specExecutorConfig)

Review comment:
       Modify the javadoc to reflect the current list of arguments.

##########
File path: gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlan.java
##########
@@ -154,7 +160,7 @@ private static JobSpec buildJobSpec(FlowSpec flowSpec, Config jobConfig, Long fl
      * execution status of the job.
      * @param jobSpec representing a fully resolved {@link JobSpec}.
      */
-    private static void addAdditionalConfig(JobSpec jobSpec, Config sysConfig) {
+    private static void addAdditionalConfig(JobSpec jobSpec, Config sysConfig, Config specExecutorConfig) {

Review comment:
       Modify the javadoc.




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org