[GitHub] [pulsar] jerrypeng opened a new pull request #7338: Various fixes and optimizations for processing assignments in function worker

[GitBox <gi...@apache.org>]

jerrypeng opened a new pull request #7338:
URL: https://github.com/apache/pulsar/pull/7338


   
   Fixes and optimizations:
   
   1. FunctionRuntimeManager initialize() should return messageId of last read message which is the position the assignment tailer should start reading from
   
   2. Inefficient use of data structures in processAssignment()
   
   3. Wait for leader to finish init routine before allowing scheduler to compute new assignments
   
   4. Start leader service early so that the worker joins the worker membership sooner and its assignments don't get rescheduled because initialize() routines for function runtime manager and metadata manager may take a while
   


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

[GitHub] [pulsar] jerrypeng merged pull request #7338: Various fixes and optimizations for processing assignments in function worker

[GitBox <gi...@apache.org>]

jerrypeng merged pull request #7338:
URL: https://github.com/apache/pulsar/pull/7338


   


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