From user-zh-return-2967-archive-asf-public=cust-asf.ponee.io@flink.apache.org Thu Apr 16 02:54:25 2020 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 4BEED18066D for ; Thu, 16 Apr 2020 04:54:25 +0200 (CEST) Received: (qmail 61988 invoked by uid 500); 16 Apr 2020 02:54:12 -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 61903 invoked by uid 99); 16 Apr 2020 02:54:11 -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; Thu, 16 Apr 2020 02:54:11 +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 D41DBC1D07 for ; Thu, 16 Apr 2020 02:54:08 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.817 X-Spam-Level: X-Spam-Status: No, score=-0.817 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, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.818, SPF_HELO_NONE=0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-ec2-va.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id U29L9KEdZvB2 for ; Thu, 16 Apr 2020 02:54:05 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.219.43; helo=mail-qv1-f43.google.com; envelope-from=libenchao@gmail.com; receiver= Received: from mail-qv1-f43.google.com (mail-qv1-f43.google.com [209.85.219.43]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTPS id DE5C0BB976 for ; Thu, 16 Apr 2020 02:54:04 +0000 (UTC) Received: by mail-qv1-f43.google.com with SMTP id di6so1331504qvb.10 for ; Wed, 15 Apr 2020 19:54:04 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to; bh=FLuYmOxgCbibWstEHS/pjZKaUV3nkD4CwGShxA/mxhE=; b=bLS03okSEE73t+7CBZcn1PjuPAAiCIEsAIie+EVPJ3OJxSA0oOoqLUzESCSo7fygvt f2wUqR8/taJPsbigQoxCYcjRq5WvRWqgGGhNGdnxync2tW7koJDlZyuyxtavAa8F48Fl D6YnifMbijZtMv+JoK+wH4VPeG/XVDm8FELLV5vjfrUjpH5lqpp/NjUWJhrKleg+WZGA +h3lDsK2EFtimwUZd9nnAnYXu6WCYi5ctFWWQb/+OvaM/klbgkBIco0aVNecHeYap0/8 WvSvaapErB6cHPNvHYOQLPgr9fPzesEEq5n7SXAoFxfCUc0tOOvyXU5njtVOYxHHhmaV 9PAA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to; bh=FLuYmOxgCbibWstEHS/pjZKaUV3nkD4CwGShxA/mxhE=; b=tYzV5QCnSPBRIgGpOYfKpenpMGa6QBPQhV5t+Bn45B6asY0CJPWDttASs0OxIs+02L BEMKOsUjeGRMpedyGLqY0EPVigaj0jgcQyXa6GwnTOhoOwzkAvt9EqaalGkYgmjrPZi4 T9BjDl67r5TYKIMQM8jbY2m1s1WqpkIiT1eQQJhRF0eBBYktchNPnHokE2B1HN3GrFDe ce6MQyLYIHAj5iFmYcVG1PW7GoS9Yr4qBDOEBE9l9VqAfr99pWW09lNr4FQA4j1Wu+ab xNRlic9le6wlySaan9I4+MraRsxFlWR2IWYafX31sNPdT8s0VqhO/3bwqtwInXZK1Wk0 dT6A== X-Gm-Message-State: AGi0PuZ0O6jwC4HzD5f+sgzGIfFu7SGObipDJ4fwpHH6+FrjiH7imPN2 vX6AhblSK6i9lLZkOdZ1Njar+PZ2K6XAQgoWmvQIpnOKlOA= X-Google-Smtp-Source: APiQypIv+GN9rzPXFdjGFz7pmsN9nxsKKZKfeShtIjLvFjIMMqqqwY5mJF2AbPelHDQFhikwWWyxckBo8pPSdmyA14k= X-Received: by 2002:a05:6214:18c1:: with SMTP id cy1mr8258476qvb.142.1587005637610; Wed, 15 Apr 2020 19:53:57 -0700 (PDT) MIME-Version: 1.0 References: <202004151948226782561@163.com> <34627b4d.d30e.1717df497f3.Coremail.xinghalo@163.com> <6191fb24.504.1718059dc16.Coremail.xinghalo@163.com> <2aa79182.545.171805d9b05.Coremail.xinghalo@163.com> <408aeb94.16cd.17180e10f2e.Coremail.xinghalo@163.com> In-Reply-To: <408aeb94.16cd.17180e10f2e.Coremail.xinghalo@163.com> From: Benchao Li Date: Thu, 16 Apr 2020 10:53:46 +0800 Message-ID: Subject: =?UTF-8?B?UmU6IGZsaW5rLTEuMTAtc3FsIOe7tOihqOmXrumimA==?= To: user-zh Content-Type: multipart/alternative; boundary="00000000000049538f05a35f8b3e" --00000000000049538f05a35f8b3e Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable https://issues.apache.org/jira/browse/FLINK-16068 https://issues.apache.org/jira/browse/FLINK-16345 =E4=B8=8A=E9=9D=A2=E8=BF=99=E4=B8=A4=E4=B8=AAissue=E7=9A=84=E4=BF=AE=E6=94= =B9=E9=83=BD=E5=8A=A0=E5=88=B0=E4=BA=861.10=E4=B8=8A=E4=BA=86=E4=B9=88=EF= =BC=9F=E5=A6=82=E6=9E=9C=E6=98=AF=E7=9A=84=E8=AF=9D=EF=BC=8C=E9=82=A3=E8=BF= =99=E5=8F=AF=E8=83=BD=E6=98=AF=E8=BF=98=E6=9C=89=E5=85=B6=E4=BB=96=E7=9A=84= bug=E3=80=82 =E5=A6=82=E6=9E=9C=E4=BD=A0=E5=8F=AF=E4=BB=A5=E5=9C=A81.10=E5=92=8C=E6=88= =96=E8=80=85master=E5=88=86=E6=94=AF=E7=9A=84=E6=9C=80=E6=96=B0=E4=BB=A3=E7= =A0=81=E4=B8=8A=E5=A4=8D=E7=8E=B0=E8=BF=99=E4=B8=AA=E9=97=AE=E9=A2=98=E7=9A= =84=E8=AF=9D=EF=BC=8C=E5=8F=AF=E4=BB=A5=E5=BB=BA=E4=B8=80=E4=B8=AAissue=E6= =9D=A5=E8=B7=9F=E8=B8=AA=E4=B8=8B=E8=BF=99=E4=B8=AA=E9=97=AE=E9=A2=98=E3=80= =82 111 =E4=BA=8E2020=E5=B9=B44=E6=9C=8816=E6=97=A5=E5=91=A8= =E5=9B=9B =E4=B8=8A=E5=8D=8810:46=E5=86=99=E9=81=93=EF=BC=9A > Hi, > =E5=9F=BA=E4=BA=8E1.10 =E6=BA=90=E7=A0=81=E6=8C=89=E7=85=A7jira=E9=87=8C= =E9=9D=A2=E7=9A=84PR=E4=BF=AE=E6=94=B9=E4=B8=8D=E8=A1=8C=E4=B9=88=EF=BC=9F > =E8=B7=9Fhbase=E7=9A=84ddl=E5=85=B3=E7=B3=BB=E5=BA=94=E8=AF=A5=E4=B8=8D= =E5=A4=A7=EF=BC=8C=E5=B0=B1=E5=8F=91=E4=B8=80=E4=B8=AAkafka=E7=9A=84=E5=90= =A7=E3=80=82 > > > //=E4=BB=A3=E7=A0=81=E5=8D=A0=E4=BD=8D=E7=AC=A6 > Flink SQL> CREATE TABLE kafka_test1 ( > //=E4=BB=A3=E7=A0=81=E5=8D=A0=E4=BD=8D=E7=AC=A6 > Flink SQL> CREATE TABLE kafka_test1 ( > > id varchar, > > a varchar, > > b int, > > ts as PROCTIME() > > ) WITH ( > > 'connector.type' =3D 'kafka', > > 'connector.version' =3D '0.11', > > 'connector.topic' =3D 'test', > > 'connector.properties.zookeeper.connect' =3D 'localnode2:2181', > > 'connector.properties.bootstrap.servers' =3D 'localnode2:9092', > > 'connector.properties.group.id' =3D 'testGroup', > > 'connector.startup-mode' =3D 'latest-offset', > > 'format.type' =3D 'json' > > ) > > ; > [INFO] Table has been created. > > > Flink SQL> select a.*,b.* from kafka_test1 a join hbase_test1 FOR > SYSTEM_TIME AS OF a.ts as b on a.id =3D b.rowkey; > > > =E5=BC=82=E5=B8=B8=E4=BF=A1=E6=81=AF=EF=BC=9A > //=E4=BB=A3=E7=A0=81=E5=8D=A0=E4=BD=8D=E7=AC=A6 > [ERROR] Could not execute SQL statement. Reason: > java.lang.AssertionError: Conversion to relational algebra failed to > preserve datatypes: > validated type: > RecordType(VARCHAR(2147483647) CHARACTER SET "UTF-16LE" id, > VARCHAR(2147483647) CHARACTER SET "UTF-16LE" a, INTEGER b, TIMESTAMP(3) N= OT > NULL ts, VARCHAR(2147483647) CHARACTER SET "UTF-16LE" rowkey, > RecordType:peek_no_expand(VARCHAR(2147483647) CHARACTER SET "UTF-16LE" a, > INTEGER b) f) NOT NULL > converted type: > RecordType(VARCHAR(2147483647) CHARACTER SET "UTF-16LE" id, > VARCHAR(2147483647) CHARACTER SET "UTF-16LE" a, INTEGER b, TIME > ATTRIBUTE(PROCTIME) NOT NULL ts, VARCHAR(2147483647) CHARACTER SET > "UTF-16LE" rowkey, RecordType:peek_no_expand(VARCHAR(2147483647) CHARACTE= R > SET "UTF-16LE" a, INTEGER b) f) NOT NULL > rel: > LogicalProject(id=3D[$0], a=3D[$1], b=3D[$2], ts=3D[$3], rowkey=3D[$4], f= =3D[$5]) > LogicalCorrelate(correlation=3D[$cor1], joinType=3D[inner], > requiredColumns=3D[{0, 3}]) > LogicalProject(id=3D[$0], a=3D[$1], b=3D[$2], ts=3D[PROCTIME()]) > LogicalTableScan(table=3D[[tgou, collie, kafka_test1, source: > [Kafka011TableSource(id, a, b)]]]) > LogicalFilter(condition=3D[=3D($cor1.id, $0)]) > LogicalSnapshot(period=3D[$cor1.ts]) > LogicalTableScan(table=3D[[tgou, collie, hbase_test1, source: > [HBaseTableSource[schema=3D[rowkey, f], projectFields=3Dnull]]]]) > > > Best, > Xinghalo --=20 Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: libenchao@gmail.com; libenchao@pku.edu.cn --00000000000049538f05a35f8b3e--