[
https://issues.apache.org/jira/browse/FALCON-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14119465#comment-14119465
]
Shwetha G S commented on FALCON-644:
------------------------------------
{quote}
How do I do that with a topic subscriber
{quote}
Earlier, for late handling, when we receive message, we used to add to delay
queue depending on late handling policy. Can't we use the same here?
metrics.log has lots of data and is not monitored, a separate file alert.log
with alerts like this will serve the purpose. Generic alert does nothing
currently, it can write to alert.log?
{code}
@Monitored(event = "retry-instance-failed")
public static String alertRetryFailed(
@Dimension(value = "entity-type") String entityType,
@Dimension(value = "entity-name") String entityName,
@Dimension(value = "nominal-name") String nominalTime,
@Dimension(value = "wf-id") String wfId,
@Dimension(value = "wf-user") String workflowUser,
@Dimension(value = "run-id") String runId,
@Dimension(value = "error-message") String message) {
return "IGNORE";
}
{code}
> Falcon message producer masks errors in Post processing
> -------------------------------------------------------
>
> Key: FALCON-644
> URL: https://issues.apache.org/jira/browse/FALCON-644
> Project: Falcon
> Issue Type: Bug
> Components: messaging
> Affects Versions: 0.6
> Reporter: Sowmya Ramesh
> Assignee: Venkatesh Seetharam
> Priority: Blocker
> Fix For: 0.6
>
> Attachments: FALCON-644-v1.patch, FALCON-644.patch
>
>
> In JMSMessageProducer all the exceptions are caught and success is returned
> [return 0] by default. Oozie will indicate that this WF action was successful
> as Falcon Messaging returns success.
> WF shouldn't be failed if post-processing fails but instead of masking errors
> this can be controlled in the WF decision on failure.
> {noformat}
> <action name='succeeded-post-processing'>
> ...
> <ok to="end"/>
> <!-- Shouldn't fail the WF if post processing fails -->
> <error to="end"/>
> </action>
> {noformat}
> Thoughts?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
