You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by da...@apache.org on 2022/08/09 15:24:41 UTC
[flink] branch master updated (3c8402a97a2 -> f53dd03fd5f)

This is an automated email from the ASF dual-hosted git repository.

dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 3c8402a97a2 [FLINK-28854][connector/jdbc] Migrate JDBC lookup table to the new LookupFunction and caching interface
     add f53dd03fd5f [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy for AsyncSinkWriter

No new revisions were added by this update.

Summary of changes:
 .../firehose/sink/KinesisFirehoseSinkWriter.java   |  15 +-
 .../kinesis/sink/KinesisStreamsSinkWriter.java     |  15 +-
 .../base/sink/writer/AIMDRateLimitingStrategy.java |  72 -------
 .../base/sink/writer/AsyncSinkWriter.java          | 164 ++++++++--------
 .../config/AsyncSinkWriterConfiguration.java       | 210 +++++++++++++++++++++
 .../sink/writer/strategy/AIMDScalingStrategy.java  |  85 +++++++++
 .../sink/writer/strategy/BasicRequestInfo.java     |  34 ++++
 .../base/sink/writer/strategy/BasicResultInfo.java |  40 ++++
 .../CongestionControlRateLimitingStrategy.java     | 124 ++++++++++++
 .../sink/writer/strategy/NoOpScalingStrategy.java  |  31 +++
 .../sink/writer/strategy/RateLimitingStrategy.java |  60 ++++++
 .../base/sink/writer/strategy/RequestInfo.java     |  27 +++
 .../base/sink/writer/strategy/ResultInfo.java      |  30 +++
 .../base/sink/writer/strategy/ScalingStrategy.java |  39 ++++
 .../connector/base/sink/ArrayListAsyncSink.java    |  17 +-
 .../sink/writer/AIMDRateLimitingStrategyTest.java  | 113 -----------
 .../base/sink/writer/AsyncSinkWriterTest.java      |  28 ++-
 .../writer/strategy/AIMDScalingStrategyTest.java   | 132 +++++++++++++
 .../CongestionControlRateLimitingStrategyTest.java | 184 ++++++++++++++++++
 .../writer/strategy/NoOpScalingStrategyTest.java   |  43 +++++
 20 files changed, 1164 insertions(+), 299 deletions(-)
 delete mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AIMDRateLimitingStrategy.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/config/AsyncSinkWriterConfiguration.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/AIMDScalingStrategy.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/BasicRequestInfo.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/BasicResultInfo.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/CongestionControlRateLimitingStrategy.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/NoOpScalingStrategy.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RateLimitingStrategy.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RequestInfo.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/ResultInfo.java
 create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/ScalingStrategy.java
 delete mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AIMDRateLimitingStrategyTest.java
 create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/AIMDScalingStrategyTest.java
 create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/CongestionControlRateLimitingStrategyTest.java
 create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/NoOpScalingStrategyTest.java