[jira] [Assigned] (IGNITE-7355) peerClassLoading doesn't work with DataStreamer Transformer

["Denis Mekhanikov (JIRA)" <ji...@apache.org>]

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

Denis Mekhanikov reassigned IGNITE-7355:
----------------------------------------

    Assignee: Denis Mekhanikov

> peerClassLoading doesn't work with DataStreamer Transformer
> -----------------------------------------------------------
>
>                 Key: IGNITE-7355
>                 URL: https://issues.apache.org/jira/browse/IGNITE-7355
>             Project: Ignite
>          Issue Type: Bug
>    Affects Versions: 2.3
>            Reporter: Evgenii Zhuravlev
>            Assignee: Denis Mekhanikov
>
> Example:
> {code:java}
>  try (IgniteDataStreamer<String, Object> streamer = ignite.dataStreamer(CacheName.CACHE)) {
>             streamer.receiver(StreamTransformer.from(new MyCacheEntryProcessor()));
>             streamer.addData("key", "value");
>         }
> private static class MyCacheEntryProcessor implements CacheEntryProcessor<String, Object, Object> {
>         @Override
>         public Object process(MutableEntry<String, Object> mutableEntry, Object... objects) throws EntryProcessorException {
>             return null;
>         }
>     }
> {code}
> workaround: use streamer.deployClass(MyCacheEntryProcessor.class);



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)