Hello, I am working on building Apache Ignite connector for Apache flink. I am currently developing the SourceFunction to consume Cache event from Ignite cluster.
Here is the PR https://github.com/apache/ignite/pull/870/files I am observing that during unit tests the IgniteSource instances are different which is created using the IgniteSource constructor and inside run() method. As a result when igniteSrc.cancel() is called the igniteSrc instance is not getting stopped. I wanted to discuss: 1. If Flink create a copy of IgniteSource object when env.addSource(igniteSrc) is called? A quick work around the problem is to use static boolean stopped variable which allows single IgniteSource instance but this limits using multiple IgniteSource with different cache combination. Regards Saikat
