Hello Ray, I have fixed the issue related to Flink IgniteSink. Please take a look on the changes [https://github.com/samaitra/ignite/blob/IGNITE-8697/ modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java]
I am working on the testcases and will raise the PR soon. Regards Saikat On Tue, Jun 5, 2018 at 1:13 AM, Ray <[email protected]> wrote: > Yes, the cache is already created before running my flink application. > > The issue can be reproduced when you submit your flink application to your > flink cluster. > > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
