This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new 07d8336 add sanity checks
07d8336 is described below
commit 07d83363b3ee81fa15fe3b322221aebd5b11fc8e
Author: Sijie Guo <guosi...@gmail.com>
AuthorDate: Thu Jul 19 12:25:02 2018 -0700
add sanity checks
---
Release-Candidate-Validation.md | 73 +++++++++++++++++++++++++++++++++++++++++
1 file changed, 73 insertions(+)
diff --git a/Release-Candidate-Validation.md b/Release-Candidate-Validation.md
index be734db..6a1aa94 100644
--- a/Release-Candidate-Validation.md
+++ b/Release-Candidate-Validation.md
@@ -36,6 +36,79 @@ pulsar-io-twitter-<release>.nar
$ bin/pulsar standalone
```
+when you started the standalone cluster, there are a few things to example:
+
+a) the standalone cluster should be able to locate all the connectors. you
should be able to see following logging information.
+
+```shell
+Found connector ConnectorDefinition(name=kinesis, description=Kinesis sink
connector, sourceClass=null,
sinkClass=org.apache.pulsar.io.kinesis.KinesisSink) from
/Users/sijie/tmp/apache-pulsar-2.1.0-incubating/./connectors/pulsar-io-kinesis-2.1.0-incubating.nar
+...
+Found connector ConnectorDefinition(name=cassandra, description=Writes data
into Cassandra, sourceClass=null,
sinkClass=org.apache.pulsar.io.cassandra.CassandraStringSink) from
/Users/sijie/tmp/apache-pulsar-2.1.0-incubating/./connectors/pulsar-io-cassandra-2.1.0-incubating.nar
+...
+Found connector ConnectorDefinition(name=aerospike, description=Aerospike
database sink, sourceClass=null,
sinkClass=org.apache.pulsar.io.aerospike.AerospikeStringSink) from
/Users/sijie/tmp/apache-pulsar-2.1.0-incubating/./connectors/pulsar-io-aerospike-2.1.0-incubating.nar
+```
+
+b) (since pulsar 2.1) the standalone should start bookkeeper table service as
well.
+
+example output:
+
+```shell
+12:12:26.099 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble
- 'default' namespace for table service : namespace_name: "default"
+default_stream_conf {
+ key_type: HASH
+ min_num_ranges: 24
+ initial_num_ranges: 24
+ split_policy {
+ fixed_range_policy {
+ num_ranges: 2
+ }
+ }
+ rolling_policy {
+ size_policy {
+ max_segment_size: 134217728
+ }
+ }
+ retention_policy {
+ time_policy {
+ retention_minutes: -1
+ }
+ }
+}
+```
+
+c) functions worker is started correctly.
+
+example output:
+
+```shell
+12:12:31.647 [pulsar-external-listener-70-1] INFO
org.apache.pulsar.functions.worker.MembershipManager - Worker
c-standalone-fw-localhost-6750:localhost:6750 became the leader.
+```
+
+b) sanity check before moving to next steps:
+
+```shell
+// check pulsar binary port is listened correctly
+$ telnet localhost 6650
+
+// check function cluster
+$ curl -s http://localhost:8080/admin/v2/functions/cluster
+// example output
+[{"workerId":"c-standalone-fw-localhost-6750","workerHostname":"localhost","port":6750}]
+
+// check brokers
+$ curl -s http://localhost:8080/admin/v2/namespaces/public
+// example outoupt
+["public/default","public/functions"]
+
+// check connectors
+$ curl -s http://localhost:8080/admin/v2/functions/connectors
+// example output
+[{"name":"aerospike","description":"Aerospike database
sink","sinkClass":"org.apache.pulsar.io.aerospike.AerospikeStringSink"},{"name":"cassandra","description":"Writes
data into
Cassandra","sinkClass":"org.apache.pulsar.io.cassandra.CassandraStringSink"},{"name":"kafka","description":"Kafka
source and sink
connector","sourceClass":"org.apache.pulsar.io.kafka.KafkaStringSource","sinkClass":"org.apache.pulsar.io.kafka.KafkaStringSink"},{"name":"kinesis","description":"Kinesis
sink connect [...]
+
+// check table services
+$ telnet localhost 4181
+```
+
2. Open another terminal to submit a Java Exclamation function.
```shell
