Hi, I have submitted the below PR, please review and share feedback.
Jira: https://issues.apache.org/jira/browse/IGNITE-8697 PR : https://github.com/apache/ignite/pull/4398 Review : https://reviews.ignite.apache.org/ignite/review/IGNT-CR-695 Regards, Saikat On Thu, Jul 26, 2018 at 11:26 PM, Saikat Maitra <saikat.mai...@gmail.com> wrote: > Hi Andrew, > > As we discussed I have updated the PR, please take a look. If it looks > good then I can go ahead and merge the changes. > > PR : https://github.com/apache/ignite/pull/4398 > Review : https://reviews.ignite.apache.org/ignite/review/IGNT-CR-695 > > Regards, > Saikat > > On Thu, Jul 26, 2018 at 11:25 PM, Saikat Maitra <saikat.mai...@gmail.com> > wrote: > >> Hi Ray, >> >> We will need to use igniteSink.setAllowOverwrite(true) flag so that >> latest computed values are stored in cache. Also we need not call >> igniteSink.open(new Configuration) >> >> Please take a look into the below modified wordCount sample. >> >> https://github.com/samaitra/flink-fn/blob/master/flink-fn/sr >> c/main/scala/com/samaitra/WordCount.scala >> >> Please review and share feedback >> >> Regards >> Saikat >> >> On Thu, Jul 26, 2018 at 1:16 AM, Ray <ray...@cisco.com> wrote: >> >>> Hi Saikat, >>> >>> The results flink calculated before sending to sink is correct, but the >>> results in Ignite is not correct. >>> You can remove the sink and print the stream content to validate my >>> point. >>> >>> >>> >>> -- >>> Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/ >>> >> >> >
