You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@ignite.apache.org by GitBox <gi...@apache.org> on 2020/03/12 06:33:11 UTC
[GitHub] [ignite-extensions] alien11689 opened a new pull request #9: Fix
ignite sink startup
alien11689 opened a new pull request #9: Fix ignite sink startup
URL: https://github.com/apache/ignite-extensions/pull/9
Current implementation of `open` function in Ignite Sink does not work when flink `parallelism` is set to value higher than one.
Flink quickly starts multiple instances of job and checking first if the instance is already started and then starting new instance leads to IgniteException `Default instance is has already been started` and job does not connect to ignite at all. Example test scenario:
0. Flink job with parallelism > 1 (higher is better to reproduce) starts
1. Job instance 1 checks for ignite existence
2. Job instance 2 checks for ignite existence
3. Job instance 1 starts ignite -> success
4. Job instance 2 starts ignite -> exception
5. Flink stops all job instances because of exception on one of its job instances
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [ignite-extensions] asfgit closed pull request #9: Fix ignite sink
startup
Posted by GitBox <gi...@apache.org>.
asfgit closed pull request #9: Fix ignite sink startup
URL: https://github.com/apache/ignite-extensions/pull/9
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [ignite-extensions] samaitra commented on issue #9: Fix ignite sink
startup
Posted by GitBox <gi...@apache.org>.
samaitra commented on issue #9: Fix ignite sink startup
URL: https://github.com/apache/ignite-extensions/pull/9#issuecomment-599130436
alien11689 I have reviewed and merged the changes for following issue.
jira : https://issues.apache.org/jira/browse/IGNITE-12786 Fix ignite sink startup
PR : https://github.com/apache/ignite-extensions/pull/9
Thank you for your help and contribution.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services