AFAIK, `FlinkKafkaConsumer010#setRateLimiter` can configure the kafka source to have a rate limiter. (I assume you uses Kafka) However it only exists in Kafka 0.10 DataStream Connector, not in other versions nor table api.
王雷 <flink...@gmail.com> 于2020年5月14日周四 下午5:31写道： > hi, All > > Does Flink support rate limitation? > How to limit the rate when the external database connected by the sink > operator has throughput limitation. > Instead of passive back pressure after reaching the limit of the external > database, we want to limit rate actively. > > Thanks > Ray > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: libenc...@gmail.com; libenc...@pku.edu.cn
