Skip to content
Permalink
Browse files

0004046: Potential bottleneck from flushing cache while processing

extract requests
  • Loading branch information
erilong committed Jul 17, 2019
1 parent f38acab commit 5474504298caeadd6a2e31886a6e8875874bbeda
@@ -1998,7 +1998,7 @@ protected void updateExtractRequestStatus(ISqlTransaction transaction, long extr
}

protected boolean canProcessExtractRequest(ExtractRequest request, CommunicationType communicationType) {
Trigger trigger = this.triggerRouterService.getTriggerById(request.getTriggerId());
Trigger trigger = this.triggerRouterService.getTriggerById(request.getTriggerId(), false);
if (trigger == null || !trigger.getSourceTableName().equalsIgnoreCase(TableConstants.getTableName(tablePrefix,
TableConstants.SYM_FILE_SNAPSHOT))) {
return true;
@@ -2025,6 +2025,9 @@ public void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status
allChildRequests = getExtractChildRequestsForNode(nodeCommunication, requests);
}

// refresh trigger cache
triggerRouterService.getTriggerById(null, true);

/*
* Process extract requests until it has taken longer than 30 seconds, and then
* allow the process to return so progress status can be seen.

0 comments on commit 5474504

Please sign in to comment.
You can’t perform that action at this time.