Re: Information regarding RichParallelSourceFunction

2016-12-25 Thread Saikat Maitra
uted across different JVMs. > > So even a static field won't help here. > > > > Best, Fabian > > > > 2016-12-22 9:12 GMT+01:00 Saikat Maitra : > > > > > Hello, > > > > > > I am working on building Apache Ignite connector for Apac

Information regarding RichParallelSourceFunction

2016-12-22 Thread Saikat Maitra
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 d

Re: Apache Flink <=> Apache Ignite integration

2016-07-16 Thread Saikat Maitra
nector would be more suitable for our "connector library" feel free to > > open a JIRA and open a pull request. > > > > Were there requests in the Ignite community to have an integration with > > Flink? > > > > > > > > On Thu, Mar 31, 2016 at

Re: Problem with flink while development

2016-04-18 Thread Saikat Maitra
Hello Jitendra, I am new to Flink community but may have seen this issue earlier. Can you try to use DataStream> instead of KeyedStream integers4 Regards Saikat On Mon, Apr 18, 2016 at 7:37 PM, Jitendra Agrawal < jitendra.agra...@northgateps.com> wrote: > Hi Team, > > Problem Description : Wh

Re: Apache Flink <=> Apache Ignite integration

2016-03-31 Thread Saikat Maitra
Hi , I agree with Roman and Raul. https://issues.apache.org/jira/browse/IGNITE-813 allows injecting data to into cache via Data Streamer. Integrating with Ignite FileSystem for source and sink will allow for bidirectional connector. It will also allow easier implementation for DataStream transform