[
https://issues.apache.org/jira/browse/GOBBLIN-1697?focusedWorklogId=810208&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-810208
]
ASF GitHub Bot logged work on GOBBLIN-1697:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 20/Sep/22 00:22
Start Date: 20/Sep/22 00:22
Worklog Time Spent: 10m
Work Description: arjun4084346 commented on code in PR #3549:
URL: https://github.com/apache/gobblin/pull/3549#discussion_r974784033
##########
gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigResourceLocalHandler.java:
##########
@@ -161,10 +161,14 @@ public CreateResponse createFlowConfig(FlowConfig
flowConfig) throws FlowConfigL
return this.createFlowConfig(flowConfig, true);
}
+ public UpdateResponse updateFlowConfig(FlowId flowId, FlowConfig flowConfig,
boolean triggerListener) {
+ // Set the max version to be the largest value so that we blindly update
the flow spec in this case
+ return updateFlowConfig(flowId, flowConfig, triggerListener,
Long.MAX_VALUE);
+ }
/**
* Update flowConfig locally and trigger all listeners iff @param
triggerListener is set to true
*/
- public UpdateResponse updateFlowConfig(FlowId flowId, FlowConfig flowConfig,
boolean triggerListener) {
+ public UpdateResponse updateFlowConfig(FlowId flowId, FlowConfig flowConfig,
boolean triggerListener, long modifiedWatermark) {
Review Comment:
Is version and watermark are the same thing?
Issue Time Tracking
-------------------
Worklog Id: (was: 810208)
Time Spent: 1h 40m (was: 1.5h)
> Have a separate resource handler to rely on CDC stream to do message
> forwarding
> -------------------------------------------------------------------------------
>
> Key: GOBBLIN-1697
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1697
> Project: Apache Gobblin
> Issue Type: Improvement
> Reporter: Zihan Li
> Priority: Major
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
