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 2022/09/05 02:12:23 UTC

[rocketmq-streams] branch main updated (cea2d6cc -> fb6187dc)

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

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


    from cea2d6cc Resolve bug of concurrent modification (#201)
     new a26425c1 feat(nest join) support nest join
     new 18b51850 maintain(example) remove MqttSourceExample
     new 7a36bba6 Merge branch 'main' into supportRsqldb
     new 52d75250 add synchronized
     new de5cbc62 Merge branch 'main' into supportRsqldb
     new d4a5daee fix(channel-rocketmq)commit offset when shutdown
     new b8da8e80 fix(channel-rocketmq)commit offset before shutdown
     new be73d55a remove scan dim
     new fa74f37f add log
     new fb6187dc Merge pull request #207 from ni-ze/supportRsqldb

The 553 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:
 .../rocketmq/streams/source/RocketMQSource.java    | 96 ++++++++++++++--------
 .../common/channel/impl/memory/MemorySource.java   |  8 +-
 .../function/service/impl/ScanFunctionService.java |  2 +-
 3 files changed, 69 insertions(+), 37 deletions(-)