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 4eaeb92 [FLINK-23696][connectors/rabbitmq] Fix
RMQSourceTest.testRedeliveredSessionIDsAck test
add 0685dcb [FLINK-24639][kinesis] Add UniformShardAssigner (#17583)
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/datastream/kinesis.md | 11 ++--
docs/content/docs/connectors/datastream/kinesis.md | 11 ++--
flink-connectors/flink-connector-kinesis/pom.xml | 6 ++
.../kinesis/util/UniformShardAssigner.java | 58 +++++++++++++++++
.../kinesis/util/UniformShardAssignerTest.java | 75 ++++++++++++++++++++++
5 files changed, 153 insertions(+), 8 deletions(-)
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/UniformShardAssigner.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/UniformShardAssignerTest.java
