[
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)
