[jira] [Created] (IGNITE-12786) Fix ignite sink startup

[Anton Vinogradov (Jira)]

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)