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 2CFFC200C4E for ; Fri, 21 Apr 2017 09:05:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2B91D160BAF; Fri, 21 Apr 2017 07:05:22 +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 9AE81160B97 for ; Fri, 21 Apr 2017 09:05:21 +0200 (CEST) Received: (qmail 20516 invoked by uid 500); 21 Apr 2017 07:05:20 -0000 Mailing-List: contact issues-help@eagle.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@eagle.apache.org Delivered-To: mailing list issues@eagle.apache.org Received: (qmail 20507 invoked by uid 99); 21 Apr 2017 07:05:20 -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; Fri, 21 Apr 2017 07:05:20 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id A4F87E3A9C; Fri, 21 Apr 2017 07:05:20 +0000 (UTC) From: garrettlish To: issues@eagle.apache.org Reply-To: issues@eagle.apache.org References: In-Reply-To: Subject: [GitHub] eagle pull request #926: EAGLE-993: add duplicate removal settings in policy... Content-Type: text/plain Message-Id: <20170421070520.A4F87E3A9C@git1-us-west.apache.org> Date: Fri, 21 Apr 2017 07:05:20 +0000 (UTC) archived-at: Fri, 21 Apr 2017 07:05:22 -0000 Github user garrettlish commented on a diff in the pull request: https://github.com/apache/eagle/pull/926#discussion_r112622249 --- Diff: eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java --- @@ -73,11 +76,11 @@ public void nextEvent(PublishPartition partition, AlertStreamEvent event) { private void notifyAlert(PublishPartition partition, AlertStreamEvent event) { // remove the column values for publish plugin match partition.getColumnValues().clear(); - if (!publishPluginMapping.containsKey(partition)) { + if (!publishPluginMapping.containsKey(partition.getPublishId())) { --- End diff -- In publisher, we are able to specify the accepted streamId list, here how can we handle dropping the alert which comes from the stream which is NOT defined accepted streamId list? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---