[GitHub] [pulsar] jerrypeng edited a comment on issue #3854: [issue #3767] support go function for pulsar

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

jerrypeng edited a comment on issue #3854: [issue #3767] support go function for pulsar
URL: https://github.com/apache/pulsar/pull/3854#issuecomment-474082073
 
 
    I have question:
   
   How are you planning to spawn a function instance from the function worker? For example, for java we spawn another process with CLI arguments:
   
   ```
   java -cp /Users/jerrypeng/workspace/incubator-pulsar/pulsar-functions/runtime-all/target/java-instance.jar:/Users/jerrypeng/workspace/incubator-pulsar/instances/deps/* -Dpulsar.functions.java.instance.jar=/Users/jerrypeng/workspace/incubator-pulsar/pulsar-functions/runtime-all/target/java-instance.jar -Dpulsar.functions.extra.dependencies.dir=/Users/jerrypeng/workspace/incubator-pulsar/instances/deps -Dlog4j.configurationFile=java_instance_log4j2.yml -Dpulsar.function.log.dir=/Users/jerrypeng/workspace/incubator-pulsar/logs/functions/public/default/java-jerry-test -Dpulsar.function.log.file=java-jerry-test-1 -Xmx1073741824 org.apache.pulsar.functions.runtime.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/java-jerry-test/1/pulsar-functions-api-examples.jar --instance_id 1 --function_id ed07d96a-ea90-4212-b9bb-440ac825f26d --function_version 1dc83fa9-5a72-4640-8b57-491bee7860e4 --function_details '{"tenant":"public","namespace":"default","name":"java-jerry-test","className":"org.apache.pulsar.functions.api.examples.ExclamationFunction","autoAck":true,"parallelism":3,"source":{"typeClassName":"java.lang.String","timeoutMs":"60000","inputSpecs":{"persistent://public/default/java-input":{"schemaType":"NONE","receiverQueueSize":{"value":100}}},"cleanupSubscription":true},"sink":{"topic":"persistent://public/default/java-output","typeClassName":"java.lang.String"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"}}' --pulsar_serviceurl pulsar://127.0.0.1:6650 --use_tls false --tls_allow_insecure false --hostname_verification_enabled false --max_buffered_tuples 1024 --port 53904 --metrics_port 53905 --state_storage_serviceurl bk://127.0.0.1:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name standalone
   ```
   
   Can you provide a example of what the arguments for running a GO function instance?
   
   I don't see code in this PR for a function runtime that support running GO functions.

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


With regards,
Apache Git Services