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

[Saikat Maitra]

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/44441153/how-to-stop-a-flink-streaming-job-from-program

I have updated the test similar to flink Nifi source tests

https://github.com/apache/flink/blob/4f50dc4df14d00203a03873edaf4252082ef4d38/flink-connectors/flink-connector-nifi/src/test/java/org/apache/flink/streaming/connectors/nifi/examples/NiFiSourceTopologyExample.java

Please review and share feedback.

https://github.com/apache/ignite/pull/870

Regards,

Saikat

[Dmitriy Pavlov]

Hi Saikat,

Could you please set status of
https://issues.apache.org/jira/browse/IGNITE-3303 to Patch Available, so
community members can see this issue in their filters?

Sincerely,
Dmitriy Pavlov

вс, 24 июн. 2018 г. в 4:30, Saikat Maitra <[hidden email]>:

> 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/44441153/how-to-stop-a-flink-streaming-job-from-program
>
> I have updated the test similar to flink Nifi source tests
>
>
> https://github.com/apache/flink/blob/4f50dc4df14d00203a03873edaf4252082ef4d38/flink-connectors/flink-connector-nifi/src/test/java/org/apache/flink/streaming/connectors/nifi/examples/NiFiSourceTopologyExample.java
>
> Please review and share feedback.
>
> https://github.com/apache/ignite/pull/870
>
> Regards,
>
> Saikat
>

[Saikat Maitra]

Hi Dmitriy,

Thank you, I have updated status to Patch Available.

Regards,
Saikat

On Mon, Jun 25, 2018 at 4:58 AM, Dmitry Pavlov <[hidden email]>
wrote:

> Hi Saikat,
>
> Could you please set status of
> https://issues.apache.org/jira/browse/IGNITE-3303 to Patch Available, so
> community members can see this issue in their filters?
>
> Sincerely,
> Dmitriy Pavlov
>
> вс, 24 июн. 2018 г. в 4:30, Saikat Maitra <[hidden email]>:
>
> > 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/44441153/how-to-
> stop-a-flink-streaming-job-from-program
> >
> > I have updated the test similar to flink Nifi source tests
> >
> >
> > https://github.com/apache/flink/blob/4f50dc4df14d00203a03873edaf425
> 2082ef4d38/flink-connectors/flink-connector-nifi/src/test/
> java/org/apache/flink/streaming/connectors/nifi/examples/
> NiFiSourceTopologyExample.java
> >
> > Please review and share feedback.
> >
> > https://github.com/apache/ignite/pull/870
> >
> > Regards,
> >
> > Saikat
> >
>