[GitHub] [pulsar] jerrypeng opened a new pull request #7716: Fix various issues with batch source

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

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


   ### Motivation
   
   1. Move BatchSourceExecutor into pulsar-function-instance module.  The function worker should be should be responsible with how to run a batch source and it shouldn't be a dependency that a user bundles with his or her batch source.  Forcing the user to bundle BatchSourceExecutor can have many unintended consequences like version mismatch between it and what version the function worker is running as.
   
   2. Fix extracting the the type information from the batch source.  This was broken and typeClassName was yet to Unknown.
   
   3.  Improve validation routine of source and batch source to return more sensible error information to allow users to identify problems easier
   
   
   
   


----------------------------------------------------------------
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 #7716: Fix various issues with batch source

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

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


   


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