Re: [DISCUSS] Pub/Sub Streamer Implementation

2019-11-10 Thread Saikat Maitra
Hi Emmanouil, Can you please take a looks at dev utils, if this is something you are looking for https://github.com/apache/ignite/tree/master/modules/dev-utils? IMO, if you can release Pub/Sub server in maven and then use it as dependency, that would be great. Regards, Saikat On Sun, Nov 10,

Re: [DISCUSS] Pub/Sub Streamer Implementation

2019-11-10 Thread Saikat Maitra
Hi Emmanouil, The master branch has been initialized. I have raised a PR to migrate Flink module to ignite-extensions. PR https://github.com/apache/ignite-extensions/pull/1 Jira : https://issues.apache.org/jira/browse/IGNITE-12356 Regards, Saikat On Sun, Nov 10, 2019 at 3:39 PM Emmanouil

IGNITE-12356 Migrate Flink module to ignite-extensions

2019-11-10 Thread Saikat Maitra
Hi I have raised a PR to migrate Flink module to ignite-extensions. PR https://github.com/apache/ignite-extensions/pull/1 Jira : https://issues.apache.org/jira/browse/IGNITE-12356 Please review and share feedback. I am observing error with initialization of GridAbstractTest as

Re: [DISCUSS] Pub/Sub Streamer Implementation

2019-11-10 Thread Emmanouil Gkatziouras
Hi all! This is an update. The integration is tested with mocks based on the original Ignite repo [1]. I am currently waiting for the first commits on the new integration project to take place in order to create my pull request accordingly to the initial commits. In order to simulate the Pub/Sub