From user-zh-return-803-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Aug 12 00:48:26 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 0402B180674 for ; Mon, 12 Aug 2019 02:48:25 +0200 (CEST) Received: (qmail 4672 invoked by uid 500); 12 Aug 2019 00:48:24 -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 4660 invoked by uid 99); 12 Aug 2019 00:48:24 -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; Mon, 12 Aug 2019 00:48:24 +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 B85341A3324 for ; Mon, 12 Aug 2019 00:48:23 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-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: spamd2-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 (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 04RwYB0MRLTn for ; Mon, 12 Aug 2019 00:48:21 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.215.171; helo=mail-pg1-f171.google.com; envelope-from=wander4096@gmail.com; receiver= Received: from mail-pg1-f171.google.com (mail-pg1-f171.google.com [209.85.215.171]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTPS id 31D5ABC7B3 for ; Mon, 12 Aug 2019 00:48:21 +0000 (UTC) Received: by mail-pg1-f171.google.com with SMTP id n4so6893272pgv.2 for ; Sun, 11 Aug 2019 17:48:21 -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=GIqiaSJ257Zyo7o1KN5pNPkh+ObBcTwv2nzwZBcq0OI=; b=ECFeApW9s/E1bb38gZpy0B49Ut9UiaRclPizkVtqJzO7wxEw9KWA8P67d+j+Eao4Su OQs9FtHnQmjYmeq/evJLhq+jkgUIww40jr2q2KwvJl6SZScuNNdNoweTwIdqxHukJRGE YOeuimV1EElNcMKK51w1cSF+EdkWRH/wLGXP3M5Shu29R8HzqM1xHLdQ4Xkryx6sOAZ/ pVSmRC7pi022VhoUlL9IhLOTKe0IaAO8pu51deGhY+Ba+MC8z9r7r9uCH4B/XCf7fbXU R1nit9CoxrNKjAuxnmQS7uquR7MCE0HSaqHfzPDKMy2Jw7xQfmhZ6gSAc2AYdxZY5Ikn NpYg== 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=GIqiaSJ257Zyo7o1KN5pNPkh+ObBcTwv2nzwZBcq0OI=; b=kzce5HbCSfTtMDf/MdWITS67mPS+edIm+eflVHeuECBklSBXnUoo9clfYgAWngwuY1 X+1S6DmVxrxAql3g+RwNka5rPcAk9b1A0k45znco5XArxjolk8G5Cjt59VcpGJ99pxHR I1LsZoYYUv36TRjznmSoibone/+hvRXFEYfAfOpVPACzmbNt97KxPPbAkodDwaHqrZ40 O5NFGh4Czc9CLNGwccLfVruB9KY/msP2cjmSlsnUTLftwdKdWkP5FcpTKMOFEFbBVS9B VOeqEwYhxBff34taCuqOVaU/bR14n69bDr91Xv5EE1AtHTqxz3mrFmr8VL69io1PxvS4 Bhjw== X-Gm-Message-State: APjAAAX3qhnfPoE4etaRIYEFTZ7zsE/muM2w2+wEw4SqhTTqs8I0vfWS ASugGj3GOTWAQRu2ub7MOKy9lBZlMGu1EQLGSe7IuyjJ7jSpdw== X-Google-Smtp-Source: APXvYqy7PUQpMNQFraSzPlYAZmx+gXUoYRU4pjVfr5qL7MpnfeMz1Iw3YaGmTMUt3kB9Zlsyt0kQXDrdGpdNU3QTJUo= X-Received: by 2002:a62:8648:: with SMTP id x69mr5573026pfd.92.1565570893941; Sun, 11 Aug 2019 17:48:13 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Zili Chen Date: Mon, 12 Aug 2019 08:47:47 +0800 Message-ID: Subject: Re: need help To: user-zh Content-Type: multipart/alternative; boundary="000000000000010ea4058fe0e1fd" --000000000000010ea4058fe0e1fd Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable =E5=BC=82=E5=B8=B8=E5=8E=9F=E5=9B=A0=E5=A6=82=E4=B8=8A=E6=89=80=E8=AF=B4=E6= =98=AF akka ask timeout =E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=8C=E8=BF=99=E4=B8= =AA=E9=97=AE=E9=A2=98=E5=89=8D=E4=B8=A4=E5=A4=A9=E6=9C=89=E4=BA=BA=E5=9C=A8= =E9=83=A8=E7=BD=B2 k8s =E7=9A=84=E6=97=B6=E5=80=99=E4=B9=9F=E9=81=87=E8=BF= =87[1] =E4=BB=96=E7=9A=84=E6=83=85=E5=86=B5=E6=98=AF=E9=85=8D=E7=BD=AE=E8=B5=84=E6= =BA=90=E8=BF=87=E5=B0=91=E5=AF=BC=E8=87=B4 JM =E6=9C=AA=E8=83=BD=E5=8F=8A= =E6=97=B6=E5=93=8D=E5=BA=94=E3=80=82=E9=99=A4=E4=BA=86=E8=B0=83=E6=95=B4=E4= =B8=8A=E8=BF=B0=E5=8F=82=E6=95=B0=E5=A4=96=E4=B9=9F=E5=8F=AF=E7=9C=8B=E7=9C= =8B=E6=98=AF=E4=B8=8D=E6=98=AF=E8=BF=99=E4=B8=AA=E9=97=AE=E9=A2=98=E3=80=82 Best, tison. [1] https://lists.apache.org/thread.html/84db9dca2e990dd0ebc30aa35390ac75a0e9c7= cbfcdbc2029986d4d7@%3Cuser-zh.flink.apache.org%3E Biao Liu =E4=BA=8E2019=E5=B9=B48=E6=9C=888=E6=97=A5=E5= =91=A8=E5=9B=9B =E4=B8=8B=E5=8D=888:00=E5=86=99=E9=81=93=EF=BC=9A > =E4=BD=A0=E5=A5=BD=EF=BC=8C > > =E5=BC=82=E5=B8=B8=E9=87=8C=E5=8F=AF=E4=BB=A5=E7=9C=8B=E5=87=BA AskTimeou= tException, =E5=8F=AF=E4=BB=A5=E8=B0=83=E6=95=B4=E4=B8=A4=E4=B8=AA=E5=8F=82= =E6=95=B0 akka.ask.timeout =E5=92=8C web.timeout > =E5=86=8D=E8=AF=95=E4=B8=80=E4=B8=8B=EF=BC=8C=E9=BB=98=E8=AE=A4=E5=80=BC= =E5=A6=82=E4=B8=8B > > akka.ask.timeout: 10 s > web.timeout: 10000 > > PS: =E6=90=9C =E2=80=9CAskTimeoutException Flink=E2=80=9D =E5=8F=AF=E4=BB= =A5=E6=90=9C=E5=88=B0=E5=BE=88=E5=A4=9A=E7=9B=B8=E5=85=B3=E7=AD=94=E6=A1=88 > > Thanks, > Biao /'b=C9=AA.a=CA=8A/ > > > > On Thu, Aug 8, 2019 at 7:33 PM =E9=99=88=E6=9F=90 = wrote: > > > > > > > ---------- Forwarded message --------- > > =E5=8F=91=E4=BB=B6=E4=BA=BA=EF=BC=9A =E9=99=88=E6=9F=90 > > Date: 2019=E5=B9=B48=E6=9C=888=E6=97=A5=E5=91=A8=E5=9B=9B =E4=B8=8B=E5= =8D=887:25 > > Subject: need help > > To: > > > > > > =E4=BD=A0=E5=A5=BD=EF=BC=8C=E6=88=91=E6=98=AF=E4=B8=80=E4=B8=AA=E5=88= =9A=E6=8E=A5=E8=A7=A6flink=E7=9A=84=E6=96=B0=E6=89=8B=EF=BC=8C=E5=9C=A8=E6= =90=AD=E5=BB=BA=E5=AE=8Cflink on > > > yarn=E9=9B=86=E7=BE=A4=E5=90=8E=EF=BC=8C=E4=BE=9D=E6=AC=A1=E5=90=AF=E5=8A= =A8zookeeper=EF=BC=8Chadoop=EF=BC=8Cyarn=EF=BC=8Cflkink=E9=9B=86=E7=BE=A4= =EF=BC=8C=E5=B9=B6=E6=8F=90=E4=BA=A4=E8=AE=A4=E8=AF=86=E5=88=B0yarn=E4=B8= =8A=E6=97=B6=E8=BF=90=E8=A1=8C=E9=81=87=E5=88=B0=E9=97=AE=E9=A2=98=EF=BC=8C= =E7=BD=91=E4=B8=8A=E6=90=9C=E7=B4=A2=E7=9B=B8=E5=85=B3=E9=97=AE=E9=A2=98=EF= =BC=8C=E6=9A=82=E6=9C=AA=E6=89=BE=E5=88=B0=E8=A7=A3=E5=86=B3=E6=96=B9=E5=BC= =8F=EF=BC=8C=E5=B8=8C=E6=9C=9B=E8=83=BD=E5=BE=97=E5=88=B0=E5=B8=AE=E5=8A=A9= =EF=BC=8C=E8=B0=A2=E8=B0=A2=E3=80=82 > > > > =E4=BD=BF=E7=94=A8=E7=9A=84=E8=BF=90=E8=A1=8C=E6=8C=87=E4=BB=A4=E4=B8= =BA=EF=BC=9A > > [root@flink01 logs]# flink run -m yarn-cluster > > ./examples/streaming/WordCount.jar > > =E6=9F=A5=E7=9C=8Blog=E5=90=8E=E9=94=99=E8=AF=AF=E4=BF=A1=E6=81=AF=E5= =A6=82=E4=B8=8B=EF=BC=9A=EF=BC=88=E9=99=84=E4=BB=B6=E4=B8=AD=E4=B8=BA=E5=AE= =8C=E6=95=B4=E7=9A=84log=E6=96=87=E4=BB=B6=EF=BC=89 > > org.apache.flink.client.program.ProgramInvocationException: Could not > > retrieve the execution result. (JobID: 91e82fd8626bde4c901bf0b1639e12e7= ) > > at > > > org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClus= terClient.java:261) > > at > > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:48= 3) > > at > > > org.apache.flink.streaming.api.environment.StreamContextEnvironment.execu= te(StreamContextEnvironment.java:66) > > at > > > org.apache.flink.streaming.examples.wordcount.WordCount.main(WordCount.ja= va:89) > > 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:529) > > at > > > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForE= xecution(PackagedProgram.java:421) > > at > > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:42= 3) > > at > > > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:8= 13) > > at > org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:287) > > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213) > > at > > > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:= 1050) > > at > > > org.apache.flink.client.cli.CliFrontend.lambda$main$11(CliFrontend.java:1= 126) > > at java.security.AccessController.doPrivileged(Native Method) > > at javax.security.auth.Subject.doAs(Subject.java:422) > > at > > > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation= .java:1836) > > at > > > org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(Hadoop= SecurityContext.java:41) > > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1126) > > Caused by: org.apache.flink.runtime.client.JobSubmissionException: Fail= ed > > to submit JobGraph. > > at > > > org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$8= (RestClusterClient.java:388) > > at > > > java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture= .java:870) > > at > > > java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(Completab= leFuture.java:852) > > at > > > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.jav= a:474) > > at > > > java.util.concurrent.CompletableFuture.completeExceptionally(CompletableF= uture.java:1977) > > at > > > org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWith= Delay$5(FutureUtils.java:208) > > at > > > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.= java:760) > > at > > > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Completabl= eFuture.java:736) > > at > > > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.jav= a:474) > > at > > > java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:56= 1) > > at > > > java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFutu= re.java:929) > > at > > > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.j= ava:442) > > at > > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java= :1149) > > at > > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.jav= a:624) > > at java.lang.Thread.run(Thread.java:748) > > Caused by: org.apache.flink.runtime.rest.util.RestClientException: > > [Internal server error., > akka.pattern.AskTimeoutException: Ask timed out on > > [Actor[akka://flink/user/dispatcher#2035575525]] after [10000 ms]. > > Sender[null] sent message of type > > "org.apache.flink.runtime.rpc.messages.LocalFencedMessage". > > at > > > akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:604= ) > > at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126) > > at > > > scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future= .scala:601) > > at > > > scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:10= 9) > > at > > > scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:59= 9) > > at > > > akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayR= evolverScheduler.scala:329) > > at > > > akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArray= RevolverScheduler.scala:280) > > at > > > akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolve= rScheduler.scala:284) > > at > > > akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverSche= duler.scala:236) > > at java.lang.Thread.run(Thread.java:748) > > > --000000000000010ea4058fe0e1fd--