[ 
https://issues.apache.org/jira/browse/GOBBLIN-1656?focusedWorklogId=778324&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-778324
 ]

ASF GitHub Bot logged work on GOBBLIN-1656:
-------------------------------------------

                Author: ASF GitHub Bot
            Created on: 03/Jun/22 21:24
            Start Date: 03/Jun/22 21:24
    Worklog Time Spent: 10m 
      Work Description: ZihanLi58 commented on code in PR #3516:
URL: https://github.com/apache/gobblin/pull/3516#discussion_r889361416


##########
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java:
##########
@@ -360,16 +361,21 @@ public Map<String, AddSpecResponse> put(Spec spec, 
boolean triggerListener) {
         responseMap.put(entry.getKey().getName(), 
entry.getValue().getResult());
       }
     }
+    AddSpecResponse<String> schedulerResponse = 
responseMap.getOrDefault(ServiceConfigKeys.GOBBLIN_SERVICE_JOB_SCHEDULER_LISTENER_CLASS,
 new AddSpecResponse<>(null));
 
-    if (isCompileSuccessful(responseMap)) {
+    if (isCompileSuccessful(schedulerResponse.getValue())) {

Review Comment:
   Can we add comments to explain this? Just to make the code more easy to read





Issue Time Tracking
-------------------

    Worklog Id:     (was: 778324)
    Time Spent: 2.5h  (was: 2h 20m)

> Return different Http Status on GaaS if Quota is Exceeded
> ---------------------------------------------------------
>
>                 Key: GOBBLIN-1656
>                 URL: https://issues.apache.org/jira/browse/GOBBLIN-1656
>             Project: Apache Gobblin
>          Issue Type: New Feature
>          Components: gobblin-service
>            Reporter: William Lo
>            Assignee: Abhishek Tiwari
>            Priority: Major
>          Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> GaaS has quota limits for proxy users and flowGroups.
> When a user wants to create a flow that exceeds their specified quota, the 
> flow should
> 1) Not be run
> 2) Return a http status code (i.e. 503) due to exceeding the resource. This 
> allows clients to implement some wait and retry functionality



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to