lizhiboo opened a new pull request #795:
URL: https://github.com/apache/rocketmq-externals/pull/795
## What is the purpose of the change
assign thread name to worker task thread, do not use default
pool-xx-thread-xx format.
--
This is an automated message from the Apache Git Servi
lizhiboo opened a new issue #796:
URL: https://github.com/apache/rocketmq-externals/issues/796
assign thread name to worker task thread, do not use default
pool-xx-thread-xx format.
#795
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
lizhiboo opened a new pull request #797:
URL: https://github.com/apache/rocketmq-externals/pull/797
## What is the purpose of the change
fields put after SinkDataEntry built, SinkDataEntry will include fields.
```java
SinkDataEntry sinkDataEntry =
dataEntryBuilder.buildSink
lizhiboo opened a new issue #798:
URL: https://github.com/apache/rocketmq-externals/issues/798
fields will not be built in SinkDataEntry.
#797
```java
SinkDataEntry sinkDataEntry =
dataEntryBuilder.buildSinkDataEntry(message.getQueueOffset());
List fields = sche
lizhiboo opened a new issue #799:
URL: https://github.com/apache/rocketmq-externals/issues/799
```java
private SinkDataEntry convertToSinkDataEntry(MessageExt message) {
Map properties = message.getProperties();
String queueName;
EntryType entryTyp
lizhiboo opened a new pull request #800:
URL: https://github.com/apache/rocketmq-externals/pull/800
Support rocketmq connector sink to hudi.
welcome to contribute together.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
lizhiboo opened a new issue #801:
URL: https://github.com/apache/rocketmq-externals/issues/801
#800
Welcome to contribute together.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
RongtongJin closed issue #3290:
URL: https://github.com/apache/rocketmq/issues/3290
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr..
953761972 opened a new issue #15:
URL: https://github.com/apache/rocketmq-dashboard/issues/15
[2021-08-29 18:29:36.297] ERROR Application run failed
java.lang.NoSuchMethodError:
org.yaml.snakeyaml.nodes.ScalarNode.getScalarStyle()Lorg/yaml/snakeyaml/DumperOptions$ScalarStyle;
at
SteNicholas opened a new issue #3298:
URL: https://github.com/apache/rocketmq/issues/3298
**FEATURE REQUEST**
RocketMQ Flink module would add the implementation of the `Catalog`
interface, which needs the schema registry feature of the RocketMQ. The schema
registry feature is like t
StyleTang commented on issue #15:
URL:
https://github.com/apache/rocketmq-dashboard/issues/15#issuecomment-907788122
@953761972
Could you provide more information about how to reproduce it?
**BUG REPORT**
1. Please describe the issue you observed:
- What did you do
hjm2015 opened a new pull request #3299:
URL: https://github.com/apache/rocketmq/pull/3299
去除多余配置,SocketChannel 创建出来默认就是阻塞的,并且上面又再次设置非阻塞的,所以这个设置阻塞是没有必要的
**Make sure set the target branch to `develop`**
## What is the purpose of the change
X
## Brief change
hjm2015 closed pull request #3299:
URL: https://github.com/apache/rocketmq/pull/3299
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr.
hjm2015 opened a new pull request #3300:
URL: https://github.com/apache/rocketmq/pull/3300
去除多余配置,SocketChannel 创建出来默认就是阻塞的,并且后面又再次设置非阻塞的,所以这个设置阻塞是没有必要的
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
coveralls commented on pull request #3300:
URL: https://github.com/apache/rocketmq/pull/3300#issuecomment-907794394
[![Coverage
Status](https://coveralls.io/builds/42490584/badge)](https://coveralls.io/builds/42490584)
Coverage increased (+0.002%) to 54.227% when pulling
**f225c
codecov-commenter commented on pull request #3300:
URL: https://github.com/apache/rocketmq/pull/3300#issuecomment-907794414
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3300?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th
lwclover commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-907928500
> It would be better if you can submit an issue related with this PR first.
next time, I will. haha
--
This is an automated message from the Apache Git Service.
To res
SpriderMan opened a new issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301
![image](https://user-images.githubusercontent.com/18304842/131272914-2cdf76e8-8df5-4799-a867-4f151bdfe4d0.png)
commitlog文件有flush到磁盘的操作,indexfile需要吗?
--
This is an automated message from the A
caigy opened a new pull request #82:
URL: https://github.com/apache/rocketmq-operator/pull/82
Try to fix #80 :
1. Return error in `broker_controller.exec()` if remote command is failed.
2. Check if `broker_controller.exec()` returns error. If so, operator would
NOT generating com
ltamber commented on a change in pull request #800:
URL: https://github.com/apache/rocketmq-externals/pull/800#discussion_r698116971
##
File path:
rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed t
ltamber commented on a change in pull request #800:
URL: https://github.com/apache/rocketmq-externals/pull/800#discussion_r698117521
##
File path:
rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
##
@@ -0,0 +1,232 @@
+
+/*
+
ltamber commented on a change in pull request #3224:
URL: https://github.com/apache/rocketmq/pull/3224#discussion_r698119097
##
File path: acl/pom.xml
##
@@ -13,7 +13,7 @@
org.apache.rocketmq
rocketmq-all
-4.9.1-SNAPSHOT
+4.9.2-SNAPSHOT
Git-Yang opened a new pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302
## What is the purpose of the change
#3296
## Brief changelog
- Add delivery TPS of SCHEDULE_TOPIC_
- Add delivery TPS for each queue of SCHEDULE_TOPIC_
- Add the w
codecov-commenter edited a comment on pull request #3224:
URL: https://github.com/apache/rocketmq/pull/3224#issuecomment-893982717
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3224?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_
Hi,
The Project Management Committee (PMC) for Apache RocketMQ has invited
Xiaofeng Jiang to become a committer and we are pleased
to announce that he has accepted.
Being a committer enables easier contribution to the project since there is
no need to go via the patch submission process. This sho
Hi,
The Project Management Committee (PMC) for Apache RocketMQ has invited
Jidi Zhang to become a committer and we are pleased to announce that he has
accepted.
Being a committer enables easier contribution to the project since there is
no need to go via the patch submission process. This should
codecov-commenter commented on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-907974326
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3302?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th
Congrats.
heng du 于2021年8月30日周一 上午10:58写道:
> Hi,
>
> The Project Management Committee (PMC) for Apache RocketMQ has invited
> Jidi Zhang to become a committer and we are pleased to announce that he has
> accepted.
>
> Being a committer enables easier contribution to the project since there is
>
Congrats.
heng du 于2021年8月30日周一 上午10:57写道:
> Hi,
>
> The Project Management Committee (PMC) for Apache RocketMQ has invited
> Xiaofeng Jiang to become a committer and we are pleased
> to announce that he has accepted.
>
> Being a committer enables easier contribution to the project since there i
Congrats!
On Sun, Aug 29, 2021 at 8:07 PM Amber Liu wrote:
> Congrats.
>
> heng du 于2021年8月30日周一 上午10:58写道:
>
> > Hi,
> >
> > The Project Management Committee (PMC) for Apache RocketMQ has invited
> > Jidi Zhang to become a committer and we are pleased to announce that he
> has
> > accepted.
>
maqingxiang commented on pull request #720:
URL:
https://github.com/apache/rocketmq-client-go/pull/720#issuecomment-907981481
> @superhx which version of your client and rmq server? Could you pls submit
a issue to describe it
https://github.com/apache/rocketmq-client-go/issues/718
Congrats!
At 2021-08-30 10:58:37, "heng du" wrote:
>Hi,
>
>The Project Management Committee (PMC) for Apache RocketMQ has invited
>Jidi Zhang to become a committer and we are pleased to announce that he has
>accepted.
>
>Being a committer enables easier contribution to the project since there is
Congrats!
At 2021-08-30 10:57:08, "heng du" wrote:
>Hi,
>
>The Project Management Committee (PMC) for Apache RocketMQ has invited
>Xiaofeng Jiang to become a committer and we are pleased
>to announce that he has accepted.
>
>Being a committer enables easier contribution to the project since ther
maqingxiang commented on issue #718:
URL:
https://github.com/apache/rocketmq-client-go/issues/718#issuecomment-907982521
https://github.com/apache/rocketmq-client-go/pull/720
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
Congrats.
发件人: Amber Liu
发送时间: 2021年8月30日 11:07
收件人: dev@rocketmq.apache.org
主题: Re: [ANNOUNCE] New committer involved, welcome Jidi Zhang
Congrats.
heng du 于2021年8月30日周一 上午10:58写道:
> Hi,
>
> The Project Management Committee (PMC) for Apache RocketMQ has invi
Congrats.
发件人: heng du
发送时间: 2021年8月30日 10:57
收件人: dev
抄送: 蒋晓峰
主题: [ANNOUNCE] New committer involved, welcome Xiaofeng Jiang
Hi,
The Project Management Committee (PMC) for Apache RocketMQ has invited
Xiaofeng Jiang to become a committer and we are pleased
to a
codecov-commenter edited a comment on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-907974326
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3302?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_
ShannonDing commented on issue #718:
URL:
https://github.com/apache/rocketmq-client-go/issues/718#issuecomment-907986786
see #720, set subversion when buildSubscriptionData
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ShannonDing merged pull request #720:
URL: https://github.com/apache/rocketmq-client-go/pull/720
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
ShannonDing closed issue #718:
URL: https://github.com/apache/rocketmq-client-go/issues/718
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
Thanks to the Apache RocketMQ community. I would like to keep contributing
to the RocketMQ streams and Flink module.
Best Regards,
Nicholas Jiang
On Mon, Aug 30, 2021 at 11:28 AM Hu Zongtang wrote:
> Congrats.
>
> --
> *发件人:* heng du
> *发送时间:* 2021年8月30日 10:57
> *收
caigy commented on issue #74:
URL:
https://github.com/apache/rocketmq-operator/issues/74#issuecomment-908029411
Is it duplicated with #38 ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the s
SteNicholas opened a new pull request #96:
URL: https://github.com/apache/rocketmq-site/pull/96
## What is the purpose of the change
Add new committer nicholasjiang to the `team.md`.
## Brief changelog
Add new committer nicholasjiang to the `team.md`.
## Verifying
odbozhou commented on a change in pull request #800:
URL: https://github.com/apache/rocketmq-externals/pull/800#discussion_r698207363
##
File path:
rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed
odbozhou commented on pull request #800:
URL:
https://github.com/apache/rocketmq-externals/pull/800#issuecomment-908075911
Submit an issue, this pr is associated with this issue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
45 matches
Mail list logo