[
https://issues.apache.org/jira/browse/GOBBLIN-1754?focusedWorklogId=833232&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-833232
]
ASF GitHub Bot logged work on GOBBLIN-1754:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 14/Dec/22 01:30
Start Date: 14/Dec/22 01:30
Worklog Time Spent: 10m
Work Description: ZihanLi58 commented on code in PR #3615:
URL: https://github.com/apache/gobblin/pull/3615#discussion_r1047913439
##########
gobblin-service/src/main/java/org/apache/gobblin/service/modules/restli/GobblinServiceFlowExecutionResourceHandlerWithWarmStandby.java:
##########
@@ -53,8 +53,15 @@ public void
resume(ComplexResourceKey<org.apache.gobblin.service.FlowStatusId, E
String flowName = key.getKey().getFlowName();
Long flowExecutionId = key.getKey().getFlowExecutionId();
try {
+ // If an existing resume or kill request is still pending then do not
accept this request
+ if (this.dagActionStore.exists(flowGroup, flowName,
flowExecutionId.toString())) {
+ this.handleException(flowGroup, flowName, flowExecutionId.toString(),
Review Comment:
Should we print out the existing action?
Issue Time Tracking
-------------------
Worklog Id: (was: 833232)
Time Spent: 20m (was: 10m)
> Fixes for mysql-related change monitors
> ----------------------------------------
>
> Key: GOBBLIN-1754
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1754
> Project: Apache Gobblin
> Issue Type: Bug
> Reporter: Urmi Mustafi
> Priority: Major
> Time Spent: 20m
> Remaining Estimate: 0h
>
> Includes small fixes and logging added to change monitors, their
> initialization, and any related parts of code that the API and execution
> layer interact with.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
