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 27F02200BA3 for ; Thu, 20 Oct 2016 23:49:38 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 26C11160B01; Thu, 20 Oct 2016 21:49:38 +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 77F5D160AE0 for ; Thu, 20 Oct 2016 23:49:37 +0200 (CEST) Received: (qmail 25231 invoked by uid 500); 20 Oct 2016 21:49:36 -0000 Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.incubator.apache.org Delivered-To: mailing list commits@beam.incubator.apache.org Received: (qmail 25222 invoked by uid 99); 20 Oct 2016 21:49:36 -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, 20 Oct 2016 21:49:36 +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 415FEC195E for ; Thu, 20 Oct 2016 21:49:36 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.219 X-Spam-Level: X-Spam-Status: No, score=-6.219 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id h63no6BKHbRg for ; Thu, 20 Oct 2016 21:49:35 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 51E415F201 for ; Thu, 20 Oct 2016 21:49:35 +0000 (UTC) Received: (qmail 7858 invoked by uid 99); 20 Oct 2016 21:47:02 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Oct 2016 21:47:02 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 2CA2F2C0073 for ; Thu, 20 Oct 2016 21:47:02 +0000 (UTC) Date: Thu, 20 Oct 2016 21:47:02 +0000 (UTC) From: "Daniel Halperin (JIRA)" To: commits@beam.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Closed] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 20 Oct 2016 21:49:38 -0000 [ https://issues.apache.org/jira/browse/BEAM-323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-323. -------------------------------- > The InProcessPipelineRunner uses user objects for State and Timer lookups > ------------------------------------------------------------------------- > > Key: BEAM-323 > URL: https://issues.apache.org/jira/browse/BEAM-323 > Project: Beam > Issue Type: Bug > Components: runner-direct > Reporter: Thomas Groh > Assignee: Thomas Groh > Priority: Critical > Fix For: 0.2.0-incubating > > > The runner keys state based on the user key that it was grouped by, instead of the structural value of that key. This causes callbacks to be updated based on java equality, so an object with a poor equals can cause the Pipeline to not progress. > Initially uncovered in https://github.com/apache/incubator-beam/pull/409 -- This message was sent by Atlassian JIRA (v6.3.4#6332)