[jira] [Created] (IGNITE-7355) peerClassLoadin doesn't work with DataStreamer Transformer

[Anton Vinogradov (Jira)]

Evgenii Zhuravlev created IGNITE-7355:
-----------------------------------------

             Summary: peerClassLoadin 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


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)