• S
    Enable Pulsar Functions to be deployed on a kubernetes cluster (#1950) · d0858065
    Sanjeev Kulkarni 提交于
    * Support submitting pulsar functions to kubernetes
    
    * Adjusted pom
    
    * Added helper function
    
    * Added port to instance config
    
    * Made things public
    
    * More fixes
    
    * Made changes to kubernetes controller
    
    * refactored jobname
    
    * Removed resource
    
    * Bumped to 2.1.0
    
    * Fix compilation bug
    
    * Fix compile bugs
    
    * Fixed compile
    
    * Compile fix
    
    * Some remant
    
    * Unnecessary imports
    
    * Added dep
    
    * Default values
    
    * Fix
    
    * Use kubectl proxy stuff
    
    * Corrected the path of pulsar-amin
    
    * Fixed bugs
    
    * No longer required
    
    * Download first
    
    * make shard id work
    
    * Removed using runtime
    
    * Fixed npe
    
    * Corrected command name
    
    * Fixed bugs
    
    * Removed commented sections
    
    * Uncommented some stuff
    
    * Address Jerry's comments
    
    * Change to 2.2
    
    * Use non camel case style for passing arguments
    
    * removed cmdline changes
    
    * Second set of changes
    
    * Next set of canges
    
    * no such module
    
    * Code complete
    
    * Fixed logic wrt packages
    
    * Do not stop externally managed functions upon exit
    
    * Modified to use AppV1 instead of beta
    
    * use lower case
    
    * Unpretty the function details
    
    * If the job exists, don't flag as error
    
    * Give ability to submit from inside a pod
    
    * remove encode/decode
    
    * Escape function details
    
    * Working copy with getstatus and stop. Restart needs some work
    
    * removed unused function
    
    * Fixed bugs
    
    * Fixed unittest
    
    * Fixed unittest
    
    * Fixed unittest
    
    * Fixed tests
    
    * Reverted conf changes
    
    * Minor nit
    
    * Exlcude logback
    
    * Updated comments
    
    * Changed jobname to include namespace/tenant
    
    * Fix unittest
    
    * Updated licenses
    
    * Use 2.0.0 instead of beta1
    d0858065
FunctionActioner.java 15.9 KB