[
https://issues.apache.org/jira/browse/IGNITE-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611467#comment-16611467
]
Saikat Maitra edited comment on IGNITE-3303 at 9/12/18 2:18 AM:
----------------------------------------------------------------
[~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 true 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. I have also
added assert f.error() == null to check if any error was encountered during the
test execution in igniteSrc.run() process. This will validate for any exception
during the streaming data process 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
was (Author: samaitra):
[~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 true 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. I have also
added assert f.error() == null to check if any error was encountered during the
test execution in igniteSec.run() process. This will validate for any exception
during the streaming data process 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)
