[
https://issues.apache.org/jira/browse/GOBBLIN-2030?focusedWorklogId=912419&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-912419
]
ASF GitHub Bot logged work on GOBBLIN-2030:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 01/Apr/24 05:12
Start Date: 01/Apr/24 05:12
Worklog Time Spent: 10m
Work Description: phet commented on code in PR #3908:
URL: https://github.com/apache/gobblin/pull/3908#discussion_r1545965267
##########
gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/ProcessWorkUnitImpl.java:
##########
@@ -66,13 +70,36 @@ public class ProcessWorkUnitImpl implements ProcessWorkUnit
{
@Override
public int processWorkUnit(WorkUnitClaimCheck wu) {
+ AutomaticTroubleshooter troubleshooter = null;
+ Optional<EventSubmitter> eventSubmitter =
Optional.ofNullable(wu.getEventSubmitterContext()).map(EventSubmitterContext::create);
try (FileSystem fs = Help.loadFileSystemForce(wu)) {
List<WorkUnit> workUnits = loadFlattenedWorkUnits(wu, fs);
log.info("(M)WU [{}] - loaded; found {} workUnits", wu.getCorrelator(),
workUnits.size());
JobState jobState = Help.loadJobState(wu, fs);
- return execute(workUnits, wu, jobState, fs);
+ log.info("Loaded jobState. Instantiating and starting
troubleshooter...");
+ troubleshooter =
AutomaticTroubleshooterFactory.createForJob(ConfigUtils.propertiesToConfig(jobState.getProperties()));
+ troubleshooter.start();
+ log.info("Finished instantiating troubleshooter. Now executing flow");
Review Comment:
is there really value in `.info` level debugging? won't exception logging
let us know where something went wrong (since line 77's logging)?
Issue Time Tracking
-------------------
Worklog Id: (was: 912419)
Time Spent: 50m (was: 40m)
> Integrate new AutoTroubleshooter with GaaS
> ------------------------------------------
>
> Key: GOBBLIN-2030
> URL: https://issues.apache.org/jira/browse/GOBBLIN-2030
> Project: Apache Gobblin
> Issue Type: Improvement
> Reporter: Matthew Ho
> Priority: Major
> Time Spent: 50m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
