Re: Memory leak in ignite-cassandra module

Hi, That's actually a bug in Cassandra's *RoundRobinPolicy* implementation. When ever *init(Cluster cluster, Collection hosts) *is called on *RoundRobinPolicy* it should reset object state to some initial state. While in current implementation it accumulates old state with new state. The problem

IGNITE-3303 - Apache Flink Integration - Flink source to run a continuous query against one or multiple caches

Hi, I have updated the PR for IGNITE-3303. I have observed that we will not be able to stop streaming job without static field as explained below https://stackoverflow.com/questions/1153/how-to-stop-a-flink-streaming-job-from-program I have updated the test similar to flink Nifi source

Re: Review request for IGNITE-8740: Support reuse of already initialized Ignite in IgniteSpringBean

Dmitry, Thanks for pointing this out. Fixed in master and 2.6. -Val On Sat, Jun 23, 2018 at 10:49 AM Dmitriy Govorukhin < dmitriy.govoruk...@gmail.com> wrote: > Valentin, > > Seems that these changes have classes without license head. TC link >

Re: Review request for IGNITE-8740: Support reuse of already initialized Ignite in IgniteSpringBean

Valentin, Seems that these changes have classes without license head. TC link