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 #57] Fix some problems with the catalog #61

Closed li-xiao-shuang closed 1 year ago

li-xiao-shuang commented 1 year ago

fix : #57

codecov-commenter commented 1 year ago

Codecov Report

Merging #61 (5bf519f) into main (0e27ff8) will increase coverage by 0.04%. The diff coverage is 40.00%.

@@             Coverage Diff              @@
##               main      #61      +/-   ##
============================================
+ Coverage     27.15%   27.20%   +0.04%     
  Complexity      149      149              
============================================
  Files            59       59              
  Lines          2467     2470       +3     
  Branches        267      268       +1     
============================================
+ Hits            670      672       +2     
- Misses         1731     1732       +1     
  Partials         66       66
Impacted Files Coverage Δ
...q/flink/catalog/RocketMQCatalogFactoryOptions.java 100.00% <ø> (ø)
...tmq/flink/sink/table/RocketMQDynamicTableSink.java 25.92% <0.00%> (-0.33%) :arrow_down:
...rocketmq/flink/catalog/RocketMQCatalogFactory.java 100.00% <100.00%> (ø)

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