search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Port RocketMQSink to FLIP-143. #70

Closed GOODBOY008 closed 1 month ago

GOODBOY008 commented 1 year ago

Link issue https://github.com/apache/rocketmq-flink/issues/56 and https://github.com/apache/rocketmq-flink/issues/64 .

codecov-commenter commented 1 year ago

Codecov Report

Merging #70 (21e95fd) into main (ebbba23) will decrease coverage by 2.31%. The diff coverage is 0.00%.

@@             Coverage Diff              @@
##               main      #70      +/-   ##
============================================
- Coverage     28.62%   26.31%   -2.32%     
- Complexity      164      171       +7     
============================================
  Files            62       75      +13     
  Lines          2536     2835     +299     
  Branches        269      283      +14     
============================================
+ Hits            726      746      +20     
- Misses         1743     2021     +278     
- Partials         67       68       +1
Impacted Files Coverage Δ
...mq/flink/legacy/example/RocketMQFlinkExample2.java 0.00% <0.00%> (ø)
.../org/apache/rocketmq/flink/sink2/RocketMQSink.java 0.00% <0.00%> (ø)
...ache/rocketmq/flink/sink2/RocketMQSinkBuilder.java 0.00% <0.00%> (ø)
...tmq/flink/sink2/committer/RocketMQCommittable.java 0.00% <0.00%> (ø)
...sink2/committer/RocketMQCommittableSerializer.java 0.00% <0.00%> (ø)
...ketmq/flink/sink2/committer/RocketMQCommitter.java 0.00% <0.00%> (ø)
...flink/sink2/writer/DefaultRocketMQSinkContext.java 0.00% <0.00%> (ø)
...he/rocketmq/flink/sink2/writer/RocketMQWriter.java 0.00% <0.00%> (ø)
...cketmq/flink/sink2/writer/RocketMQWriterState.java 0.00% <0.00%> (ø)
...nk/sink2/writer/RocketMQWriterStateSerializer.java 0.00% <0.00%> (ø)
... and 6 more

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

lizhimins commented 1 month ago

Closed this pr, please create a new one if necessary