Saikat Maitra created IGNITE-12786:
--------------------------------------
Summary: Fix ignite sink startup
Key: IGNITE-12786
URL: https://issues.apache.org/jira/browse/IGNITE-12786
Project: Ignite
Issue Type: Bug
Components: streaming
Reporter: Saikat Maitra
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:
# Flink job with parallelism > 1 (higher is better to reproduce) starts
# Job instance 1 checks for ignite existence
# Job instance 2 checks for ignite existence
# Job instance 1 starts ignite -> success
# Job instance 2 starts ignite -> exception
# Flink stops all job instances because of exception on one of its job
instances
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
