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,
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
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.
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/
ion there.
>
> Andrey, Dmitry, please help with the review.
>
> Thanks,
> Stan
>
> From: Saikat Maitra
> Sent: 22 июля 2018 г. 8:28
> To: u...@ignite.apache.org; ray...@cisco.com
> Subject: Re: Apache Flink Sink + Ignite: Ouch! Argument is invalid
>
> Hi Ray, Andrew
>
. 8:28
To: u...@ignite.apache.org; ray...@cisco.com
Subject: Re: Apache Flink Sink + Ignite: Ouch! Argument is invalid
Hi Ray, Andrew
As discussed I have fixed the issue with IgniteSink when running in cluster
mode.
Please review the below PR and share feedback.
PR : https://github.com/apache
