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 2CC6D200C8F for ; Fri, 9 Jun 2017 20:19:48 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2B89A160BCA; Fri, 9 Jun 2017 18:19:48 +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 2558F160BB6 for ; Fri, 9 Jun 2017 20:19:46 +0200 (CEST) Received: (qmail 92599 invoked by uid 500); 9 Jun 2017 18:19:46 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 92589 invoked by uid 99); 9 Jun 2017 18:19:46 -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; Fri, 09 Jun 2017 18:19:46 +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 C22AAC0A09 for ; Fri, 9 Jun 2017 18:19:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.889 X-Spam-Level: * X-Spam-Status: No, score=1.889 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, T_REMOTE_IMAGE=0.01] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id sJDTZ3D2MU8s for ; Fri, 9 Jun 2017 18:19:43 +0000 (UTC) Received: from mail-ua0-f178.google.com (mail-ua0-f178.google.com [209.85.217.178]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id C93425F5B8 for ; Fri, 9 Jun 2017 18:19:42 +0000 (UTC) Received: by mail-ua0-f178.google.com with SMTP id q15so36618279uaa.2 for ; Fri, 09 Jun 2017 11:19:42 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=UL4g+pEvBdj0Kmjtpy1HkpfedAbyhHpXavIWW0sm+lM=; b=TYqVDjeeteSNPIC5oKLkEfhvZQbVTK6pDKVzcOBQQqp6a92DU2xMf2k0PkC09V0JM1 arnlszbu0jzdKG8yyQi5XWX5L0PFGUcuN0TkyzrLEefDGKsGrsgfPDXp8RQv14IBgmKR u7aLjrgmiBWlwQfoJpZ4Zn0qpr0/qo39nvGwOtFaLizGB9UFdQThVVxCOIoojUAjyNHB khrNIZsPo105X0dmiD5f628hkOHrZ9pfRtTDnJZB0uJb6M/Pi/N5bR5kToeixNfkDtkh oGihSojyZBN748MVpK+glbdor6+Tf06DDF//+KJ3+shSwJicGbr/KmOgxxhRB6/b2L1W Lkag== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=UL4g+pEvBdj0Kmjtpy1HkpfedAbyhHpXavIWW0sm+lM=; b=k5pUW3yq9LRQ98ge+HphhnYPF1ZUqsfsgCab1+FHep5RHWd2+JLEXm/SfUYK5HB+yr 5Ykj2fdaCbsGBjjGP/yGRGDcKwiMcH1NfOkEnqlMQpVf/6/if8/SWA9Ai0ZwM0Ro8xG+ RzVAvkdJUrYug942zgMBWybsFdmBv1/2XqJvjfGeZVt7cFMnjSBsMdzgy6R6T7Bkhy43 dZpf9uzN+ffdHwuxyqvV+Z360vfLOKdkOK545Xys9TyUWlFUImQFe0dXEAz0bTbX5HMI 9bgMKUUH66iGx8S2+fIOx4h63AMYudK7/hspioGXFqY3FxGgHjG+BLmb3UjO8LZImLfZ kxMQ== X-Gm-Message-State: AODbwcCu1cub6s95dLKQe7Sye77MPxBBMF2NS3gy3msZJIiMNfPjuTff 3mSMk+udxnXMboNUCtC0IYoC+vnnWELTUSo= X-Received: by 10.176.95.217 with SMTP id g25mr18222118uaj.71.1497032381596; Fri, 09 Jun 2017 11:19:41 -0700 (PDT) MIME-Version: 1.0 Received: by 10.159.62.152 with HTTP; Fri, 9 Jun 2017 11:19:41 -0700 (PDT) In-Reply-To: References: From: Dawid Wysakowicz Date: Fri, 9 Jun 2017 20:19:41 +0200 Message-ID: Subject: Re: Stream sql example To: user Content-Type: multipart/alternative; boundary="089e0820496052878405518b036a" archived-at: Fri, 09 Jun 2017 18:19:48 -0000 --089e0820496052878405518b036a Content-Type: text/plain; charset="UTF-8" Sorry forgot to add the link: https://gist.github.com/dawidwys/537d12a6f2355cba728bf93f1af87b45 Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder 2017-06-09 20:19 GMT+02:00 Dawid Wysakowicz : > Hi, > I tried writing a simple sql query with custom StreamTableSource and it > fails with error: > > org.apache.flink.table.codegen.CodeGenException: Arity of result type >>> does not match number of expressions. >> >> at org.apache.flink.table.codegen.CodeGenerator.generateResultExpression( >>> CodeGenerator.scala:940) >> >> at org.apache.flink.table.codegen.CodeGenerator. >>> generateConverterResultExpression(CodeGenerator.scala:883) >> >> at org.apache.flink.table.plan.nodes.CommonScan$class. >>> generatedConversionFunction(CommonScan.scala:57) >> >> at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan. >>> generatedConversionFunction(StreamTableSourceScan.scala:35) >> >> at org.apache.flink.table.plan.nodes.datastream.StreamScan$ >>> class.convertToInternalRow(StreamScan.scala:48) >> >> at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan. >>> convertToInternalRow(StreamTableSourceScan.scala:35) >> >> at org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan. >>> translateToPlan(StreamTableSourceScan.scala:107) >> >> > You can check the source code here: > > > Z pozdrowieniami! / Cheers! > > Dawid Wysakowicz > > *Data/Software Engineer* > > Skype: dawid_wys | Twitter: @OneMoreCoder > > > --089e0820496052878405518b036a Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable

Z poz= drowieniami! / Cheers!


Dawid Wysakowicz

<= p dir=3D"ltr" style=3D"font-size:12.8px;color:rgb(136,136,136);line-height:= 1.38;margin-top:0pt;margin-bottom:0pt">Data/Software Engineer

<= span style=3D"line-height:1.38;color:rgb(102,102,102);font-family:Arial;fon= t-size:13.3333px;white-space:pre-wrap">Skype: dawid_wys | Twitter: @OneMore= Coder


2017-06-09 20:19 GMT+02:00 Dawid Wysakowicz = <wysakowicz.dawid@gmail.com>:
Hi,
I tried writing a simple = sql query with custom StreamTableSource and it fails with error:
=
org.apache.flink.table.codegen.Code= GenException: Arity of result type does not match number of expressions.
= at org.apache.flink.table.codegen.CodeGenerator.generateRe= sultExpression(CodeGenerator.scala:940)
at org.apache.flink.= table.codegen.CodeGenerator.generateConverterResultExpressio= n(CodeGenerator.scala:883)
at org.apache.flink.table.plan.nod= es.CommonScan$class.generatedConversionFunction(CommonScan.scala:= 57)
at org.apache.flink.table.plan.nodes.datastream.Stre= amTableSourceScan.generatedConversionFunction(StreamTableSourceSc= an.scala:35)
at org.apache.flink.table.plan.nodes.datast= ream.StreamScan$class.convertToInternalRow(StreamScan.scala:48)
= at org.apache.flink.table.plan.nodes.datastream.StreamTab= leSourceScan.convertToInternalRow(StreamTableSourceScan.scala:35)
at org.apache.flink.table.plan.nodes.datastream.St= reamTableSourceScan.translateToPlan(StreamTableSourceScan.scala:<= wbr>107)

You can check the sou= rce code here:
=C2=A0

Z pozdrowienia= mi! / Cheers!


Dawid Wysakowicz

Skype: dawid_wys | Twitter: @OneMoreCoder


--089e0820496052878405518b036a--