From user-zh-return-3129-archive-asf-public=cust-asf.ponee.io@flink.apache.org Thu Apr 23 03:53:57 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 317A4180181 for ; Thu, 23 Apr 2020 05:53:57 +0200 (CEST) Received: (qmail 82346 invoked by uid 500); 23 Apr 2020 03:53:55 -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 82296 invoked by uid 99); 23 Apr 2020 03:53:55 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Apr 2020 03:53:55 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 59B431A32EC for ; Thu, 23 Apr 2020 03:53:54 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.2 X-Spam-Level: X-Spam-Status: No, score=0.2 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=akulaku-com.20150623.gappssmtp.com Received: from mx1-ec2-va.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id b2go76exiitz for ; Thu, 23 Apr 2020 03:53:51 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.166.172; helo=mail-il1-f172.google.com; envelope-from=zhangyu@akulaku.com; receiver= Received: from mail-il1-f172.google.com (mail-il1-f172.google.com [209.85.166.172]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTPS id 31D43BB94E for ; Thu, 23 Apr 2020 03:53:51 +0000 (UTC) Received: by mail-il1-f172.google.com with SMTP id s10so4200850iln.11 for ; Wed, 22 Apr 2020 20:53:50 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=akulaku-com.20150623.gappssmtp.com; s=20150623; h=mime-version:references:in-reply-to:from:date:message-id:subject:to; bh=w0dmSoWQccrYLGO+6CxBLV/rIPk2aoRmwFr7iL5zAOc=; b=dA/OY+qhnGSVsgo2ouu+Xw9WAV+ioYLm9rZIbDauulBsxT080fRrvvEdmeJzSOcwPL R6ptTwuD42QkgtCm3LwvR4IRwItW4BqaCZo+vnRXuVosEzv7LehT8nmrD4YE/6HiSOI5 6/NQ4kIsZrq7AqHQXPbYKegMgBXZ81KW2CO5ipGKkVa1bLozgd78WNADKQ3NIPvLdLJV 0azzbkPiOAXB8c7cqzmKDAIQouLd+IJM+gwRMuWlUFOyvcEz+VyV6nbFHaWSosS89z+3 rZ38nehFpqbI7QouQOi8dwAI8eejAdnCKVP018pG6mKiyU1r48FqWVjwIFLT/i0OdFIO JZHQ== 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=w0dmSoWQccrYLGO+6CxBLV/rIPk2aoRmwFr7iL5zAOc=; b=dqmVbwGBwRGa2gvVb1spRqYXGBl+Z2cLcjASQlUkLF+CDs0NK3QZSItU86KwlxhAfx NVsqTYavQRhS2BipZPZDl13+Inlf0qRIDGbd6l+VM8mbsOzH/ZP7exIKADoJq/wz13gj nzWykU7U50tIEshi7cNQVYlKbKFWvQCcZ8Ry3SEhiwdIS3ty/liPDjA0t2H5XtGb+mZe guD2xaBQRJ0kry0mCfqcUYihHzfx5tR19wxjXYzQpVYM0oFSMo+jasHWcko/yCGTzqwm OfDCGkfGcAYXHKUsOgSyC8WauEjRnPVAMcSYI5D7BfICzHyjna+9nuYv4iKvy8MIgjap CNYw== X-Gm-Message-State: AGi0PuaRBDkazoxLja3UBgIMWo/d/aFUoAfPNM2NsSaNV3PVe37kuQgH V7ZI7aYvWdG51XRshw0rDUyrm6OOQPSQ3ILJ4ZZfz9tDu1Q= X-Google-Smtp-Source: APiQypJ0oVwq5+J3KzQ7wz5G92qYlTcrXfW2GPW1UfG7C98BT8soha7SWmbSjxGFyXgJt2dESfgU7Jg4mXCsfZfCAGU= X-Received: by 2002:a92:7e4a:: with SMTP id z71mr1630623ilc.83.1587614030254; Wed, 22 Apr 2020 20:53:50 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: =?UTF-8?B?5a6H5byg?= Date: Thu, 23 Apr 2020 11:53:39 +0800 Message-ID: Subject: =?UTF-8?B?UmU6IOWFs+S6jkZsaW5rMS4xMCBTdGFuZGFsb25lIOaooeW8j+S7u+WKoeaPkOS6pA==?= To: user-zh@flink.apache.org Content-Type: multipart/alternative; boundary="00000000000050688f05a3ed32ff" --00000000000050688f05a3ed32ff Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable =E4=BD=A0=E7=9A=84=E6=84=8F=E6=80=9D=E6=98=AF=EF=BC=8CUberJar =E4=B8=8D=E6= =94=BE=E5=9C=A8 lib =E9=87=8C=EF=BC=8C=E5=9C=A8=E7=94=A8=E6=88=B7=E7=A8=8B= =E5=BA=8F=E9=87=8C=E9=80=9A=E8=BF=87=E7=BA=BF=E7=A8=8B=E4=B8=8A=E4=B8=8B=E6= =96=87 ClassLoader =E8=83=BD=E5=8A=A0=E8=BD=BD=E5=88=B0 KafkaTableSourceSinkFactory =E5=90=97=EF=BC=9F=EF=BC=88=E5=90=8C=E6=97=B6 class loading =E4=B8=BA child= -first=EF=BC=89 =E3=80=8B=E3=80=8B=E6=98=AF=E7=9A=84 On Thu, Apr 23, 2020 at 11:42 AM tison wrote: > >=E3=80=8B=E6=8B=BF=E5=88=B0ClassLoader=E5=90=8E=E7=9C=8B=E4=B8=8B=E8=83= =BD=E4=B8=8D=E8=83=BD=E5=8F=96=E5=88=B0KafkaTableSourceSinkFactory=E7=9A=84= class > >=E8=BF=99=E4=B8=AA=E8=83=BD=E6=8B=BF=E5=88=B0 > > =E4=BD=A0=E7=9A=84=E6=84=8F=E6=80=9D=E6=98=AF=EF=BC=8CUberJar =E4=B8=8D= =E6=94=BE=E5=9C=A8 lib =E9=87=8C=EF=BC=8C=E5=9C=A8=E7=94=A8=E6=88=B7=E7=A8= =8B=E5=BA=8F=E9=87=8C=E9=80=9A=E8=BF=87=E7=BA=BF=E7=A8=8B=E4=B8=8A=E4=B8=8B= =E6=96=87 ClassLoader =E8=83=BD=E5=8A=A0=E8=BD=BD=E5=88=B0 > KafkaTableSourceSinkFactory > =E5=90=97=EF=BC=9F=EF=BC=88=E5=90=8C=E6=97=B6 class loading =E4=B8=BA chi= ld-first=EF=BC=89 > > =E5=A6=82=E6=9E=9C=E6=98=AF=E8=BF=99=E6=A0=B7=EF=BC=8C=E5=90=AC=E8=B5=B7= =E6=9D=A5 client =E7=9A=84 classloading =E7=AD=96=E7=95=A5=E6=B2=A1=E5=95= =A5=E9=97=AE=E9=A2=98=EF=BC=8C=E4=BC=BC=E4=B9=8E=E6=98=AF SPI =E5=8A=A0=E8= =BD=BD=E9=82=A3=E8=BE=B9=E7=9A=84 ClassLoader =E6=9C=89=E9=97=AE=E9=A2=98= =E3=80=82=E4=B9=8B=E5=89=8D > FileSystem =E7=9B=B8=E5=85=B3=E8=A7=A3=E6=9E=90=E5=B0=B1=E5=87=BA=E8=BF= =87=E7=B1=BB=E4=BC=BC=E7=9A=84 ClassLoader =E7=9A=84 BUG > > Best, > tison. > > > =E5=AE=87=E5=BC=A0 =E4=BA=8E2020=E5=B9=B44=E6=9C=88= 23=E6=97=A5=E5=91=A8=E5=9B=9B =E4=B8=8A=E5=8D=8811:36=E5=86=99=E9=81=93=EF= =BC=9A > > > =E6=88=91=E5=B0=9D=E8=AF=95=E8=BF=9B=E8=A1=8C=E4=BA=86=E6=B7=BB=E5=8A= =A0=EF=BC=8C=E7=A8=8B=E5=BA=8F=E4=BE=9D=E7=84=B6=E6=97=A0=E6=B3=95=E8=BF=90= =E8=A1=8C=EF=BC=8C=E5=BC=82=E5=B8=B8=E4=BF=A1=E6=81=AF=E5=92=8C=E4=B8=8A=E9= =9D=A2=E4=B8=80=E8=87=B4=EF=BC=8C=E4=B8=8B=E9=9D=A2=E6=98=AF=E6=88=91=E7=9A= =84shade=E9=85=8D=E7=BD=AE=EF=BC=9A > > > > > > org.apache.maven.plugins > > maven-shade-plugin > > > > > > > > package > > > > shade > > > > > > > > > > > > > > implementation=3D"org.apache.maven.plugins.shade.resource.ManifestResourc= eTransformer"> > > > > com.akulaku.data.main.StreamMain > > > > > > > > > > > > *:* > > > > META-INF/*.SF > > META-INF/*.DSA > > META-INF/*.RSA > > > > > > > > > > > > > > > > > > org.apache.flink:flink-table-common > > > > org.apache.flink:flink-table-api-java > > > > org.apache.flink:flink-table-api-java-bridge_2.11 > > > > org.apache.flink:flink-table-planner-blink_2.11 > > > > org.apache.flink:flink-connector-kafka-0.11_2.11 > > > > org.apache.flink:flink-connector-kafka-base_2.11 > > org.apache.flink:flink-json > > > > > > > > > > > > com.ibm.icu > > > > org.apache.flink.table.shaded.com.ibm.icu > > > > > > > > > > > > > > > > > > On Thu, Apr 23, 2020 at 10:53 AM Jingsong Li > > wrote: > > > > > Hi, > > > > > > Flink=E7=9A=84connector=E5=8F=91=E7=8E=B0=E6=9C=BA=E5=88=B6=E6=98=AF= =E9=80=9A=E8=BF=87java > spi=E6=9C=8D=E5=8A=A1=E5=8F=91=E7=8E=B0=E6=9C=BA=E5=88=B6=E7=9A=84=EF=BC= =8C=E6=89=80=E4=BB=A5=E4=BD=A0=E7=9A=84services=E4=B8=8B=E6=96=87=E4=BB=B6= =E4=B8=8D=E5=8C=85=E5=90=ABKafka=E7=9B=B8=E5=85=B3=E7=9A=84=E5=86=85=E5=AE= =B9=E5=B0=B1=E4=B8=8D=E4=BC=9A=E5=8A=A0=E8=BD=BD=E5=88=B0=E3=80=82 > > > > > > > =E8=80=8C=E4=B8=94=E4=B8=A4=E7=A7=8D=E6=89=93=E5=8C=85=E6=96=B9=E5= =BC=8F=E8=BF=90=E8=A1=8C=E6=97=B6=E6=98=AF=E9=83=BD=E8=83=BD=E5=8A=A0=E8=BD= =BD=E5=88=B0KafkaFactory=E7=B1=BB=E6=96=87=E4=BB=B6=E7=9A=84 > > > > > > =E5=8F=AA=E6=98=AF=E7=B1=BB=E6=96=87=E4=BB=B6=E6=98=AF=E6=B2=A1=E6=9C= =89=E7=94=A8=E7=9A=84=EF=BC=8C=E6=B2=A1=E5=9C=B0=E6=96=B9=E5=BC=95=E7=94=A8= =E5=88=B0=E5=AE=83=E3=80=82 > > > > > > =E4=BD=A0=E8=AF=95=E8=AF=95[1]=E4=B8=AD=E7=9A=84=E6=96=B9=E6=B3=95=EF= =BC=9F=E6=B7=BB=E5=8A=A0combine.children > > > > > > [1] > > > > > > > > > https://github.com/apache/flink/blob/master/flink-table/flink-table-uber-= blink/pom.xml#L104 > > > > > > Best, > > > Jingsong Lee > > > > > > On Thu, Apr 23, 2020 at 10:37 AM =E5=AE=87=E5=BC=A0 wrote: > > > > > > > > > > > > > > > > > =E6=88=91=E8=BF=99=E9=9D=A2=E9=87=87=E7=94=A8shade=E6=89=93=E5=8C=85=E6= =96=B9=E5=BC=8F=E8=BF=9B=E8=A1=8C=E4=BA=86=E5=B0=9D=E8=AF=95=EF=BC=8C=E5=8F= =91=E7=8E=B0=E4=BE=9D=E7=84=B6=E8=BF=90=E8=A1=8C=E5=87=BA=E9=94=99=EF=BC=8C= =E8=BF=90=E8=A1=8C=E9=94=99=E8=AF=AF=E6=97=A5=E5=BF=97=E4=B8=8Eassembly=E6= =89=93=E5=8C=85=E4=BA=A7=E7=94=9F=E7=9A=84=E9=94=99=E8=AF=AF=E6=97=A5=E5=BF= =97=E4=B8=80=E8=87=B4=EF=BC=8C=E5=B0=B1=E6=98=AF=E4=B8=8A=E9=9D=A2=E6=8F=90= =E5=88=B0=E7=9A=84=E9=94=99=E8=AF=AF=EF=BC=8C=E8=80=8C=E4=B8=94shade=E5=92= =8Cassembly=E6=89=93=E5=8C=85=E4=BA=A7=E7=94=9F=E7=9A=84 > > > > > > > > > > > > > > META-INF/services/org.apache.flink.table.factories.TableFactory=E6=96=87= =E4=BB=B6=E5=8F=8A=E9=87=8C=E9=9D=A2=E7=9A=84=E5=86=85=E5=AE=B9=E4=B8=80=E8= =87=B4=EF=BC=8C=E8=80=8C=E4=B8=94=E4=B8=A4=E7=A7=8D=E6=89=93=E5=8C=85=E6=96= =B9=E5=BC=8F=E8=BF=90=E8=A1=8C=E6=97=B6=E6=98=AF=E9=83=BD=E8=83=BD=E5=8A=A0= =E8=BD=BD=E5=88=B0KafkaFactory=E7=B1=BB=E6=96=87=E4=BB=B6=E7=9A=84=EF=BC=8C= =E6=89=80=E4=BB=A5=E8=B2=8C=E4=BC=BC=E4=B8=8D=E6=98=AF=E6=89=93=E5=8C=85=E5= =AF=BC=E8=87=B4=E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=8C=E8=80=8C=E6=9B=B4=E5=83= =8F=E6=98=AFbug > > > > =E4=B8=8B=E9=9D=A2=E6=98=AF=E6=88=91maven=E6=8F=92=E4=BB=B6=E9=85= =8D=E7=BD=AE=EF=BC=9A > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > org.apache.maven.plugins > > > > maven-shade-plugin > > > > > > > > > > > > > > > > package > > > > > > > > shade > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > implementation=3D"org.apache.maven.plugins.shade.resource.ManifestResourc= eTransformer"> > > > > > > > > com.akulaku.data.main.StreamMain > > > > > > > > > > > > > > > > > > > > > > > > *:* > > > > > > > > META-INF/*.SF > > > > META-INF/*.DSA > > > > META-INF/*.RSA > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Wed, Apr 22, 2020 at 8:00 PM Jingsong Li > > > > wrote: > > > > > > > > > Hi, > > > > > > > > > > > > > > > > > > > > > > > > > =E5=A6=82=E6=9E=9Corg.apache.flink.table.factories.TableFactory=E9=87=8C= =E9=9D=A2=E6=B2=A1=E6=9C=89KafkaTableSourceSinkFactory=EF=BC=8C=E9=82=A3=E5= =B0=B1=E6=98=AF=E6=89=93=E5=8C=85=E6=9C=89=E9=97=AE=E9=A2=98=E3=80=82=E4=B8= =8D=E6=B8=85=E6=A5=9A1.9=E7=9A=84=E6=98=AF=E6=80=8E=E4=B9=88=E8=BF=90=E8=A1= =8C=E8=B5=B7=E6=9D=A5=E7=9A=84=EF=BC=8C=E4=BD=86=E6=98=AF=E6=89=80=E6=9C=89= =E7=9A=84jar=E7=9A=84meta-inf-services=E6=96=87=E4=BB=B6=E9=83=BD=E6=B2=A1= =E6=9C=89KafkaTableSourceSinkFactory=EF=BC=8C=E9=82=A3=E4=B9=9F=E4=B8=8D=E5= =BA=94=E8=AF=A5=E8=83=BD=E8=BF=90=E8=A1=8C=E8=B5=B7=E6=9D=A5=E7=9A=84=E3=80= =82 > > > > > > > > > > =E6=8E=A8=E8=8D=90=E6=89=93=E5=8C=85=E6=96=B9=E5=BC=8F=E7=94=A8sh= ade=EF=BC=8Cshade=E4=BC=9Amerge meta-inf-services=E7=9A=84=E6=96=87=E4=BB= =B6=E7=9A=84=E3=80=82 > > > > > > > > > > Best, > > > > > Jingsong Lee > > > > > > > > > > On Wed, Apr 22, 2020 at 7:31 PM =E5=AE=87=E5=BC=A0 wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > =E3=80=8B=E4=B9=9F=E7=A1=AE=E8=AE=A4=E4=B8=8Borg.apache.flink.table.facto= ries.TableFactory=E7=9A=84=E5=86=85=E5=AE=B9=EF=BC=8C=E9=87=8C=E9=9D=A2=E6= =9C=89=E6=B2=A1=E6=9C=89KafkaTableSourceSinkFactory > > > > > > > > > > > > > > > > > > > > > > > > > > > =E8=BF=99=E4=B8=AA=E6=88=91=E7=9C=8B=E4=BA=86=E4=B8=80=E4=B8=8B=E6=88=91= =E5=85=88=E5=89=8Dflink1.9=E7=9A=84=E5=B7=A5=E7=A8=8B=EF=BC=8C=E5=BA=94=E7= =94=A8=E7=A8=8B=E5=BA=8FJar=E9=87=8C=E9=9D=A2=E4=B9=9F=E6=98=AF=E6=B2=A1=E6= =9C=89=E8=BF=99=E4=B8=AA=E7=B1=BB=E7=9A=84=EF=BC=8C=E4=BD=86=E6=98=AF=E7=A8= =8B=E5=BA=8F=E8=BF=90=E8=A1=8C=E5=8A=A0=E8=BD=BD=E6=98=AF=E6=B2=A1=E9=97=AE= =E9=A2=98=E7=9A=84=EF=BC=8C=E8=BF=99=E4=B9=88=E5=AF=B9=E6=AF=94=E8=B2=8C=E4= =BC=BC=E5=B0=B1=E4=B8=8D=E6=98=AFmaven=E6=89=93=E5=8C=85=E7=9A=84=E9=97=AE= =E9=A2=98=E4=BA=86=E3=80=82=E3=80=82=E3=80=82=E3=80=82=E3=80=82 > > > > > > > > > > > > On Wed, Apr 22, 2020 at 7:22 PM =E5=AE=87=E5=BC=A0 wrote: > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > =E3=80=8B=E4=B9=9F=E7=A1=AE=E8=AE=A4=E4=B8=8Borg.apache.flink.table.facto= ries.TableFactory=E7=9A=84=E5=86=85=E5=AE=B9=EF=BC=8C=E9=87=8C=E9=9D=A2=E6= =9C=89=E6=B2=A1=E6=9C=89KafkaTableSourceSinkFactory > > > > > > > =E8=BF=99=E4=B8=AA=E6=B2=A1=E6=9C=89=EF=BC=8C=E5=8F=AA=E6=9C= =89org.apache.flink.formats.json.JsonRowFormatFactory > > > > > > > =E3=80=8B=E6=8B=BF=E5=88=B0ClassLoader=E5=90=8E=E7=9C=8B=E4= =B8=8B=E8=83=BD=E4=B8=8D=E8=83=BD=E5=8F=96=E5=88=B0KafkaTableSourceSinkFact= ory=E7=9A=84class > > > > > > > =E8=BF=99=E4=B8=AA=E8=83=BD=E6=8B=BF=E5=88=B0 > > > > > > > > > > > > > > =E8=BF=99=E4=B9=88=E7=9C=8B=E6=9D=A5 =E8=B2=8C=E4=BC=BC=E6=98= =AF mvn=E6=89=93=E5=8C=85=E6=9C=89=E9=97=AE=E9=A2=98=EF=BC=9A > > > > > > > mvn clean package -DskipTests > > > > > > > =E4=BE=9D=E8=B5=96=E8=8C=83=E5=9B=B4=E4=B8=BA=E9=BB=98=E8=AE= =A4 > > > > > > > > > > > > > > > > > > > > > On Wed, Apr 22, 2020 at 7:05 PM Jingsong Li < > > > jingsonglee0@gmail.com> > > > > > > > wrote: > > > > > > > > > > > > > >> Hi, > > > > > > >> > > > > > > >> > > > > > > >> > > > > > > > > > > > > > > > > > > > > > =E4=B9=9F=E7=A1=AE=E8=AE=A4=E4=B8=8Borg.apache.flink.table.factories.Tabl= eFactory=E7=9A=84=E5=86=85=E5=AE=B9=EF=BC=8C=E9=87=8C=E9=9D=A2=E6=9C=89=E6= =B2=A1=E6=9C=89KafkaTableSourceSinkFactory > > > > > > >> > > > > > > >> > > > > > > > > =E8=BF=99=E4=B8=AA=E6=8C=87=E7=9A=84=E6=98=AF=E6=89=93=E5=8D=B0=E5=BD= =93=E5=89=8D=E7=BA=BF=E7=A8=8B=E7=9A=84classloader=E5=98=9BThread.currentTh= read().getContextClassLoader() > > > > > > >> =E6=98=AF=E7=9A=84=EF=BC=8C=E6=8B=BF=E5=88=B0ClassLoader=E5= =90=8E=E7=9C=8B=E4=B8=8B=E8=83=BD=E4=B8=8D=E8=83=BD=E5=8F=96=E5=88=B0KafkaT= ableSourceSinkFactory=E7=9A=84class > > > > > > >> > > > > > > >> Best, > > > > > > >> Jingsong Lee > > > > > > >> > > > > > > >> On Wed, Apr 22, 2020 at 7:00 PM =E5=AE=87=E5=BC=A0 > wrote: > > > > > > >> > > > > > > >> > =E7=9C=8B=E4=B8=8B=E4=BD=A0=E6=89=93=E5=8C=85=E7=9A=84 Ube= rJar =E9=87=8C=E6=9C=89=E6=B2=A1=E4=B8=80=E4=B8=AA=E5=86=85=E5=AE=B9=E5=8C= =85=E6=8B=AC > > > > > > >> > 1=E3=80=81=E4=B8=8B=E9=9D=A2=E8=BF=99=E4=B8=AA=E6=96=87=E4= =BB=B6=E6=98=AF=E5=AD=98=E5=9C=A8=E7=9A=84 > > > > > > >> > > > > > > > > > > org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFacto= ry > > > > > > >> > =E7=9A=84=E6=96=87=E4=BB=B6 > > > > > > >> > > > META-INF/services/org.apache.flink.table.factories.TableFactory > > > > > > >> > 2=E3=80=81flink=E7=89=88=E6=9C=AC1.10=EF=BC=8CStandalone= =E6=A8=A1=E5=BC=8F=E5=90=AF=E5=8A=A8=E6=9C=8D=E5=8A=A1=EF=BC=88start-cluste= r.sh=EF=BC=89=EF=BC=8Cflink > > > > > > >> > run=E8=BF=90=E8=A1=8C(/software/flink-1.10.0/bin/flink run= -c > > > > > com.data.main.StreamMain > > > > > > >> > ./flink_1.10_test-1.0-jar-with-dependencies.jar) > > > > > > >> > 3=E3=80=81=E5=86=8D=E7=A1=AE=E8=AE=A4=E4=B8=8B"TableEnviro= nmentImpl.sqlQuery"=E8=B0=83=E7=94=A8=E6=97=B6=E5=80=99=E7=9A=84ThreadClass= Loader=EF=BC=9F > > > > > > >> > > > > > > > > =E8=BF=99=E4=B8=AA=E6=8C=87=E7=9A=84=E6=98=AF=E6=89=93=E5=8D=B0=E5=BD= =93=E5=89=8D=E7=BA=BF=E7=A8=8B=E7=9A=84classloader=E5=98=9BThread.currentTh= read().getContextClassLoader() > > > > > > >> > > > > > > > >> > > > > > > > >> > > > > > > > >> > On Wed, Apr 22, 2020 at 6:00 PM Jingsong Li < > > > > jingsonglee0@gmail.com > > > > > > > > > > > > >> > wrote: > > > > > > >> > > > > > > > >> > > Hi, > > > > > > >> > > > > > > > > >> > > =E5=85=88=E7=A1=AE=E8=AE=A4=E4=B8=8B=E4=BD=A0=E7=9A=84Ja= r=E5=8C=85=E9=87=8C=E6=9C=89=E6=B2=A1=E6=9C=89 meta-inf-services=E7=9A=84= =E6=96=87=E4=BB=B6=EF=BC=9F=E9=87=8C=E9=9D=A2=E7=A1=AE=E5=AE=9A=E6=9C=89Kaf= ka=EF=BC=9F > > > > > > >> > > > > > > > > >> > > > > =E5=A6=82=E6=9E=9C=E6=9C=89=EF=BC=8C=E5=86=8D=E7=A1=AE=E8=AE=A4=E4=B8= =8B"TableEnvironmentImpl.sqlQuery"=E8=B0=83=E7=94=A8=E6=97=B6=E5=80=99=E7= =9A=84ThreadClassLoader? > > > > > > >> > > =E5=9B=A0=E4=B8=BA=E7=8E=B0=E5=9C=A8=E9=BB=98=E8=AE=A4= =E6=98=AF=E9=80=9A=E8=BF=87ThreadClassLoader=E6=9D=A5=E8=8E=B7=E5=8F=96Fact= ory=E7=9A=84=E3=80=82 > > > > > > >> > > > > > > > > >> > > Best, > > > > > > >> > > Jingsong Lee > > > > > > >> > > > > > > > > >> > > On Wed, Apr 22, 2020 at 5:30 PM =E5=AE=87=E5=BC=A0 > > > wrote: > > > > > > >> > > > > > > > > >> > > > =E6=88=91=E8=BF=99=E9=9D=A2=E4=BD=BF=E7=94=A8Standalon= e=E6=A8=A1=E5=BC=8F=E8=BF=90=E8=A1=8CFlink=E4=BB=BB=E5=8A=A1=EF=BC=8C=E4=BD= =86=E6=98=AFUber > > > > > > >> > > > > > > Jar=E9=87=8C=E9=9D=A2=E7=9A=84TableSourceFactory=E4=B8=8D=E8=83=BD=E8= =A2=AB=E5=8A=A0=E8=BD=BD=EF=BC=8C=E5=8D=B3=E4=BD=BF=E8=AE=BE=E7=BD=AE=E4=BA= =86classloader.resolve-order: > > > > > > >> > > > child-first=EF=BC=8C=E5=8F=AA=E6=9C=89=E6=94=BE=E5=9C= =A8lib=E7=9B=AE=E5=BD=95=E6=89=8D=E8=83=BD=E5=8A=A0=E8=BD=BD=E5=BE=97=E5=88= =B0=EF=BC=8C=E6=88=91=E7=9C=8B=E5=8F=91=E5=B8=83=E6=96=87=E6=A1=A3=E8=B7=9F= =E6=94=B9=E4=BA=86=E7=B1=BB=E5=8A=A0=E8=BD=BD=E7=AD=96=E7=95=A5=EF=BC=8C=E4= =BD=86=E6=98=AF=E6=88=91=E4=B8=8D=E7=9F=A5=E9=81=93=E4=B8=BA=E4=BB=80=E4=B9= =88Uber > > > > > > >> > > Jar=E9=87=8C=E9=9D=A2=E7=9A=84Factory=E4=B8=8D=E8=83=BD= =E8=A2=AB=E5=8A=A0=E8=BD=BD > > > > > > >> > > > Flink Client respects Classloading Policy (FLINK-13749 > > > > > > >> > > > ) > > > > > > >> > > > < > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > https://ci.apache.org/projects/flink/flink-docs-release-1.10/release-note= s/flink-1.10.html#flink-client-respects-classloading-policy-flink-13749 > > > > > > >> > > > > > > > > > > >> > > > > > > > > > >> > > > The Flink client now also respects the configured > > > classloading > > > > > > >> policy, > > > > > > >> > > > i.e., parent-first or child-first classloading. > > Previously, > > > > only > > > > > > >> > cluster > > > > > > >> > > > components such as the job manager or task manager > > supported > > > > > this > > > > > > >> > > setting. > > > > > > >> > > > This does mean that users might get different behaviou= r > in > > > > their > > > > > > >> > > programs, > > > > > > >> > > > in which case they should configure the classloading > > policy > > > > > > >> explicitly > > > > > > >> > to > > > > > > >> > > > use parent-first classloading, which was the previous > > > > > (hard-coded) > > > > > > >> > > > behaviour. > > > > > > >> > > > > > > > > > >> > > > =E5=BC=82=E5=B8=B8=E4=BF=A1=E6=81=AF=EF=BC=9A > > > > > > >> > > > > > > > > > >> > > > > > rg.apache.flink.client.program.ProgramInvocationException: > > > > The > > > > > > >> main > > > > > > >> > > > method caused an error: findAndCreateTableSource faile= d. > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedPr= ogram.java:335) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForE= xecution(PackagedProgram.java:205) > > > > > > >> > > > at > > > > > > >> > > > > > > > > >> > > > > > > > > > org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:138) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:6= 64) > > > > > > >> > > > at > > > > > > org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:21= 3) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:= 895) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:9= 68) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecu= rityContext.java:30) > > > > > > >> > > > at > > > > > > >> > > org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968) > > > > > > >> > > > Caused by: org.apache.flink.table.api.TableException: > > > > > > >> > > > findAndCreateTableSource failed. > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSourc= e(TableFactoryUtil.java:55) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSourc= e(TableFactoryUtil.java:92) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.plan.schema.CatalogSourceTable.findAndCrea= teTableSource(CatalogSourceTable.scala:156) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.plan.schema.CatalogSourceTable.tableSource= $lzycompute(CatalogSourceTable.scala:65) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.plan.schema.CatalogSourceTable.tableSource= (CatalogSourceTable.scala:65) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.plan.schema.CatalogSourceTable.toRel(Catal= ogSourceTable.scala:76) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.toRel(SqlToRelConverter.java= :3328) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertIdentifier(SqlToRelCo= nverter.java:2357) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverte= r.java:2051) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverte= r.java:2005) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverte= r.java:2083) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertSelectImpl(SqlToRelCo= nverter.java:646) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertSelect(SqlToRelConver= ter.java:627) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertQueryRecursive(SqlToR= elConverter.java:3181) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.calcite.sql2rel.SqlToRelConverter.convertQuery(SqlToRelConvert= er.java:563) > > > > > > >> > > > at > > > > org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > $apache$flink$table$planner$calcite$FlinkPlannerImpl$$rel(FlinkPlannerImp= l.scala:148) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.calcite.FlinkPlannerImpl.rel(FlinkPlannerI= mpl.scala:135) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.operations.SqlToOperationConverter.toQuery= Operation(SqlToOperationConverter.java:522) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.operations.SqlToOperationConverter.convert= SqlQuery(SqlToOperationConverter.java:436) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.operations.SqlToOperationConverter.convert= (SqlToOperationConverter.java:154) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.jav= a:66) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.api.internal.TableEnvironmentImpl.sqlQuery(TableEn= vironmentImpl.java:464) > > > > > > >> > > > at > > com.akulaku.data.main.StreamMain.main(StreamMain.java:87) > > > > > > >> > > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > > > Method) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java= :62) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorI= mpl.java:43) > > > > > > >> > > > at java.lang.reflect.Method.invoke(Method.java:498) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedPr= ogram.java:321) > > > > > > >> > > > ... 8 more > > > > > > >> > > > Caused by: > > > > > > >> org.apache.flink.table.api.NoMatchingTableFactoryException: > > > > > > >> > > > Could not find a suitable table factory for > > > > > > >> > > > 'org.apache.flink.table.factories.TableSourceFactory' = in > > > > > > >> > > > the classpath. > > > > > > >> > > > > > > > > > >> > > > Reason: Required context properties mismatch. > > > > > > >> > > > > > > > > > >> > > > The matching candidates: > > > > > > >> > > > > org.apache.flink.table.sources.CsvAppendTableSourceFactory > > > > > > >> > > > Mismatched properties: > > > > > > >> > > > 'connector.type' expects 'filesystem', but is 'kafka' > > > > > > >> > > > 'format.type' expects 'csv', but is 'json' > > > > > > >> > > > > > > > > > >> > > > The following properties are requested: > > > > > > >> > > > connector.properties.bootstrap.servers=3Dcentos:9092 > > > > > > >> > > > connector.properties.zookeeper.connect=3Dcentos:2181 > > > > > > >> > > > connector.startup-mode=3Dearliest-offset > > > > > > >> > > > connector.topic=3Dtest > > > > > > >> > > > connector.type=3Dkafka > > > > > > >> > > > connector.version=3D0.11 > > > > > > >> > > > format.type=3Djson > > > > > > >> > > > schema.0.data-type=3DVARCHAR(2147483647) > > > > > > >> > > > schema.0.name=3Dbus > > > > > > >> > > > schema.1.data-type=3DBIGINT > > > > > > >> > > > schema.1.name=3Dts > > > > > > >> > > > schema.2.data-type=3DVARCHAR(2147483647) > > > > > > >> > > > schema.2.name=3Dtype > > > > > > >> > > > schema.3.data-type=3DBIGINT > > > > > > >> > > > schema.3.name=3DputRowNum > > > > > > >> > > > schema.4.data-type=3DTIMESTAMP(3) NOT NULL > > > > > > >> > > > schema.4.expr=3DPROCTIME() > > > > > > >> > > > schema.4.name=3Dproctime > > > > > > >> > > > update-mode=3Dappend > > > > > > >> > > > > > > > > > >> > > > The following factories have been considered: > > > > > > >> > > > > org.apache.flink.table.sources.CsvBatchTableSourceFactory > > > > > > >> > > > > org.apache.flink.table.sources.CsvAppendTableSourceFactory > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryService.filterByContext(Tabl= eFactoryService.java:322) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryS= ervice.java:190) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryService.findSingleInternal(T= ableFactoryService.java:143) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryService.find(TableFactorySer= vice.java:96) > > > > > > >> > > > at > > > > > > >> > > > > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > > > > > > > > > > > > > > > > org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSourc= e(TableFactoryUtil.java:52) > > > > > > >> > > > > > > > > > >> > > > > > > > > >> > > > > > > > > >> > > -- > > > > > > >> > > Best, Jingsong Lee > > > > > > >> > > > > > > > > >> > > > > > > > >> > > > > > > >> > > > > > > >> -- > > > > > > >> Best, Jingsong Lee > > > > > > >> > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- > > > > > Best, Jingsong Lee > > > > > > > > > > > > > > > > > > -- > > > Best, Jingsong Lee > > > > > > --00000000000050688f05a3ed32ff--