apache/rocketmq-streams issues and pull requests

#312 - snapshot-2.0.1 add dispatcher module, support huawei and tencent clo…

Pull Request - State: open - Opened by j-ching 9 months ago

#311 - Multiple sinks cannot be implemented

Issue - State: open - Opened by 380828801 12 months ago

#310 - [ISSUE #299]polish(example) remove selection count

Pull Request - State: open - Opened by ni-ze about 1 year ago - 1 comment

#309 - OSAPP 2023-local storage optimization

Issue - State: closed - Opened by ni-ze about 1 year ago

#308 - polish example

Issue - State: closed - Opened by ni-ze about 1 year ago

#307 - [ISSUE #308]polish example

Pull Request - State: closed - Opened by ni-ze about 1 year ago

#306 - [ISSUS #309]OSAPP 2023-local storage optimization

Pull Request - State: closed - Opened by starmilkxin about 1 year ago - 1 comment

#305 - The `WordCount` example cannot run successfully

Issue - State: closed - Opened by elenacliu about 1 year ago - 1 comment

#304 - Add 2 user examples using different `window` type and `keyBy` by more than one keys

Issue - State: closed - Opened by elenacliu about 1 year ago

#303 - Add files via upload

Pull Request - State: closed - Opened by Kintles about 1 year ago - 2 comments

#302 - [ISSUE #300]npe when process data

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#301 - Add files via upload

Pull Request - State: closed - Opened by StarkChou over 1 year ago - 1 comment

#300 - WordCount demo dosen't work well

Issue - State: closed - Opened by xiaoweige1101 over 1 year ago - 1 comment

#299 - There's no difference between the implementation for the two `count` functions of `GroupedStreamImpl`

Issue - State: open - Opened by elenacliu over 1 year ago - 2 comments

#298 - what's the difference between `AccumulatorSupplier.java` and `AggregateSupplier.java`?

Issue - State: closed - Opened by elenacliu over 1 year ago - 1 comment

#297 - [ISSUE #304] add 2 window examples

Pull Request - State: closed - Opened by elenacliu over 1 year ago - 4 comments

#296 - Add watermark in IdleWindowScaner

Pull Request - State: closed - Opened by starmilkxin over 1 year ago - 2 comments

#295 - [ISSUE #281] Do not process the data from the removed MessageQueues by removing the queues from the originListener first

Pull Request - State: closed - Opened by Shuozeli over 1 year ago - 6 comments

#294 - Discard data because of delay

Issue - State: closed - Opened by ni-ze over 1 year ago

#293 - [ISSUE #294]Discard data because of delay

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#292 - [ISSUE #247] Support flatmap function in GroupedStream

Pull Request - State: closed - Opened by Shuozeli over 1 year ago

#292 - [ISSUE #247] Support flatmap function in GroupedStream

Pull Request - State: closed - Opened by Shuozeli over 1 year ago

#291 - [ISSUE #290] Change the logic of watermark judging whether to solve the data

Pull Request - State: closed - Opened by starmilkxin over 1 year ago

#291 - [ISSUE #290] Change the logic of watermark judging whether to solve the data

Pull Request - State: open - Opened by starmilkxin over 1 year ago

#290 - The logic of watermark judging whether to solve the data may result in missing data.

Issue - State: closed - Opened by starmilkxin over 1 year ago - 2 comments

#290 - The logic of watermark judging whether to solve the data may result in missing data.

Issue - State: open - Opened by starmilkxin over 1 year ago - 2 comments

#289 - Why the termination condition is 'start > valueTime - sizeInterval' instead of 'start >= valueTime - sizeInterval' ?

Issue - State: open - Opened by starmilkxin over 1 year ago - 1 comment

#289 - Why the termination condition is 'start > valueTime - sizeInterval' instead of 'start >= valueTime - sizeInterval' ?

Issue - State: closed - Opened by starmilkxin over 1 year ago - 1 comment

#288 - [ISSUE #286] fix bug: npl when rebalance

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#288 - [ISSUE #286] fix bug: npl when rebalance

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#287 - Messages which before RocketMQStream created will be consumed

Issue - State: closed - Opened by longbowen over 1 year ago - 11 comments

#286 - Instance reports an error, after another instance closed.

Issue - State: closed - Opened by longbowen over 1 year ago - 1 comment

#286 - Instance reports an error, after another instance closed.

Issue - State: closed - Opened by longbowen over 1 year ago - 1 comment

#285 - Will there be a complete test framework in the future to test the functions?

Issue - State: closed - Opened by elenacliu over 1 year ago - 2 comments

#284 - [ISSUE #246] finish data processing when function return null

Pull Request - State: closed - Opened by elenacliu over 1 year ago - 4 comments

#283 - Add constructor

Issue - State: closed - Opened by ni-ze over 1 year ago

#283 - Add constructor

Issue - State: closed - Opened by ni-ze over 1 year ago

#282 - [ISSUE #283]polish(example) add constructor

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#282 - [ISSUE #283]polish(example) add constructor

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#281 - Do not process data coms from removed MessageQueue.

Issue - State: closed - Opened by ni-ze over 1 year ago - 2 comments
Labels: good first issue

#281 - Do not process data coms from removed MessageQueue.

