[
https://issues.apache.org/jira/browse/IGNITE-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611467#comment-16611467
]
Saikat Maitra commented on IGNITE-3303:
---------------------------------------
[~amashenkov]
I have incorporated the review comments.
Also, I wanted to share that IgniteSrc is a continuous process and continue to
run unless stopped is set to false or our desired test execution time is
complete. I have added a fail () statement in the catch block to check if
during igniteSrc.run any exception is encountered within 3 secs. This will
validate for any exception in the streaming data from source. If we use f.get()
then the source will be continuously running and we will be waiting for result
event synchronously.
Please review and let me know if any changes required.
Regards
Saikat
> Apache Flink Integration - Flink source to run a continuous query against one
> or multiple caches
> ------------------------------------------------------------------------------------------------
>
> Key: IGNITE-3303
> URL: https://issues.apache.org/jira/browse/IGNITE-3303
> Project: Ignite
> Issue Type: New Feature
> Components: streaming
> Reporter: Saikat Maitra
> Assignee: Saikat Maitra
> Priority: Major
> Attachments: Screen Shot 2016-10-07 at 12.44.47 AM.png,
> testFlinkIgniteSourceWithLargeBatch.log, win7.PNG
>
>
> Apache Flink integration
> +++ *Ignite as a bidirectional Connector* +++
> As a Flink source => run a continuous query against one or multiple
> caches [4].
> Related discussion :
> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-lt-gt-Apache-Ignite-integration-td8163.html
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
