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 279C7200BA6 for ; Tue, 18 Oct 2016 17:41:19 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 263BC160AFC; Tue, 18 Oct 2016 15:41:19 +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 68E18160ACE for ; Tue, 18 Oct 2016 17:41:18 +0200 (CEST) Received: (qmail 68030 invoked by uid 500); 18 Oct 2016 15:41:17 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 68019 invoked by uid 99); 18 Oct 2016 15:41:17 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Oct 2016 15:41:17 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 083241804F7 for ; Tue, 18 Oct 2016 15:41:17 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-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-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id hZ6X00oo5ozB for ; Tue, 18 Oct 2016 15:41:14 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id E50655F257 for ; Tue, 18 Oct 2016 15:41:13 +0000 (UTC) Received: (qmail 64064 invoked by uid 99); 18 Oct 2016 15:40:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Oct 2016 15:40:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 850C72C4C77 for ; Tue, 18 Oct 2016 15:40:58 +0000 (UTC) Date: Tue, 18 Oct 2016 15:40:58 +0000 (UTC) From: "Chandni Singh (JIRA)" To: dev@apex.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Comment Edited] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 18 Oct 2016 15:41:19 -0000 [ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585751#comment-15585751 ] Chandni Singh edited comment on APEXMALHAR-2284 at 10/18/16 3:40 PM: --------------------------------------------------------------------- One concept that I think I should point is how getAsync improves performance is that if the value is not available immediately, then the client can cache the future and work on other keys. Look at the implementations of AbstractDeduper. 1. If SpillableArrayListMultimap only lacks asynchronous get, then that can be added to it. That should not be the only reason to duplicate the functionality. 2. ManagedTimeMultiValueState has no tests and is full of warnings. We should not create a complete separate implementation which duplicates a larger part of functionality provided by something existing otherwise we will have too many slightly different variations of the same thing and that will be very difficult to manage. IMO this is a good opportunity to improve SpillableArrayListMultimapImpl and use that. was (Author: csingh): One concept that I think I should point is that getAsync improves performance is that if the value is not available immediately, then the client can cache the future and work on other keys. Look at the implementations of AbstractDeduper. 1. If SpillableArrayListMultimap only lacks asynchronous get, then that can be added to it. That should not be the only reason to duplicate the functionality. 2. ManagedTimeMultiValueState has no tests and is full of warnings. We should not create a complete separate implementation which duplicates a larger part of functionality provided by something existing otherwise we will have too many slightly different variations of the same thing and that will be very difficult to manage. IMO this is a good opportunity to improve SpillableArrayListMultimapImpl and use that. > POJOInnerJoinOperatorTest fails in Travis CI > -------------------------------------------- > > Key: APEXMALHAR-2284 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2284 > Project: Apache Apex Malhar > Issue Type: Bug > Reporter: Thomas Weise > Assignee: Chaitanya > Priority: Blocker > Fix For: 3.6.0 > > > https://s3.amazonaws.com/archive.travis-ci.org/jobs/166322754/log.txt > {code} > Failed tests: > POJOInnerJoinOperatorTest.testEmitMultipleTuplesFromStream2:337 Number of tuple emitted expected:<2> but was:<4> > POJOInnerJoinOperatorTest.testInnerJoinOperator:184 Number of tuple emitted expected:<1> but was:<2> > POJOInnerJoinOperatorTest.testMultipleValues:236 Number of tuple emitted expected:<2> but was:<3> > POJOInnerJoinOperatorTest.testUpdateStream1Values:292 Number of tuple emitted expected:<1> but was:<2> > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)