ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Saikat Maitra (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (IGNITE-3303) Apache Flink Integration - Flink source to run a continuous query against one or multiple caches
Date Wed, 12 Sep 2018 02:19:00 GMT

    [ 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)

Mime
View raw message