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

【Bug】retryTimes didn't work #105

Closed humkum closed 5 months ago

humkum commented 6 months ago

retryTimes didn't work because follow reasons:

  1. In RocketMQDynamicTableSinkFactory.java the params order is "sleepTimeMs,retryTimes". But in RocketMQDynamicTableSink.class the params order is "retryTimes, sleepTimeMs" image image

  2. retryTimes didn't put into sink properties