You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In the slicer and worker the calls to job_runner.initialize() can occur twice which has the side effect of calling newReader() twice on the loader operations. This can cause problems if the reader does initialization in that function and the Kafka reader can end up creating two client instances in the same worker process. This needs to be refactored to guarantee that job_runner.initialize() is called once and only once.
The text was updated successfully, but these errors were encountered:
In the slicer and worker the calls to
job_runner.initialize()
can occur twice which has the side effect of calling newReader() twice on the loader operations. This can cause problems if the reader does initialization in that function and the Kafka reader can end up creating two client instances in the same worker process. This needs to be refactored to guarantee thatjob_runner.initialize()
is called once and only once.The text was updated successfully, but these errors were encountered: