apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

[ISSUE #257]Use thread name as rocksdb path #256

Closed ni-ze closed 1 year ago

ni-ze commented 1 year ago
  1. use the name of thread as rocksdb path;
  2. clean the temporary data of rocksdb in local;
  3. make WorkerThread shutdown method idempotent;

close #257

codecov-commenter commented 1 year ago

Codecov Report

Merging #256 (45f24e3) into develop (f499b19) will not change coverage. The diff coverage is 0.00%.

@@           Coverage Diff           @@
##           develop    #256   +/-   ##
=======================================
  Coverage     0.00%   0.00%           
=======================================
  Files           79      79           
  Lines         2640    2646    +6     
  Branches       250     252    +2     
=======================================
- Misses        2640    2646    +6     
Impacted Files Coverage Δ
.../apache/rocketmq/streams/core/common/Constant.java 0.00% <ø> (ø)
...he/rocketmq/streams/core/running/WorkerThread.java 0.00% <0.00%> (ø)
...ache/rocketmq/streams/core/state/RocksDBStore.java 0.00% <0.00%> (ø)

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more