From user-zh-return-670-archive-asf-public=cust-asf.ponee.io@flink.apache.org Wed Jul 24 01:51:51 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 D63941802C7 for ; Wed, 24 Jul 2019 03:51:50 +0200 (CEST) Received: (qmail 75796 invoked by uid 500); 24 Jul 2019 01:51:46 -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 75782 invoked by uid 99); 24 Jul 2019 01:51: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; Wed, 24 Jul 2019 01:51: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 4881DC0E99 for ; Wed, 24 Jul 2019 01:51:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.05 X-Spam-Level: ** X-Spam-Status: No, score=2.05 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, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-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 (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id WphVrAZXROgm for ; Wed, 24 Jul 2019 01:51:43 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.215.195; helo=mail-pg1-f195.google.com; envelope-from=wander4096@gmail.com; receiver= Received: from mail-pg1-f195.google.com (mail-pg1-f195.google.com [209.85.215.195]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTPS id CB84CBC7AD for ; Wed, 24 Jul 2019 01:51:42 +0000 (UTC) Received: by mail-pg1-f195.google.com with SMTP id w10so20331940pgj.7 for ; Tue, 23 Jul 2019 18:51:42 -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=jxPLBxahG3Zs6wM8PaDa0TPhiFzcBdA7aBJSrTAsU1k=; b=lYXAXD/ebQ2oMFmXHuNBcEYHwc+xYjdvCLER1eBXNLe36DjunQwqc5VOUIUlVxBlGR IG39kLZ51VBNf5HTHQDs5QXsKBZiz/Fjev7vK2lBoklkKDU4Gv7PuvNSrgcHxCY+Y+ru 4+V5sFutguo13t9zdvfVp+YcemgiolnaS20HCBVNXi4ynblpnGRChoMnEt3nc5CC6Iuh pY/haFWjpIQCYQiUxwGt5ih1FbkvTOomAAexUJFgWCxnqZaJhT+UzbevipVWG4n8LqLm 2g37q/coMPCYkQmH0a25WlWnuZSH8O5J1ZhRnaEsN0x83Fx2trbSOCOIvXDWXdBXiAp4 4v0g== 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=jxPLBxahG3Zs6wM8PaDa0TPhiFzcBdA7aBJSrTAsU1k=; b=Rcmipbuc/vmd1vZPQZuq8CjEQr1qsyhSjgF24ldNMdRkHwi+t0fNAxyDuNqJgGG94C 3tYepacHqwXxmp6XUkloB4+euDRKUTtZGIECBNdkxTHSvs3hO7Z0oCzIjCDBM+mt2AV2 NVYjM7CSFsknAwulgoCCBhfZQYsRt2Fryykj+ZO1NAmXoZO4UvEUwno33QF07etVOL37 n920CWt0ArhAodI8vkd+Fhd1VizKGl5vKQ1cWftp4Uf4NfGpsxhh09f0uXwqpf7nNRO0 d436UtucS92XhsiW2FuSX8E2Kz5oZB9gU5sgZSOP2QLHHKLDL8IA/Lxu2cb/apXa9O+h pgwQ== X-Gm-Message-State: APjAAAV9XSgow7cm/wQzdceVm790V35nHDQabtWVLQYTXYODkSzp8hYM ZDYBEC+QKQ6x0cWjQ8ZAMivVXbOSBHPSZ5gVH6B00BzwO7+jFQ== X-Google-Smtp-Source: APXvYqyXCnHHfhmd2g/311qbQcENn8Zv6VwB33m1J/npkbPhxQ0EBZFtTAHSsHF+DpXQRVFufINIXWD7KUKLTT3kafA= X-Received: by 2002:a63:3112:: with SMTP id x18mr78995307pgx.385.1563933101652; Tue, 23 Jul 2019 18:51:41 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Zili Chen Date: Wed, 24 Jul 2019 09:51:08 +0800 Message-ID: Subject: =?UTF-8?B?UmU6IEZsaW5rIDEuOCBydW7lj4LmlbDkuI3kuIDmoLc=?= To: user-zh@flink.apache.org Content-Type: multipart/alternative; boundary="000000000000f9fdd9058e638c0e" --000000000000f9fdd9058e638c0e Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable =E4=BD=A0=E5=A5=BD=EF=BC=8C=E5=8F=AF=E4=BB=A5=E6=9F=A5=E7=9C=8B=E4=B8=8B lo= g/ =E7=9B=AE=E5=BD=95=E4=B8=8B=E7=9A=84=E7=9B=B8=E5=85=B3=E6=97=A5=E5=BF=97= =E6=9C=89=E6=B2=A1=E6=9C=89=E8=BF=99=E6=A0=B7=E4=B8=80=E6=AE=B5 2019-07-24 09:34:36,507 WARN org.apache.flink.client.cli.CliFrontend - Could not load CLI class org.apache.flink.yarn.cli.FlinkYarnSessionCli. java.lang.NoClassDefFoundError: org/apache/hadoop/yarn/exceptions/YarnException at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.flink.client.cli.CliFrontend.loadCustomCommandLine(CliFrontend.j= ava:1187) at org.apache.flink.client.cli.CliFrontend.loadCustomCommandLines(CliFrontend.= java:1147) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1072) Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.yarn.exceptions.YarnException at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 5 more =E5=A6=82=E6=9E=9C=E6=9C=89=E7=9A=84=E8=AF=9D=EF=BC=8C=E7=8E=B0=E5=9C=A8 Fl= ink =E6=8A=8A=E6=A0=B8=E5=BF=83=E5=8C=85=E5=92=8C hadoop =E7=9A=84 pre-bund= led =E5=8C=85=E5=88=86=E5=BC=80 release=EF=BC=8C=E9=9C=80=E8=A6=81=E4=BD=A0= =E5=8D=95=E7=8B=AC=E4=B8=8B=E8=BD=BD pre-bundled =E7=9A=84 hadoop =E7=84=B6=E5=90=8E=E6=94=BE=E5=88=B0 lib/ =E6=96=87=E4=BB=B6=E5=A4= =B9=E9=87=8C=E3=80=82 =E5=85=B7=E4=BD=93=E5=9C=B0=EF=BC=8C=E8=AF=B7=E4=BB=94=E7=BB=86=E9=98=85=E8= =AF=BB=E4=B8=8B=E8=BD=BD=E9=A1=B5=E9=9D=A2[1] "Apache Flink 1.8.1" =E5=AD= =97=E6=A0=B7=E4=B8=8A=E9=9D=A2=E7=9A=84=E6=96=87=E5=AD=97=E5=86=85=E5=AE=B9= =E3=80=82 Best, tison. [1] https://flink.apache.org/downloads.html =E7=8E=8B=E4=BD=A9 =E4=BA=8E2019=E5=B9=B47=E6=9C=8824=E6= =97=A5=E5=91=A8=E4=B8=89 =E4=B8=8A=E5=8D=889:30=E5=86=99=E9=81=93=EF=BC=9A > =E4=B9=8B=E5=89=8D=E4=B8=8B=E8=BD=BD=E7=9A=84Flink 1.8=EF=BC=8C=E8=BF=90= =E8=A1=8Cbin/flink run --help=EF=BC=8C=E4=BC=9A=E6=9C=89 yarn-cluster =E7= =9A=84=E4=B8=80=E4=BA=9B=E5=8F=82=E6=95=B0=EF=BC=8C=E5=A6=82=E4=B8=8B: > Options for yarn-cluster mode: > -d,--detached If present, runs the job in > detached > mode > -m,--jobmanager Address of the JobManager > (master) to > which to connect. Use this flag > to > connect to a different JobManag= er > than > the one specified in the > configuration. > -sae,--shutdownOnAttachedExit If the job is submitted in > attached > mode, perform a best-effort > cluster > shutdown when the CLI is > terminated > abruptly, e.g., in response to = a > user > interrupt, such as typing Ctrl = + > C. > -yD use value for given property > -yd,--yarndetached If present, runs the job in > detached > mode (deprecated; use non-YARN > specific option instead) > -yh,--yarnhelp Help for the Yarn session CLI. > -yid,--yarnapplicationId Attach to running YARN session > -yj,--yarnjar Path to Flink jar file > -yjm,--yarnjobManagerMemory Memory for JobManager Container > with > optional unit (default: MB) > -yn,--yarncontainer Number of YARN container to > allocate > (=3DNumber of Task Managers) > -ynl,--yarnnodeLabel Specify YARN node label for the > YARN > application > -ynm,--yarnname Set a custom name for the > application > on YARN > -yq,--yarnquery Display available YARN resource= s > (memory, cores) > -yqu,--yarnqueue Specify YARN queue. > -ys,--yarnslots Number of slots per TaskManager > -yst,--yarnstreaming Start Flink in streaming mode > -yt,--yarnship Ship files in the specified > directory > (t for transfer) > -ytm,--yarntaskManagerMemory Memory per TaskManager Containe= r > with > optional unit (default: MB) > -yz,--yarnzookeeperNamespace Namespace to create the Zookeep= er > sub-paths for high availability > mode > -z,--zookeeperNamespace Namespace to create the Zookeep= er > sub-paths for high availability > mode > > > =E7=8E=B0=E5=9C=A8=E4=B8=8B=E8=BD=BD=E7=9A=84Flink 1.8=EF=BC=8C=E8=BF=90= =E8=A1=8Cbin/flink run --help=EF=BC=8C=E6=80=BB=E5=85=B1=E5=8F=AA=E6=9C=89= =E5=A6=82=E4=B8=8B=E5=8F=82=E6=95=B0=EF=BC=8C=E5=B0=91=E4=BA=86yarn-cluster= =E9=80=89=E9=A1=B9: > Action "run" compiles and runs a program. > > Syntax: run [OPTIONS] > "run" action options: > -c,--class Class with the program entry > point > ("main" method or "getPlan()" > method. > Only needed if the JAR file doe= s > not > specify the class in its > manifest. > -C,--classpath Adds a URL to each user code > classloader on all nodes in th= e > cluster. The paths must specify= a > protocol (e.g. file://) and be > accessible on all nodes (e.g. b= y > means > of a NFS share). You can use th= is > option multiple times for > specifying > more than one URL. The protocol > must > be supported by the {@link > java.net.URLClassLoader}. > -d,--detached If present, runs the job in > detached > mode > -n,--allowNonRestoredState Allow to skip savepoint state > that > cannot be restored. You need to > allow > this if you removed an operator > from > your program that was part of t= he > program when the savepoint was > triggered. > -p,--parallelism The parallelism with which to r= un > the > program. Optional flag to > override the > default value specified in the > configuration. > -q,--sysoutLogging If present, suppress logging > output to > standard out. > -s,--fromSavepoint Path to a savepoint to restore > the job > from (for example > hdfs:///flink/savepoint-1537). > -sae,--shutdownOnAttachedExit If the job is submitted in > attached > mode, perform a best-effort > cluster > shutdown when the CLI is > terminated > abruptly, e.g., in response to = a > user > interrupt, such as typing Ctrl = + > C. > Options for default mode: > -m,--jobmanager Address of the JobManager (master) t= o > which > to connect. Use this flag to connect > to a > different JobManager than the one > specified > in the configuration. > -z,--zookeeperNamespace Namespace to create the Zookeeper > sub-paths > for high availability mode > > > =E5=8F=91=E7=8E=B0=EF=BC=8C=E5=B0=91=E4=BA=86yarn-cluster=E7=9A=84=E4=B8= =80=E4=BA=9B=E5=8F=82=E6=95=B0=EF=BC=8C=E8=AF=B7=E6=95=99=E4=B8=8B=EF=BC=8C= =E8=BF=99=E6=98=AF=E4=BB=80=E4=B9=88=E5=8E=9F=E5=9B=A0=E5=95=8A > --000000000000f9fdd9058e638c0e--