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 d02b424 Updated Release Candidate Validation (markdown)
d02b424 is described below
commit d02b424da749c948c56357bf2c24c9810152e767
Author: Boyang Jerry Peng <[email protected]>
AuthorDate: Tue Apr 9 11:12:09 2019 -0700
Updated Release Candidate Validation (markdown)
---
Release-Candidate-Validation.md | 81 ++++++++++++++++++-----------------------
1 file changed, 36 insertions(+), 45 deletions(-)
diff --git a/Release-Candidate-Validation.md b/Release-Candidate-Validation.md
index 348a5c6..6cf5521 100644
--- a/Release-Candidate-Validation.md
+++ b/Release-Candidate-Validation.md
@@ -338,25 +338,26 @@ $ bin/pulsar-admin sink get --tenant public --namespace
default --name cassandra
```shell
// get the running status
-$ bin/pulsar-admin functions getstatus --tenant public --namespace default
--name cassandra-test-sink
+$ bin/pulsar-admin sink getstatus --tenant public --namespace default --name
cassandra-test-sink
{
- "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,
+ "numReadFromPulsar" : 0,
+ "numSystemExceptions" : 0,
+ "latestSystemExceptions" : [ ],
+ "numSinkExceptions" : 0,
+ "latestSinkExceptions" : [ ],
+ "numWrittenToSink" : 0,
+ "lastReceivedTime" : 0,
+ "workerId" : "c-standalone-fw-localhost-8080"
}
- ]
+ } ]
}
```
@@ -368,36 +369,26 @@ $ for i in {0..10}; do bin/pulsar-client produce -m
"key-$i" -n 1 test_cassandra
6. Check the sink status. It should show 11 messages are processed.
```shell
-$ bin/pulsar-admin functions getstatus --tenant public --namespace default
--name cassandra-test-sink
+$ bin/pulsar-admin sink getstatus --tenant public --namespace default --name
cassandra-test-sink
{
- "functionStatusList": [
- {
- "running": true,
- "numProcessed": "11",
- "numSuccessfullyProcessed": "11",
- "lastInvocationTime": "1532031040117",
- "instanceId": "0",
- "metrics": {
- "metrics": {
- "__total_processed__": {
- "count": 5.0,
- "sum": 5.0,
- "max": 5.0
- },
- "__total_successfully_processed__": {
- "count": 5.0,
- "sum": 5.0,
- "max": 5.0
- },
- "__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,
+ "numReadFromPulsar" : 11,
+ "numSystemExceptions" : 0,
+ "latestSystemExceptions" : [ ],
+ "numSinkExceptions" : 0,
+ "latestSinkExceptions" : [ ],
+ "numWrittenToSink" : 11,
+ "lastReceivedTime" : 1554833501277,
+ "workerId" : "c-standalone-fw-localhost-8080"
}
- ]
+ } ]
}
```
