This is an automated email from the ASF dual-hosted git repository. jerrypeng pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push: new 7dd5616 Updated Release Candidate Validation (markdown) 7dd5616 is described below commit 7dd5616487ef4af5cdbbecd0135d5c295458c640 Author: Boyang Jerry Peng <jerry.boyang.p...@gmail.com> AuthorDate: Tue Apr 9 11:31:20 2019 -0700 Updated Release Candidate Validation (markdown) --- Release-Candidate-Validation.md | 62 +++++++++++++++++++++++------------------ 1 file changed, 35 insertions(+), 27 deletions(-) diff --git a/Release-Candidate-Validation.md b/Release-Candidate-Validation.md index 6cf5521..c92d6c4 100644 --- a/Release-Candidate-Validation.md +++ b/Release-Candidate-Validation.md @@ -447,43 +447,51 @@ $ bin/pulsar-admin functions get --tenant test --namespace test-namespace --name "namespace": "test-namespace", "name": "word_count", "className": "org.apache.pulsar.functions.api.examples.WordCountFunction", - "userConfig": "{\"PublishTopic\":\"test_result\"}", + "inputSpecs": { + "test_wordcount_src": { + "isRegexPattern": false + } + }, + "output": "test_wordcount_dest", + "processingGuarantees": "ATLEAST_ONCE", + "retainOrdering": false, + "userConfig": { + "PublishTopic": "test_result" + }, + "runtime": "JAVA", "autoAck": true, "parallelism": 1, - "source": { - "topicsToSerDeClassName": { - "test_wordcount_src": "" - }, - "typeClassName": "java.lang.String" - }, - "sink": { - "topic": "test_wordcount_dest", - "typeClassName": "java.lang.Void" + "resources": { + "cpu": 1.0, + "ram": 1073741824, + "disk": 10737418240 }, - "resources": {} + "cleanupSubscription": true } ``` ```shell $ bin/pulsar-admin functions getstatus --tenant test --namespace test-namespace --name word_count { - "functionStatusList": [ - { - "running": true, - "instanceId": "0", - "metrics": { - "metrics": { - "__total_processed__": {}, - "__total_successfully_processed__": {}, - "__total_system_exceptions__": {}, - "__total_user_exceptions__": {}, - "__total_serialization_exceptions__": {}, - "__avg_latency_ms__": {} - } - }, - "workerId": "c-standalone-fw-localhost-6750" + "numInstances" : 1, + "numRunning" : 1, + "instances" : [ { + "instanceId" : 0, + "status" : { + "running" : true, + "error" : "", + "numRestarts" : 0, + "numReceived" : 0, + "numSuccessfullyProcessed" : 0, + "numUserExceptions" : 0, + "latestUserExceptions" : [ ], + "numSystemExceptions" : 0, + "latestSystemExceptions" : [ ], + "averageLatency" : 0.0, + "lastInvocationTime" : 0, + "workerId" : "c-standalone-fw-localhost-8080" } - ] + } ] } ```