From issues-return-170068-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Jun 4 10:21:20 2018 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 [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id D02C1180636 for ; Mon, 4 Jun 2018 10:21:19 +0200 (CEST) Received: (qmail 3842 invoked by uid 500); 4 Jun 2018 08:21:18 -0000 Mailing-List: contact issues-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 issues@flink.apache.org Received: (qmail 3833 invoked by uid 99); 4 Jun 2018 08:21:18 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 04 Jun 2018 08:21:18 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C78A7DFA59; Mon, 4 Jun 2018 08:21:18 +0000 (UTC) From: Aitozi To: issues@flink.apache.org Reply-To: issues@flink.apache.org References: In-Reply-To: Subject: [GitHub] flink issue #6059: [Flink-9418] Migrate SharedBuffer to use MapState Content-Type: text/plain Message-Id: <20180604082118.C78A7DFA59@git1-us-west.apache.org> Date: Mon, 4 Jun 2018 08:21:18 +0000 (UTC) Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6059 @dawidwys I'm sorry, I don't have a systematic testing tool. I'm working on the inner dynamic cep and `CEPOperator` can process serveral `NFA` when receive an element. Then i encounter the backpressure problem, i just test the patch if can overcome the backpressure problem. with this patch apply, 200 parallel CEPOperator can handle about 7000qps data input with about 30 patterns(rule) without backpressue. The type of pattern may have different influence, so the data I provide here may not be so useful. ---