You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by ka...@apache.org on 2023/01/20 09:02:35 UTC

[rocketmq-streams] branch develop updated (f499b197 -> 51d13d5e)

This is an automated email from the ASF dual-hosted git repository.

karp pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


    from f499b197 Merge pull request #254 from ni-ze/develop
     new 5e1dd642 use the name of thread as rocksdb path.
     new 1a935323 Merge branch 'local/upstream/develop' into develop
     new 73146ed4 repeated stop in workerThread
     new 45f24e31 modify the name of workeThread
     new 51d13d5e Merge pull request #256 from ni-ze/develop

The 717 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 core/pom.xml                                       |  8 +++--
 .../rocketmq/streams/core/common/Constant.java     |  2 +-
 .../streams/core/running/WorkerThread.java         | 14 ++++++---
 .../rocketmq/streams/core/state/RocksDBStore.java  | 36 +++++++++++++---------
 .../streams/core/state/RocksDBStoreTest.java       |  2 +-
 5 files changed, 38 insertions(+), 24 deletions(-)