Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C48F8180CA for ; Wed, 24 Jun 2015 16:04:50 +0000 (UTC) Received: (qmail 70466 invoked by uid 500); 24 Jun 2015 16:04:50 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 70388 invoked by uid 500); 24 Jun 2015 16:04:50 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 70378 invoked by uid 99); 24 Jun 2015 16:04:50 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Jun 2015 16:04:50 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of ewenstephan@gmail.com designates 209.85.216.45 as permitted sender) Received: from [209.85.216.45] (HELO mail-vn0-f45.google.com) (209.85.216.45) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Jun 2015 16:02:36 +0000 Received: by vnbg1 with SMTP id g1so6986023vnb.3 for ; Wed, 24 Jun 2015 09:04:24 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:date:message-id:subject :from:to:content-type; bh=hDjE86UsY/zme12I/ouVI3IUK7fcQYfcmKjg+0TfL9o=; b=H1BS/ti0qrrqPP3D2Y0yETxR59dONBWkDqJ2kxU8mW1hTx/xNVJSvbwml//UGPHGMg CuTZY/bLhsApykvnxhOTyfvOQn6NUdRTpF9PeNV8eCg7Rp6W4FWAwpaIdIXOZXbJ5ybm rN2hwBEkmert+alcX5rnX6XEEvmHOlO2ZBzDG1TItQF1x/OmAKco6Uf1Vr81hb7k40Xf +4eIsnEZsuhyq0u5SQhvvPyUpSswUuz1WHdbLofwMuK+hY+KKc1EgWvC1aIVDADJ9MTq MAFBZ9RTXwerYa4iERyiKPd3AexAEvwdWf3/siHJaR74fRip340cQnzR4Y4JYDWxsoPL sY5w== MIME-Version: 1.0 X-Received: by 10.52.71.203 with SMTP id x11mr38015931vdu.48.1435161864026; Wed, 24 Jun 2015 09:04:24 -0700 (PDT) Sender: ewenstephan@gmail.com Received: by 10.31.164.210 with HTTP; Wed, 24 Jun 2015 09:04:23 -0700 (PDT) Received: by 10.31.164.210 with HTTP; Wed, 24 Jun 2015 09:04:23 -0700 (PDT) In-Reply-To: References: Date: Wed, 24 Jun 2015 18:04:23 +0200 X-Google-Sender-Auth: 0PxyAhx_5Uq95yjW0noVs_o5vss Message-ID: Subject: Re: Datasets union CompilerException From: Stephan Ewen To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a113637fa19c0e8051945a91e X-Virus-Checked: Checked by ClamAV on apache.org --001a113637fa19c0e8051945a91e Content-Type: text/plain; charset=UTF-8 Hmm, that issue must have been introduced as part of a recent change. Can you share your program so we can reproduce abs fix the bug? Am 24.06.2015 16:56 schrieb "Flavio Pompermaier" : > Hi to all, > > I'm running my flink-job on the new 0.9.0 version of Flink and now I get > this exception: > > Exception in thread "main" org.apache.flink.optimizer.CompilerException: > Bug: Plan generation for Unions picked a ship strategy between binary plan > operators. > at > org.apache.flink.optimizer.traversals.BinaryUnionReplacer.collect(BinaryUnionReplacer.java:113) > at > org.apache.flink.optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplacer.java:72) > at > org.apache.flink.optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplacer.java:41) > at > org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:170) > at > org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) > at > org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163) > at > org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163) > at > org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) > at > org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) > at > org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) > at > org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) > at > org.apache.flink.optimizer.plan.OptimizedPlan.accept(OptimizedPlan.java:127) > at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:520) > at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:402) > at > org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:173) > at > org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:54) > at > org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:789) > > How can I fix that? > > Best, > Flavio > --001a113637fa19c0e8051945a91e Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

Hmm, that issue must have been introduced as part of a recen= t change.

Can you share your program so we can reproduce abs fix the b= ug?

Am 24.06.2015 16:56 schrieb "Flavio Pomperm= aier" <pompermaier@okkam.it= >:
Hi to all,

=
I'm running my flink-job on the new 0.9.0 version of Flink and now= I get this exception:

Exception in thread &q= uot;main" org.apache.flink.optimizer.CompilerException: Bug: Plan gene= ration for Unions picked a ship strategy between binary plan operators.
at org.apache.flink.opt= imizer.traversals.BinaryUnionReplacer.collect(BinaryUnionReplacer.java:113)=
at org.apache.flink= .optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplacer.jav= a:72)
at org.apache.= flink.optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplace= r.java:41)
at org.ap= ache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:1= 70)
at org.apache.fl= ink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199)=
at org.apache.flink= .optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163)
<= div> at org.apache.flink.optimi= zer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163)
at org.apache.flink.optimizer.pla= n.SingleInputPlanNode.accept(SingleInputPlanNode.java:199)
at org.apache.flink.optimizer.plan.S= ingleInputPlanNode.accept(SingleInputPlanNode.java:199)
at org.apache.flink.optimizer.plan.Sing= leInputPlanNode.accept(SingleInputPlanNode.java:199)
at org.apache.flink.optimizer.plan.Single= InputPlanNode.accept(SingleInputPlanNode.java:199)
at org.apache.flink.optimizer.plan.Optimized= Plan.accept(OptimizedPlan.java:127)
at org.apache.flink.optimizer.Optimizer.compile(Optimizer.j= ava:520)
at org.apac= he.flink.optimizer.Optimizer.compile(Optimizer.java:402)
at org.apache.flink.client.LocalExecut= or.executePlan(LocalExecutor.java:173)
at org.apache.flink.api.java.LocalEnvironment.execute(Lo= calEnvironment.java:54)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvi= ronment.java:789)

How can I fix that?
<= div>
Best,
Flavio
--001a113637fa19c0e8051945a91e--