From user-zh-return-1294-archive-asf-public=cust-asf.ponee.io@flink.apache.org Sat Oct 12 07:17:49 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id BA4B3180608 for ; Sat, 12 Oct 2019 09:17:48 +0200 (CEST) Received: (qmail 73047 invoked by uid 500); 12 Oct 2019 07:17:47 -0000 Mailing-List: contact user-zh-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user-zh@flink.apache.org Delivered-To: mailing list user-zh@flink.apache.org Received: (qmail 73035 invoked by uid 99); 12 Oct 2019 07:17:45 -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; Sat, 12 Oct 2019 07:17:45 +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 57E3CC0B58 for ; Sat, 12 Oct 2019 07:17:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.049 X-Spam-Level: X-Spam-Status: No, score=0.049 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=qq.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id EMvU00xdbsMV for ; Sat, 12 Oct 2019 07:17:43 +0000 (UTC) Received: from smtpbgsg2.qq.com (smtpbgsg2.qq.com [54.254.200.128]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 7890A5F41C for ; Sat, 12 Oct 2019 07:17:41 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=qq.com; s=s201512; t=1570864651; bh=qKTghtFnzlFhc1GOelLSCkOIq6mPWCrbl6zCQL1lsd4=; h=Mime-Version:Subject:From:Date:Message-Id:To; b=ljEHubmIH04W0snkGxgzBsEoMHL635yv4zc/YxpEnL4bDePQRKLec0as7QiELLJPc 53sMYtNDBTh2HUPM33mKlVTIfG83QOFjQcfxyA2Gf52xE/v8F6R8PRYg2aBfc5tnHf tGD5PAXulVrdk+U40w/ytTQPppSUl5uJq1hrhhbU= X-QQ-mid: esmtp7t1570864649t7gw13x1m Received: from [10.107.99.161] (unknown [112.65.125.218]) by esmtp4.qq.com (ESMTP) with SMTP id 0 for ; Sat, 12 Oct 2019 15:17:28 +0800 (CST) X-QQ-SSF: 00000000000000W0UF100F00000000Y X-QQ-FEAT: 8oHFcAoL8WOkzAvm6cI+yznNgqRnqeLlSuzrbe24qvqtRlOroEjmfLEOx9vHe 0rSy0KLPgd3/OAO5x7AjWK8uLXyMCADBR3TQWXmoK7WGAx+YyWDJSFp2Y35ygy5bAzokoc9 KU1+Ys1UqtRTSkbcTzPhHP/j1Pqy1j69B/kvAohHiSZlbDqkTv67r+cEVROfYZs9Tpcq+Ca UQ0LNF9vxcZdyE6TGsNesOU4L8A+9nQF+u4nhBGihvYvvyRDGbIgT9AP5ofQDwt0pvsBIuq vGbhIBAyepspsfhTSsCSpVwUeZNmuEFCYVx5GznpG4jO4ofVxXkkYXjZp1/iPmyQpXRg== X-QQ-GoodBg: 0 Content-Type: text/plain; charset=gb2312 Mime-Version: 1.0 (Mac OS X Mail 12.4 \(3445.104.11\)) Subject: =?gb2312?B?UmU6IMq508NmbGluay1zcWzKtc/WbXlzcWzOrLHttcRqb2lutcRk?= =?gb2312?B?ZGy6zWRtbLXEyr7B0A==?= From: yelun <986463030@qq.com> X-Priority: 3 In-Reply-To: <005AC2E1-F1D1-4AF7-93A0-FE4D7F32732A@qq.com> Date: Sat, 12 Oct 2019 15:17:28 +0800 Content-Transfer-Encoding: quoted-printable Message-Id: <3E915D8D-C0ED-4470-B697-7427A73943EE@qq.com> References: <005AC2E1-F1D1-4AF7-93A0-FE4D7F32732A@qq.com> To: user-zh@flink.apache.org X-Mailer: Apple Mail (2.3445.104.11) X-QQ-SENDSIZE: 520 Feedback-ID: esmtp:qq.com:bgforeign:bgforeign2 X-QQ-Bgrelay: 1 =C7=EB=CE=CA=D5=E2=D6=D6=B4=B4=BD=A8dimtable ddl=B7=BD=CA=BD=D4=DAflink = sql-client=B5=C4=BF=C9=D2=D4=D0=B4=C2=F0=A3=AC=BB=F2=D5=DF=D4=DA=D7=A2=B2=E1= =D2=BB=B8=F6catalog,=D0=BB=D0=BB=A1=A3 > =D4=DA 2019=C4=EA10=D4=C212=C8=D5=A3=AC=CF=C2=CE=E72:12=A3=ACyelun = <986463030@qq.com> =D0=B4=B5=C0=A3=BA >=20 > =CE=D2=CA=D4=C1=CB=D2=BB=CF=C2=D4=C6=D0=B0=B4=F3=C0=D0=B5=C4=B7=BD=B7=A8= =CA=C7=BF=C9=D2=D4=B5=C4 >=20 >> =D4=DA 2019=C4=EA10=D4=C212=C8=D5=A3=AC=C9=CF=CE=E79:16=A3=AC=D3=AD=B7=E7= =C0=CB=D7=D3 <576637834@qq.com> =D0=B4=B5=C0=A3=BA >>=20 >> select *, PROCTIME() as proctime from source =B1=A8=D2=EC=B3=A3SQL = parse failed. Encountered ")" at ...  >> PROCTIME ()=D5=E2=B7=BD=B7=A8=BA=C3=CF=F1=B2=BB=D6=A7=B3=D6=A1=A3 >>=20 >>=20 >>=20 >> ---=D4=AD=CA=BC=D3=CA=BC=FE--- >> =B7=A2=BC=FE=C8=CB: "Jark Wu"> =B7=A2=CB=CD=CA=B1=BC=E4: 2019=C4=EA10=D4=C211=C8=D5(=D0=C7=C6=DA=CE=E5= ) =CD=ED=C9=CF7:23 >> =CA=D5=BC=FE=C8=CB: "user-zh"> =D6=F7=CC=E2: Re: =CA=B9=D3=C3flink-sql=CA=B5=CF=D6mysql=CE=AC=B1=ED=B5= =C4join=B5=C4ddl=BA=CDdml=B5=C4=CA=BE=C1=D0 >>=20 >>=20 >> =C4=BF=C7=B0 o.proctime =D4=DA DDL =D4=DD=CA=B1=BB=B9=C9=F9=C3=F7=B2=BB= =C1=CB=A3=AC=B2=BB=BF=C9=D2=D4=BF=C9=D2=D4=CA=B9=D3=C3=C7=B6=CC=D7 query = =C9=FA=B3=C9=D2=BB=B8=F6 proctime =D7=D6=B6=CE=A1=A3 >>=20 >> "select ... >>  from (select *, PROCTIME() as proctime from source)" >>=20 >> On Fri, 11 Oct 2019 at 18:45, =D3=AD=B7=E7=C0=CB=D7=D3 = <576637834@qq.com> wrote: >>=20 >> > =C7=EB=CE=CAsql ddl=C8=E7=BA=CE=B6=A8=D2=E5o.proctime=C4=D8=A3=BF >> > >> > >> > >> > ---=D4=AD=CA=BC=D3=CA=BC=FE--- >> > =B7=A2=BC=FE=C8=CB: "Jark Wu"> > =B7=A2=CB=CD=CA=B1=BC=E4: 2019=C4=EA9=D4=C229=C8=D5(=D0=C7=C6=DA=C8= =D5) =D6=D0=CE=E711:42 >> > =CA=D5=BC=FE=C8=CB: "user-zh"> > =D6=F7=CC=E2: Re: = =CA=B9=D3=C3flink-sql=CA=B5=CF=D6mysql=CE=AC=B1=ED=B5=C4join=B5=C4ddl=BA=CD= dml=B5=C4=CA=BE=C1=D0 >> > >> > >> > Hi, >> > >> > mysql =CE=AC=B1=ED=B5=C4 DDL =BA=CD =D4=B4=B1=ED/=BD=E1=B9=FB=B1=ED= =B5=C4 DDL =CA=C7=D2=BB=D1=F9=B5=C4=A1=A3 =C0=FD=C8=E7=CF=C2=C3=E6=D5=E2=B8= =F6 DDL =B5=C4=C9=F9=C3=F7=A3=ACrates =D4=DA flink sql =D6=D0=BC=C8=BF=C9=D2= =D4=D7=F7=CE=AA >> > source =D2=B2=BF=C9=D2=D4=CA=C7 sink=A3=AC=D2=B2=BF=C9=D2=D4=CA=C7= =CE=AC=B1=ED=A1=A3 >> > >> > CREATE TABLE rates ( >> > &nbsp;&nbsp;&nbsp; currency VARCHAR, >> > &nbsp;&nbsp;&nbsp; rate BIGINT >> > ) WITH ( >> > &nbsp;&nbsp;&nbsp; 'connector.type' =3D 'jdbc', -- = =CA=B9=D3=C3 jdbc connector >> > &nbsp;&nbsp;&nbsp; 'connector.url' =3D >> > 'jdbc:mysql://localhost:3306/flink-test', -- jdbc url >> > &nbsp;&nbsp;&nbsp; 'connector.table' =3D 'rates', -- = =B1=ED=C3=FB >> > &nbsp;&nbsp;&nbsp; 'connector.username' =3D 'root', = -- =D3=C3=BB=A7=C3=FB >> > &nbsp;&nbsp;&nbsp; 'connector.password' =3D = '123456', -- =C3=DC=C2=EB >> > ) >> > >> > =C8=E7=B9=FB=D2=AA=D3=C3=CB=FC=D7=F7=CE=AA=CE=AC=B1=ED=B5=C4=BB=B0= =A3=AC=C4=C7=C3=B4=D0=E8=D2=AA=D3=C3=B5=BD temporal join =B5=C4=D3=EF=B7=A8= =A1=A3=C8=E7=A3=BA >> > >> > SELECT >> > &nbsp; o.amout, o.currency, r.rate, o.amount * r.rate >> > FROM >> > &nbsp; Orders AS o >> > &nbsp; JOIN rates FOR SYSTEM_TIME AS OF o.proctime AS r >> > &nbsp; ON r.currency =3D o.currency >> > >> > &nbsp;=B9=D8=D3=DA=CE=AC=B1=ED join=A3=AC=BF=C9=D2=D4=B2=E9=BF= =B4=B9=D9=B7=BD=CE=C4=B5=B5=A3=BA >> > >> > = https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming= /joins.html#join-with-a-temporal-table >> > >> > >> > >> > >> > On Fri, 27 Sep 2019 at 14:12, yelun <986463030@qq.com&gt; = wrote: >> > >> > &gt; Hi=A3=AC=B8=F7=CE=BB=B4=F3=C0=D0=A3=BA >> > &gt; >> > &gt; = =D3=D0=C3=BB=D3=D0=CA=B9=D3=C3flink-sql=CA=B5=CF=D6mysql=CE=AC=B1=ED=B5=C4= join=B5=C4ddl=BA=CDdml=B5=C4=CA=BE=C1=D0=B5=C4demo=C4=DC=B9=BB=B2=CE=BF=BC= =D2=BB=CF=C2=A3=AC=B7=C7=B3=A3=B8=D0=D0=BB=A1=A3 >=20 >=20