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 98DAB200BD3 for ; Tue, 22 Nov 2016 07:16:54 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 979C5160B19; Tue, 22 Nov 2016 06:16:54 +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 E3069160AF9 for ; Tue, 22 Nov 2016 07:16:53 +0100 (CET) Received: (qmail 10166 invoked by uid 500); 22 Nov 2016 06:16:53 -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 10135 invoked by uid 99); 22 Nov 2016 06:16:52 -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, 22 Nov 2016 06:16:52 +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 299AB180027 for ; Tue, 22 Nov 2016 06:16:52 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.768 X-Spam-Level: X-Spam-Status: No, score=-6.768 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, KAM_LOTSOFHASH=0.25, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999, URIBL_BLOCKED=0.001] 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 fYktGYcYZk3N for ; Tue, 22 Nov 2016 06:16:50 +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 BD9165FB75 for ; Tue, 22 Nov 2016 06:16:49 +0000 (UTC) Received: (qmail 9903 invoked by uid 99); 22 Nov 2016 06:16:48 -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; Tue, 22 Nov 2016 06:16:48 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 7EC42E00E5; Tue, 22 Nov 2016 06:16:48 +0000 (UTC) From: Renkai To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org Message-ID: Subject: [GitHub] flink pull request #2847: [FLINK-5031]Consecutive DataStream.split() ignored Content-Type: text/plain Date: Tue, 22 Nov 2016 06:16:48 +0000 (UTC) archived-at: Tue, 22 Nov 2016 06:16:54 -0000 GitHub user Renkai opened a pull request: https://github.com/apache/flink/pull/2847 [FLINK-5031]Consecutive DataStream.split() ignored I think this is a way to solve this issue, but might not be the best one.Since I'm knowing the code base enough, I hope someone may review it and give some advice. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Renkai/flink FLINK-5031 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2847.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2847 ---- commit e216c79cd99c08d92847a6254c13fc8d75bb94c3 Author: renkai Date: 2016-11-21T06:38:03Z add a new StreamNode when split commit 8ce23e658102c35c58946429fd0fde5e72d722df Author: renkai Date: 2016-11-21T07:00:04Z fix test case commit 6672354819f2a6411f1a4c9479653f421b6163c6 Author: renkai Date: 2016-11-21T07:09:01Z delete output selectors check since those infos are moved to split1 commit d59900a19c0d966ee175fbbe9661004cec556670 Author: renkai Date: 2016-11-21T07:44:58Z add unit test for consecutive split commit 8198ee28e95371651d8c159db36dfcf6163c1659 Author: renkai Date: 2016-11-22T02:22:16Z add unit test for consecutive split commit 2a0d0ec730c1b7d5c955a4ef374ebd7fd6c58f5c Author: renkai Date: 2016-11-22T03:14:37Z add unit test for consecutive split commit 410b8717b76df8bfa40b59f1593439442d34ec49 Author: renkai Date: 2016-11-22T03:26:18Z add unit test for consecutive split commit 290f2f6f6fc1a249cf30d04cc31429e95dc0ec44 Author: renkai Date: 2016-11-22T03:50:13Z add unit test for consecutive split ---- --- 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. ---