Issue - State: open - Opened by ni-ze over 1 year ago - 2 comments
Labels: good first issue

#280 - Bump jackson-databind from 2.13.4.1 to 2.13.4.2 in /core

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#280 - Bump jackson-databind from 2.13.4.1 to 2.13.4.2 in /core

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#279 - multi-instance applications consumers problem

Issue - State: closed - Opened by comecny over 1 year ago - 1 comment

#279 - multi-instance applications consumers problem

Issue - State: closed - Opened by comecny over 1 year ago - 1 comment

#278 - UnsatisfiedLinkError

Issue - State: closed - Opened by Jerryunclock over 1 year ago - 2 comments

#278 - UnsatisfiedLinkError

Issue - State: closed - Opened by Jerryunclock over 1 year ago - 2 comments

#277 - modify NOTICE file

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#276 - [ISSUE #272]Support subscribe topic from first

Pull Request - State: closed - Opened by Jargon9 over 1 year ago - 18 comments

#275 - [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream

Pull Request - State: closed - Opened by joeCarf over 1 year ago - 3 comments

#275 - [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream

Pull Request - State: closed - Opened by joeCarf over 1 year ago - 3 comments

#274 - release 1.1.1

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#274 - release 1.1.1

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#273 - release 1.1.1

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#273 - release 1.1.1

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#272 - support subscribe topic from first

Issue - State: closed - Opened by ni-ze over 1 year ago - 3 comments
Labels: good first issue, help wanted

#271 - [ISSUE #268]modify the return type of flatmap

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#271 - [ISSUE #268]modify the return type of flatmap

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#270 - polish double stream join

Issue - State: closed - Opened by ni-ze over 1 year ago

#270 - polish double stream join

Issue - State: closed - Opened by ni-ze over 1 year ago

#269 - [ISSUE #270]polish double stream join

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#269 - [ISSUE #270]polish double stream join

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#268 - Why does flatMap interface return RStream<T> instead of RStream<VR> ？

Issue - State: closed - Opened by huangql over 1 year ago - 1 comment

#268 - Why does flatMap interface return RStream<T> instead of RStream<VR> ？

Issue - State: closed - Opened by huangql over 1 year ago - 1 comment

#267 - Add watermark in session window

Issue - State: closed - Opened by ni-ze over 1 year ago

#267 - Add watermark in session window

Issue - State: closed - Opened by ni-ze over 1 year ago

#267 - Add watermark in session window

Issue - State: closed - Opened by ni-ze over 1 year ago

#266 - [ISSUE #267]Add watermark in session window

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#266 - [ISSUE #267]Add watermark in session window

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#265 - store watermark

Issue - State: closed - Opened by ni-ze over 1 year ago

#265 - store watermark

Issue - State: closed - Opened by ni-ze over 1 year ago

#265 - store watermark

Issue - State: closed - Opened by ni-ze over 1 year ago

#264 - [ISSUE #265]store watermark

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#264 - [ISSUE #265]store watermark

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#263 - The idle window does not trigger

Issue - State: closed - Opened by ni-ze over 1 year ago

#263 - The idle window does not trigger

Issue - State: closed - Opened by ni-ze over 1 year ago

#263 - The idle window does not trigger

Issue - State: closed - Opened by ni-ze over 1 year ago

#262 - [ISSUE #263]The idle window does not trigger

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#262 - [ISSUE #263]The idle window does not trigger

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#262 - [ISSUE #263]The idle window does not trigger

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#262 - [ISSUE #263]The idle window does not trigger

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#261 - Modify the configure of ObjectMapper

Issue - State: closed - Opened by ni-ze over 1 year ago

#261 - Modify the configure of ObjectMapper

Issue - State: closed - Opened by ni-ze over 1 year ago

#261 - Modify the configure of ObjectMapper

Issue - State: closed - Opened by ni-ze over 1 year ago

#260 - [ISSUE #261]Modify the configure of ObjectMapper

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#260 - [ISSUE #261]Modify the configure of ObjectMapper

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#260 - [ISSUE #261]Modify the configure of ObjectMapper

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#260 - [ISSUE #261]Modify the configure of ObjectMapper

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#259 - [ISSUE #251]Support avg function in WindowStream

Pull Request - State: closed - Opened by Jargon9 over 1 year ago - 5 comments

#259 - [ISSUE #251]Support avg function in WindowStream

Pull Request - State: closed - Opened by Jargon9 over 1 year ago - 5 comments

#259 - [ISSUE #251]Support avg function in WindowStream

Pull Request - State: closed - Opened by Jargon9 over 1 year ago - 5 comments

#258 - move log

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#258 - move log

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#258 - move log

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#258 - move log

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#257 - Use thread name as rocksdb path

Issue - State: closed - Opened by ni-ze over 1 year ago

#257 - Use thread name as rocksdb path

Issue - State: closed - Opened by ni-ze over 1 year ago

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

Pull Request - State: closed - Opened by ni-ze over 1 year ago - 1 comment

#255 - keep state topic consistent with source topic

Issue - State: closed - Opened by ni-ze over 1 year ago

#255 - keep state topic consistent with source topic

Issue - State: closed - Opened by ni-ze over 1 year ago

GitHub / apache/rocketmq-streams issues and pull requests