Skip to content

01-Snode

Snode: create and drop
1. Create an 8-node dnode and create snodes on each dnode.
2. Check the results of each field in information_schema.ins_snodes.
3. Delete the snodes and check again.
4. Randomly create and delete snodes, and check the results.
path: cases/18-StreamProcessing/01-Snode/test_snode_mgmt_basic.py

Snode: repeatedly drop with stream
1. Create a 6-node dnode and a 3-replica database.
2. Create snodes on each node.
3. Then delete these snodes.
4. Repeat creating snodes.
5. Create a stream and check its status.
6. Continue deleting snodes.
7. Check the operational status of the stream.
path: cases/18-StreamProcessing/01-Snode/test_snode_mgmt_replica3.py

Snode: replica test
Test the failover of 2-replica snodes.
path: cases/18-StreamProcessing/01-Snode/test_snode_mgmt_replicas.py

Parameter: alter config
Modify the parameters streamBufferSize and numOfMnodeStreamMgmtThreads.
path: cases/18-StreamProcessing/01-Snode/test_snode_params_alter_value.py

Parameter: check default value
Check the default values of the following parameters:
1. numOfMnodeStreamMgmtThreads
2. numOfVnodeStreamReaderThreads
3. numOfStreamTriggerThreads
4. streamBufferSize
5. numOfStreamRunnerThreads
6. streamNotifyMessageSize
7. streamNotifyFrameSize
path: cases/18-StreamProcessing/01-Snode/test_snode_params_check_default.py

Parameter: check maximum value
Check the maximum values of the following parameters:
1. numOfMnodeStreamMgmtThreads
2. numOfVnodeStreamReaderThreads
3. numOfStreamTriggerThreads
4. streamBufferSize
5. numOfStreamRunnerThreads
6. streamNotifyMessageSize
7. streamNotifyFrameSize
path: cases/18-StreamProcessing/01-Snode/test_snode_params_check_maxvalue.py

Parameter: check maximum value
Check the maximum values of the following parameters:
1. numOfMnodeStreamMgmtThreads
2. numOfVnodeStreamReaderThreads
3. numOfStreamTriggerThreads
4. streamBufferSize
5. numOfStreamRunnerThreads
6. streamNotifyMessageSize
7. streamNotifyFrameSize
path: cases/18-StreamProcessing/01-Snode/test_snode_params_check_minvalue.py

Privilege: recalculate
1. Check normal user no write privilege to recalc stream.
2. Check normal user no query/write privilege to recalc stream.
3. Check normal user have write privilege to recalc stream.
path: cases/18-StreamProcessing/01-Snode/test_snode_privileges_recalc.py

Privilege: snode and stream
1. Check normal user create snode.
2. Check normal user show snode.
3. Check normal user select ins_snodes.
4. Check normal user drop snode.
5. Check normal user create stream.
6. Check normal user drop stream.
path: cases/18-StreamProcessing/01-Snode/test_snode_privileges_stream.py

Privilege: show and systables
1. Check normal user query ins_streams.
2. Check normal user query ins_stream_tasks.
3. Check normal user query ins_stream_recalculates.
path: cases/18-StreamProcessing/01-Snode/test_snode_privileges_systable.py

Privilege: on multi database
1. Check normal user create stream in two db.
2. Check normal no source db read privilege to create stream.
3. Check grant read privilege on source db to user.
path: cases/18-StreamProcessing/01-Snode/test_snode_privileges_twodb.py