rocketmq-flink
rocketmq-flink copied to clipboard
Port RocketMQSink to FLIP-143.
Link issue https://github.com/apache/rocketmq-flink/issues/56 and https://github.com/apache/rocketmq-flink/issues/64 .
Codecov Report
Merging #70 (21e95fd) into main (ebbba23) will decrease coverage by
2.31%
. The diff coverage is0.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
Closed this pr, please create a new one if necessary