From user-return-34952-archive-asf-public=cust-asf.ponee.io@flink.apache.org Thu May 14 09:31:16 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 6A680180621 for ; Thu, 14 May 2020 11:31:16 +0200 (CEST) Received: (qmail 26951 invoked by uid 500); 14 May 2020 09:31:14 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 26941 invoked by uid 99); 14 May 2020 09:31:14 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 May 2020 09:31:14 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 14899C0791 for ; Thu, 14 May 2020 09:31:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.001 X-Spam-Level: X-Spam-Status: No, score=-0.001 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-ec2-va.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id jDOwJZrGI2ty for ; Thu, 14 May 2020 09:31:13 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.208.41; helo=mail-ed1-f41.google.com; envelope-from=flinkray@gmail.com; receiver= Received: from mail-ed1-f41.google.com (mail-ed1-f41.google.com [209.85.208.41]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTPS id BA355BB8C2 for ; Thu, 14 May 2020 09:31:12 +0000 (UTC) Received: by mail-ed1-f41.google.com with SMTP id bs4so1820846edb.6 for ; Thu, 14 May 2020 02:31:12 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=gCo9+jzHEvkttSay64+45ZZd9YkmvgNb8fQHsJ7jTI8=; b=t5cOis2dott+skOnAL9jKjUB30PLTj3c6VEU0xQSOfB7S2Vk9l3Z7XihC0EhZFNCER 4joi7cl7EQJrcIKT/49U32h8AAqp5q5rpZH9Foj6KQdqXHZzJfAw+uDGTPfVdQHyL28c soOAphgJmr9UO14fIqrNLKuzIcVqt9dOOpGqJOEYsWW4MpvOxa1zo29pC3DnshLZUnVX D7QHSPL3cIWT/eFBx0PMKFRI/JUdklyZG6KjccslgTqBHt0qJxqnBPW68zCzYRUezBuo eax6bZ9iAM3kBhWznAfpInDkhlYQq6cep805BUOrdC3YWPYiONJf39FYWqHCFI78khXP KxyA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=gCo9+jzHEvkttSay64+45ZZd9YkmvgNb8fQHsJ7jTI8=; b=ilPwZOWBW/+StqFlC2PteIR8IoEzNKzMtiKKgOJD0PvYHh4v/ReQ6VHlJ39p1Q1d4G KWpxA5Ys4zxxemEsacM79k6QupJOa4de7ppg3SCE5Z0nrfml07UDUeKnR7vCbFlSvk+F WMK9SglQ1HpS8m52WWXL5966PpVhWuEgQgdYcrJt8WqKzi/s7Jcs+k3c9N1rPOuhdeBc gXWIWdYH4C6GupxS63CbzZA5TIGk0fmxkH8X0Tl+x4VwA06XMkiofKbS4HTPpU3qwTVe 22DwNp3LGorEwtlYeuGxkZ08DSLRqNYB7Autcipee6S1kHD+Y4cdZl5Hvy5/mC0g6+2s YIsQ== X-Gm-Message-State: AOAM532nj/Hb7Zj9f5Q1VAfqvkOhn8w1mDyGqFgm5I2gNkQgHa+VKR6E Hs5Q7Md0oLfWXBZ+EwA71GJFFPnpiSK6w9bB1GlofigD X-Google-Smtp-Source: ABdhPJxM2Rs6Oxf6CmlsjPH4UnK+Hsud94mYphIX21/6MqSLYJOzWGdeNzZLqgt2Ty6T4xUKrark741RMMI/VA/l0a8= X-Received: by 2002:a50:cdc8:: with SMTP id h8mr3047806edj.26.1589448671375; Thu, 14 May 2020 02:31:11 -0700 (PDT) MIME-Version: 1.0 From: =?UTF-8?B?546L6Zu3?= Date: Thu, 14 May 2020 17:31:00 +0800 Message-ID: Subject: Flink operator throttle To: user@flink.apache.org Content-Type: multipart/alternative; boundary="00000000000072373805a5985b34" --00000000000072373805a5985b34 Content-Type: text/plain; charset="UTF-8" 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 --00000000000072373805a5985b34 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
hi, All

Does Flink support rate limitation?
How= to limit the rate when the external database connected by the sink operato= r has throughput limitation.
Instead of passive back pressure after rea= ching the limit of the external database, we want to limit rate actively.
Thanks
Ray
--00000000000072373805a5985b34--