This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9795457 [FLINK-12064] [core, State Backends] RocksDBKeyedStateBackend
snapshots uses incorrect key serializer if reconfigure happens during restore
new edf082a [FLINK-11501] [kafka] Add ratelimiting to Kafka consumer
(#7679)
new e42fa0e [FLINK-11826] Ignore flaky testRateLimitedConsumer
new cf065a0 [FLINK-11826][tests] Harden
Kafka09ITCase#testRateLimitedConsumer
The 16089 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../connectors/kafka/FlinkKafkaConsumer010.java | 10 +-
.../connectors/kafka/internal/Kafka010Fetcher.java | 6 +-
.../kafka/internal/Kafka010FetcherTest.java | 6 +-
.../connectors/kafka/FlinkKafkaConsumer09.java | 26 +++-
.../connectors/kafka/internal/Kafka09Fetcher.java | 7 +-
.../kafka/internal/KafkaConsumerThread.java | 67 +++++++++-
.../streaming/connectors/kafka/Kafka09ITCase.java | 142 +++++++++++++++++++++
.../kafka/internal/Kafka09FetcherTest.java | 6 +-
.../kafka/internal/KafkaConsumerThreadTest.java | 139 +++++++++++++++++++-
flink-core/pom.xml | 6 +
.../io/ratelimiting/FlinkConnectorRateLimiter.java | 57 ++++-----
.../GuavaFlinkConnectorRateLimiter.java | 79 ++++++++++++
12 files changed, 507 insertions(+), 44 deletions(-)
copy
flink-java/src/main/java/org/apache/flink/api/java/summarize/ObjectColumnSummary.java
=>
flink-core/src/main/java/org/apache/flink/api/common/io/ratelimiting/FlinkConnectorRateLimiter.java
(53%)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/io/ratelimiting/GuavaFlinkConnectorRateLimiter.java
