ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saikat Maitra <saikat.mai...@gmail.com>
Subject IGNITE-3303 - Apache Flink Integration - Flink source to run a continuous query against one or multiple caches
Date Sun, 24 Jun 2018 01:30:31 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message