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 45DB0200C3A for ; Fri, 31 Mar 2017 09:20:00 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 44690160B8C; Fri, 31 Mar 2017 07:20:00 +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 87440160B80 for ; Fri, 31 Mar 2017 09:19:59 +0200 (CEST) Received: (qmail 14134 invoked by uid 500); 31 Mar 2017 07:19:58 -0000 Mailing-List: contact notifications-help@asterixdb.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@asterixdb.apache.org Delivered-To: mailing list notifications@asterixdb.apache.org Received: (qmail 14123 invoked by uid 99); 31 Mar 2017 07:19:58 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 31 Mar 2017 07:19:58 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 18E13C18AA for ; Fri, 31 Mar 2017 07:19:58 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.919 X-Spam-Level: X-Spam-Status: No, score=0.919 tagged_above=-999 required=6.31 tests=[SPF_FAIL=0.919] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id RRldMnekn-t3 for ; Fri, 31 Mar 2017 07:19:57 +0000 (UTC) Received: from unhygienix.ics.uci.edu (unhygienix.ics.uci.edu [128.195.14.130]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id ECA505FBCA for ; Fri, 31 Mar 2017 07:19:56 +0000 (UTC) Received: from localhost (localhost [127.0.0.1]) by unhygienix.ics.uci.edu (Postfix) with ESMTP id A45C02421EB; Fri, 31 Mar 2017 00:19:56 -0700 (PDT) Date: Fri, 31 Mar 2017 00:19:56 -0700 From: "Xikui Wang (Code Review)" To: Jenkins Reply-To: xkkwww@gmail.com X-Gerrit-MessageType: newpatchset Subject: Change in asterixdb[master]: WIP - Fix record loss for certain certain feed type X-Gerrit-Change-Id: Ifb2d550750ec084232831befa0bf0fd0d94e7bae X-Gerrit-ChangeURL: X-Gerrit-Commit: 2d61cbdf7190d0925117b946fc279093f9300bd9 In-Reply-To: References: MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Content-Disposition: inline User-Agent: Gerrit/2.12.7 Message-Id: <20170331071956.A45C02421EB@unhygienix.ics.uci.edu> archived-at: Fri, 31 Mar 2017 07:20:00 -0000 Hello Jenkins, I'd like you to reexamine a change. Please visit https://asterix-gerrit.ics.uci.edu/1646 to look at the new patch set (#2). Change subject: WIP - Fix record loss for certain certain feed type ...................................................................... WIP - Fix record loss for certain certain feed type 1. Fix blindly replace connector between FeedCollector and AssignOperator. 2. Wrap AssignOperator into the FeedMetaOperator to make sure the operators inside (udf, accessor, etc.) can handle messages in the feed workflow. 3. Revise feed connection job merge function. 4. Test case fix. Change-Id: Ifb2d550750ec084232831befa0bf0fd0d94e7bae --- M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.java M asterixdb/asterix-app/src/main/java/org/apache/asterix/utils/FeedOperations.java M asterixdb/asterix-app/src/test/resources/runtimets/results/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.4.adm M asterixdb/asterix-app/src/test/resources/runtimets/results/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.5.adm M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java M asterixdb/asterix-installer/src/test/resources/transactionts/results/query_after_restart/dataset-with-meta-record/dataset-with-meta-record.5.adm 7 files changed, 33 insertions(+), 27 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/46/1646/2 -- To view, visit https://asterix-gerrit.ics.uci.edu/1646 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: Ifb2d550750ec084232831befa0bf0fd0d94e7bae Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Xikui Wang Gerrit-Reviewer: Jenkins