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 <[email protected]>
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"
}
- ]
+ } ]
}
```