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

[ISSUE #32] Implementation of RocketMQ Catalog #49

Closed li-xiao-shuang closed 1 year ago

li-xiao-shuang commented 1 year ago

fix : #32

li-xiao-shuang commented 1 year ago

better to check CI error first.

done

SteNicholas commented 1 year ago

@li-xiao-shuang, @GOODBOY008, thanks for your contribution. I left the comments for the changes of this pull request. BTW, please squash the commits to one commit. PTAL.

codecov-commenter commented 1 year ago

Codecov Report

:exclamation: No coverage uploaded for pull request base (main@017db20). Click here to learn what that means. The diff coverage is n/a.

@@           Coverage Diff           @@
##             main      #49   +/-   ##
=======================================
  Coverage        ?   27.14%           
  Complexity      ?      149           
=======================================
  Files           ?       59           
  Lines           ?     2424           
  Branches        ?      258           
=======================================
  Hits            ?      658           
  Misses          ?     1701           
  Partials        ?       65

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