Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 74106200CF8 for ; Thu, 14 Sep 2017 14:36:07 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 72BB31609CC; Thu, 14 Sep 2017 12:36:07 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B88BF1609CE for ; Thu, 14 Sep 2017 14:36:06 +0200 (CEST) Received: (qmail 65213 invoked by uid 500); 14 Sep 2017 12:36:05 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 65202 invoked by uid 99); 14 Sep 2017 12:36:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Sep 2017 12:36:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 01C8F1A7F1D for ; Thu, 14 Sep 2017 12:36:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -100.002 X-Spam-Level: X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id yehPP5B3lihH for ; Thu, 14 Sep 2017 12:36:04 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id D73655FCE9 for ; Thu, 14 Sep 2017 12:36:03 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id DC5B3E0E99 for ; Thu, 14 Sep 2017 12:36:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 34CDE25386 for ; Thu, 14 Sep 2017 12:36:00 +0000 (UTC) Date: Thu, 14 Sep 2017 12:36:00 +0000 (UTC) From: "Tzu-Li (Gordon) Tai (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 14 Sep 2017 12:36:07 -0000 Tzu-Li (Gordon) Tai created FLINK-7622: ------------------------------------------ Summary: Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Key: FLINK-7622 URL: https://issues.apache.org/jira/browse/FLINK-7622 Project: Flink Issue Type: Improvement Components: Kinesis Connector Reporter: Tzu-Li (Gordon) Tai This issue was brought to discussion by [~sthm] offline. Currently, records are added to the Kinesis KPL producer client without checking the number of outstanding records within the local KPL queue. This manner is basically neglecting backpressure when producing to Kinesis through KPL, and can therefore exhaust system resources. We should respect {{producer.getOutstandingRecordsCount()}} as a measure of backpressure, and propagate backpressure upstream by blocking further sink invocations when some threshold of outstanding record count is exceeded. The recommended threshold [1] seems to be 10,000. -- This message was sent by Atlassian JIRA (v6.4.14#64029)