You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Denis Mekhanikov (Jira)" <ji...@apache.org> on 2020/09/25 15:59:00 UTC

[jira] [Updated] (IGNITE-13487) Decrease logging level for exceptions thrown from compute engine

     [ https://issues.apache.org/jira/browse/IGNITE-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Denis Mekhanikov updated IGNITE-13487:
--------------------------------------
    Summary: Decrease logging level for exceptions thrown from compute engine  (was: Decrease logging level for exceptions throws from compute engine)

> Decrease logging level for exceptions thrown from compute engine
> ----------------------------------------------------------------
>
>                 Key: IGNITE-13487
>                 URL: https://issues.apache.org/jira/browse/IGNITE-13487
>             Project: Ignite
>          Issue Type: Improvement
>            Reporter: Denis Mekhanikov
>            Assignee: Denis Mekhanikov
>            Priority: Major
>
> When a compute job fails during execution, it leads to two error messages printed on different nodes:
> 1. {{Failed to execute job}} on the map node.
>  2. {{Failed to obtain remote job result policy for result from ComputeTask.result(..) method (will fail the whole task)}} on the reduce node.
> Also an exception is thrown from the {{execute()}} method that triggered this task.
> It seems that none of these errors should actually be shown to users. This information should be printed only if debug logging is enabled for the corresponding packages.
> The issue can be reproduced by running the following example:
> {code:java}
> public class ComputeException {
>     public static void main(String[] args) {
>         new ComputeException().run();
>     }
>     void run() {
>         IgniteConfiguration igniteCfg = Ignition.loadSpringBean("config/ignite.xml", "ignite.cfg");
>         igniteCfg.setClientMode(true);
>         try (Ignite ignite = Ignition.start(igniteCfg)) {
>             ignite.compute(ignite.cluster().forServers()).execute(new ErroneousTask(), null);
>         }
>     }
>     public static class ErroneousTask extends ComputeTaskAdapter<Object, Object> {
>         @Override public @NotNull Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> list,
>             @Nullable Object o) throws IgniteException {
>             LinkedHashMap<ErroneousJob, ClusterNode> map = new LinkedHashMap<>();
>             for (ClusterNode node : list)
>                 map.put(new ErroneousJob(), node);
>             return map;
>         }
>         @Override public @Nullable Object reduce(List<ComputeJobResult> list) throws IgniteException {
>             return null;
>         }
>     }
>     public static class ErroneousJob extends ComputeJobAdapter {
>         @Override public Object execute() throws IgniteException {
>             throw new IgniteException("I failed. Sorry :(");
>         }
>     }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)