Return-Path: 
 <user-return-2524-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-user-archive@minotaur.apache.org
Delivered-To: apmail-flink-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 32DEA10DC8
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Fri, 28 Aug 2015 09:03:33 +0000 (UTC)
Received: (qmail 55831 invoked by uid 500); 28 Aug 2015 09:03:32 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 55760 invoked by uid 500); 28 Aug 2015 09:03:32 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 55751 invoked by uid 99); 28 Aug 2015 09:03:32 -0000
Received: from mail-relay.apache.org (HELO mail-relay.apache.org)
 (140.211.11.15)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 28 Aug 2015 09:03:32 +0000
Received: from mail-wi0-f174.google.com (mail-wi0-f174.google.com
 [209.85.212.174])
	by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with
 ESMTPSA id CFE5F1A01DA
	for <user@flink.apache.org>; Fri, 28 Aug 2015 09:03:31 +0000 (UTC)
Received: by wibcx1 with SMTP id cx1so7208863wib.1
        for <user@flink.apache.org>; Fri, 28 Aug 2015 02:03:29 -0700 (PDT)
X-Received: by 10.194.121.34 with SMTP id lh2mr9862379wjb.101.1440752609044;
 Fri, 28 Aug 2015 02:03:29 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.28.9.195 with HTTP; Fri, 28 Aug 2015 02:03:09 -0700 (PDT)
In-Reply-To: 
 <A9B95645A9EAB24A9693F53358DB8A612EBCF7E5@bt1shkrd.bt0d0000.w2k.bouyguestelecom.fr>
References: 
 <A9B95645A9EAB24A9693F53358DB8A612EBCF7E5@bt1shkrd.bt0d0000.w2k.bouyguestelecom.fr>
From: Robert Metzger <rmetzger@apache.org>
Date: Fri, 28 Aug 2015 11:03:09 +0200
Message-ID: 
 <CAGr9p8BHsMEsu4S3soj3WufdJTCz4htB1ZoKcHJ1SV6BogceUw@mail.gmail.com>
Subject: Re: "Flink YARN Client requested shutdown" in flink -m yarn-cluster
 mode?
To: "user@flink.apache.org" <user@flink.apache.org>
Content-Type: multipart/alternative; boundary=089e01227cf078ee40051e5b5bee

--089e01227cf078ee40051e5b5bee
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Is the log from 0.9-SNAPSHOT or 0.10-SNAPSHOT?

Can you send me (if you want privately as well) the full log of the yarn
application:

yarn logs -applicationId <appId>.

We need to find out why the TaskManagers are shutting down. That is most
likely logged in the TaskManager logs.


On Fri, Aug 28, 2015 at 10:57 AM, LINZ, Arnaud <ALINZ@bouyguestelecom.fr>
wrote:

> Hello,
>
>
>
> I=E2=80=99ve moved my version from 0.9.0 and tried both 0.9-SNAPSHOT &
> 0.10-SNAPSHOT to continue my batch execution on my secured cluster thanks
> to [FLINK-2555].
>
> My application works nicely in local mode and also in yarn mode using a
> job container started with yarn-session.sh, but it fails in =E2=80=93m
> yarn-cluster mode
>
>
>
> Yarn logs indicate that  =E2=80=9CFlink YARN Client requested shutdown=E2=
=80=9D but I did
> nothing like that (or not intentionally). The nodes are not even starting
> and the exec() does not return any JobExecutionResult.
>
>
>
> My command line was :
>
> flink run -m yarn-cluster -yd -yn 2 -ytm 1500 -yqu default -ys 4 --class
> <myMainClass> <myJar> <some options>
>
>
>
> Any idea what I=E2=80=99ve done wrong?
>
>
>
> Greetings,
>
> Arnaud
>
>
>
> PS - Yarn log extract :
>
> (=E2=80=A6)
>
> 09:56:29,111 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Successfu=
l
> registration at JobManager (akka.tcp://
> flink@172.19.115.51:54806/user/jobmanager), starting network stack and
> library cache.
>
> 09:56:29,817 INFO
> org.apache.flink.runtime.io.network.netty.NettyClient         - Successfu=
l
> initialization (took 73 ms).
>
> 09:56:29,889 INFO
> org.apache.flink.runtime.io.network.netty.NettyServer         - Successfu=
l
> initialization (took 55 ms). Listening on SocketAddress /
> 172.19.115.52:41920.
>
> 09:56:29,890 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Determine=
d
> BLOB server address to be /172.19.115.51:38505. Starting BLOB cache.
>
> 09:56:29,893 INFO
> org.apache.flink.runtime.blob.BlobCache                       - Created
> BLOB cache storage directory
> /tmp/blobStore-7150f7d7-f7a3-4c4c-9cda-3877da5aacd6
>
> 09:56:52,367 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Received
> task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (1/3)
>
> 09:56:52,375 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Received
> task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (3/3)
>
> 09:56:52,383 INFO  org.apache.flink.runtime.taskmanager.Task
>         - Loading JAR files for task CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (1/3)
>
> 09:56:52,387 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Loading J=
AR
> files for task CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (3/3)
>
> 09:56:52,394 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Received
> task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (1/3)
>
> 09:56:52,402 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Loading J=
AR
> files for task CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (1/3)
>
> 09:56:52,425 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Received
> task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (2/3)
>
> 09:56:52,429 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Loading J=
AR
> files for task CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (2/3)
>
> 09:56:52,454 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Stopping
> YARN TaskManager with final application status FAILED and diagnostics:
> Flink YARN Client requested shutdown
>
> 09:56:52,480 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Stopping
> TaskManager akka://flink/user/taskmanager#2116513584.
>
> 09:56:52,483 INFO
> org.apache.flink.yarn.YarnTaskManager                         - Cancellin=
g
> all computations and discarding all cached data.
>
> 09:56:52,486 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Attemptin=
g
> to fail task externally CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (3/3)
>
> 09:56:52,486 INFO
> org.apache.flink.runtime.taskmanager.Task                     - CHAIN
> DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (3/3)
> switched to FAILED with exception.
>
> java.lang.Exception: TaskManager is shutting down.
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.postStop(TaskManager.sca=
la:195)
>
>         at akka.actor.Actor$class.aroundPostStop(Actor.scala:475)
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.aroundPostStop(TaskManag=
er.scala:114)
>
>         at
> akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$=
finishTerminate(FaultHandling.scala:210)
>
>         at
> akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
>
>         at akka.actor.ActorCell.terminate(ActorCell.scala:369)
>
>         at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
>
>         at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
>
>         at
> akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
>
>         at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.jav=
a:1339)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
>         at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.j=
ava:107)
>
> 09:56:52,511 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Attemptin=
g
> to fail task externally CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (1/3)
>
> 09:56:52,511 INFO
> org.apache.flink.runtime.taskmanager.Task                     - CHAIN
> DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (1/3)
> switched to FAILED with exception.
>
> java.lang.Exception: TaskManager is shutting down.
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.postStop(TaskManager.sca=
la:195)
>
>         at akka.actor.Actor$class.aroundPostStop(Actor.scala:475)
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.aroundPostStop(TaskManag=
er.scala:114)
>
>         at
> akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$=
finishTerminate(FaultHandling.scala:210)
>
>         at
> akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
>
>         at akka.actor.ActorCell.terminate(ActorCell.scala:369)
>
>         at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
>
>         at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
>
>         at
> akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
>
>         at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.jav=
a:1339)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
>         at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.j=
ava:107)
>
> 09:56:52,515 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Attemptin=
g
> to fail task externally CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (2/3)
>
> 09:56:52,515 INFO
> org.apache.flink.runtime.taskmanager.Task                     - CHAIN
> DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 2) (2/3)
> switched to FAILED with exception.
>
> java.lang.Exception: TaskManager is shutting down.
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.postStop(TaskManager.sca=
la:195)
>
>         at akka.actor.Actor$class.aroundPostStop(Actor.scala:475)
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.aroundPostStop(TaskManag=
er.scala:114)
>
>         at
> akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$=
finishTerminate(FaultHandling.scala:210)
>
>         at
> akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
>
>         at akka.actor.ActorCell.terminate(ActorCell.scala:369)
>
>         at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
>
>         at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
>
>         at
> akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
>
>         at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.jav=
a:1339)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
>         at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.j=
ava:107)
>
> 09:56:52,518 INFO
> org.apache.flink.runtime.taskmanager.Task                     - Attemptin=
g
> to fail task externally CHAIN DataSource (at
> createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (1/3)
>
> 09:56:52,519 INFO
> org.apache.flink.runtime.taskmanager.Task                     - CHAIN
> DataSource (at createInput(ExecutionEnvironment.java:502)
> (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -> FlatMa=
p
> (FlatMap at readTable(HiveDAO.java:107)) -> Map (Key Extractor 1) (1/3)
> switched to FAILED with exception.
>
> java.lang.Exception: TaskManager is shutting down.
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.postStop(TaskManager.sca=
la:195)
>
>         at akka.actor.Actor$class.aroundPostStop(Actor.scala:475)
>
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.aroundPostStop(TaskManag=
er.scala:114)
>
>         at
> akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$=
finishTerminate(FaultHandling.scala:210)
>
>         at
> akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
>
>         at akka.actor.ActorCell.terminate(ActorCell.scala:369)
>
>         at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
>
>         at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
>
>         at
> akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
>
>         at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.jav=
a:1339)
>
>         at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
>         at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.j=
ava:107)
>
> 09:56:52,528 INFO
> org.apache.flink.yarn.YarnTaskManager                         -
> Disassociating from JobManager
>
> 09:56:53,242 INFO
> org.apache.flink.runtime.blob.BlobCache                       - Downloadi=
ng
> fa68a8a2d6075c8e3692e1f1ac34dc2dba3d201e from /172.19.115.51:38505
>
> 09:56:53,257 INFO
> org.apache.flink.runtime.io.network.netty.NettyClient         - Successfu=
l
> shutdown (took 10 ms).
>
> 09:56:53,263 INFO
> org.apache.flink.runtime.io.network.netty.NettyServer         - Successfu=
l
> shutdown (took 4 ms).
>
>
>
> ------------------------------
>
> L'int=C3=A9grit=C3=A9 de ce message n'=C3=A9tant pas assur=C3=A9e sur int=
ernet, la soci=C3=A9t=C3=A9
> exp=C3=A9ditrice ne peut =C3=AAtre tenue responsable de son contenu ni de=
 ses pi=C3=A8ces
> jointes. Toute utilisation ou diffusion non autoris=C3=A9e est interdite.=
 Si
> vous n'=C3=AAtes pas destinataire de ce message, merci de le d=C3=A9truir=
e et
> d'avertir l'exp=C3=A9diteur.
>
> The integrity of this message cannot be guaranteed on the Internet. The
> company that sent this message cannot therefore be held liable for its
> content nor attachments. Any unauthorized use or dissemination is
> prohibited. If you are not the intended recipient of this message, then
> please delete it and notify the sender.
>

--089e01227cf078ee40051e5b5bee
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Is the log from 0.9-SNAPSHOT or 0.10-SNAPSHOT?<div><br></d=
iv><div>Can you send me (if you want privately as well) the full log of the=
 yarn application:</div><div><br></div><div>yarn logs -applicationId &lt;ap=
pId&gt;.</div><div><br></div><div>We need to find out why the TaskManagers =
are shutting down. That is most likely logged in the TaskManager logs.</div=
><div><br></div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_qu=
ote">On Fri, Aug 28, 2015 at 10:57 AM, LINZ, Arnaud <span dir=3D"ltr">&lt;<=
a href=3D"mailto:ALINZ@bouyguestelecom.fr" target=3D"_blank">ALINZ@bouygues=
telecom.fr</a>&gt;</span> wrote:<br><blockquote class=3D"gmail_quote" style=
=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">





<div lang=3D"FR" link=3D"blue" vlink=3D"purple">
<div>
<p><span lang=3D"EN-US">Hello,<u></u><u></u></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">I=E2=80=99ve moved my version from 0.9.0 and tried =
both 0.9-SNAPSHOT &amp; 0.10-SNAPSHOT to continue my batch execution on my =
secured cluster thanks to [FLINK-2555].<u></u><u></u></span></p>
<p><span lang=3D"EN-US">My application works nicely in local mode and also =
in yarn mode using a job container started with
</span><span lang=3D"EN-US" style=3D"font-family:&quot;Courier New&quot;">y=
arn-session.sh</span><span lang=3D"EN-US">, but it fails in
</span><span lang=3D"EN-US" style=3D"font-family:&quot;Courier New&quot;">=
=E2=80=93m yarn-cluster</span><span lang=3D"EN-US"> mode<u></u><u></u></spa=
n></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">Yarn logs indicate that =C2=A0=E2=80=9CFlink YARN C=
lient requested shutdown=E2=80=9D but I did nothing like that (or not inten=
tionally). The nodes are not even starting and the exec() does not return a=
ny JobExecutionResult.
<u></u><u></u></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">My command line was :<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-family:&quot;Courier New&quot;">flink=
 run -m yarn-cluster -yd -yn 2 -ytm 1500 -yqu default -ys 4 --class &lt;myM=
ainClass&gt; &lt;myJar&gt; &lt;some options&gt;<u></u><u></u></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">Any idea what I=E2=80=99ve done wrong?<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">Greetings,<u></u><u></u></span></p>
<p><span lang=3D"EN-US">Arnaud<u></u><u></u></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
<p><span lang=3D"EN-US">PS - Yarn log extract :<u></u><u></u></span></p>
<p><span lang=3D"EN-US">(=E2=80=A6)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:29,111 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Succes=
sful registration at JobManager (akka.tcp://<a href=3D"http://flink@172.19.=
115.51:54806/user/jobmanager" target=3D"_blank">flink@172.19.115.51:54806/u=
ser/jobmanager</a>),
 starting network stack and library cache.<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:29,817 INFO=C2=A0 org.apache.flink.runtime.io.network.nett=
y.NettyClient=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Successful =
initialization (took 73 ms).<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:29,889 INFO=C2=A0 org.apache.flink.runtime.io.network.nett=
y.NettyServer=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Successful =
initialization (took 55 ms). Listening on SocketAddress /<a href=3D"http://=
172.19.115.52:41920" target=3D"_blank">172.19.115.52:41920</a>.<u></u><u></=
u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:29,890 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Determ=
ined BLOB server address to be /<a href=3D"http://172.19.115.51:38505" targ=
et=3D"_blank">172.19.115.51:38505</a>. Starting BLOB cache.<u></u><u></u></=
span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:29,893 INFO=C2=A0 org.apache.flink.runtime.blob.BlobCache=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Created BLOB ca=
che storage directory /tmp/blobStore-7150f7d7-f7a3-4c4c-9cda-3877da5aacd6<u=
></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,367 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Receiv=
ed task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502) (or=
g.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 1) (1/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,375 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Receiv=
ed task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502) (or=
g.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 1) (3/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,383 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 =
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0- Loading JAR files for tas=
k CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 1) (1=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,387 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Loading JAR files for ta=
sk CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 1) (3=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,394 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Receiv=
ed task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502) (or=
g.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 2) (1/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,402 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Loading JAR files for ta=
sk CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 2) (1=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,425 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Receiv=
ed task CHAIN DataSource (at createInput(ExecutionEnvironment.java:502) (or=
g.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 2) (2/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,429 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Loading JAR files for ta=
sk CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 2) (2=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,454 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Stoppi=
ng YARN TaskManager with final application status FAILED and diagnostics: F=
link
 YARN Client requested shutdown<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,480 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Stoppi=
ng TaskManager akka://flink/user/taskmanager#2116513584.<u></u><u></u></spa=
n></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,483 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Cancel=
ling all computations and discarding all cached data.<u></u><u></u></span><=
/p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,486 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Attempting to fail task =
externally CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 1) (3=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,486 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - CHAIN DataSource (at cre=
ateInput(ExecutionEnvironment.java:502) (org.apache.flink.api.java.hadoop.m=
apreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 1) (3/3) switched to FAILED with exception.<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">java.lang.Exception: TaskManager is shutting down.<u></u><u></u>=
</span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.postStop(TaskManager.scala:195)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.Actor$c=
lass.aroundPostStop(Actor.scala:475)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.aroundPostStop(TaskManager.scala:114)<u></u>=
<u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(Faul=
tHandling.scala:210)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.terminate(FaultHandling.scala:172)<u></u><u></u></span=
></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.terminate(ActorCell.scala:369)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.invokeAll$1(ActorCell.scala:462)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.systemInvoke(ActorCell.scala:478)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.processAllSystemMessages(Mailbox.scala:279)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.run(Mailbox.scala:220)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.exec(Mailbox.scala:231)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)<u></u><u></u></span>=
</p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)<u></u><u></=
u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,511 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 =C2=A0=C2=A0- Attempting to fail task =
externally CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 2) (1=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,511 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - CHAIN DataSource (at cre=
ateInput(ExecutionEnvironment.java:502) (org.apache.flink.api.java.hadoop.m=
apreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 2) (1/3) switched to FAILED with exception.<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">java.lang.Exception: TaskManager is shutting down.<u></u><u></u>=
</span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.postStop(TaskManager.scala:195)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.Actor$c=
lass.aroundPostStop(Actor.scala:475)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.aroundPostStop(TaskManager.scala:114)<u></u>=
<u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(Faul=
tHandling.scala:210)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.terminate(FaultHandling.scala:172)<u></u><u></u></span=
></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.terminate(ActorCell.scala:369)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.invokeAll$1(ActorCell.scala:462)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.systemInvoke(ActorCell.scala:478)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.processAllSystemMessages(Mailbox.scala:279)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.run(Mailbox.scala:220)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.exec(Mailbox.scala:231)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)<u></u><u></u></span>=
</p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)<u></u><u></=
u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,515 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Attempting to fail task =
externally CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 2) (2=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,515 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - CHAIN DataSource (at cre=
ateInput(ExecutionEnvironment.java:502) (org.apache.flink.api.java.hadoop.m=
apreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 2) (2/3) switched to FAILED with exception.<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">java.lang.Exception: TaskManager is shutting down.<u></u><u></u>=
</span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.postStop(TaskManager.scala:195)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.Actor$c=
lass.aroundPostStop(Actor.scala:475)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.aroundPostStop(TaskManager.scala:114)<u></u>=
<u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(Faul=
tHandling.scala:210)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.terminate(FaultHandling.scala:172)<u></u><u></u></span=
></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.terminate(ActorCell.scala:369)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.invokeAll$1(ActorCell.scala:462)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.systemInvoke(ActorCell.scala:478)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.processAllSystemMessages(Mailbox.scala:279)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.run(Mailbox.scala:220)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.exec(Mailbox.scala:231)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)<u></u><u></u></span>=
</p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)<u></u><u></=
u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,518 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Attempting to fail task =
externally CHAIN DataSource (at createInput(ExecutionEnvironment.java:502)
 (org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat)) -&gt; Flat=
Map (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extractor 1) (1=
/3)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,519 INFO=C2=A0 org.apache.flink.runtime.taskmanager.Tas=
k=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - CHAIN DataSource (at cre=
ateInput(ExecutionEnvironment.java:502) (org.apache.flink.api.java.hadoop.m=
apreduce.HadoopInputFormat))
 -&gt; FlatMap (FlatMap at readTable(HiveDAO.java:107)) -&gt; Map (Key Extr=
actor 1) (1/3) switched to FAILED with exception.<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">java.lang.Exception: TaskManager is shutting down.<u></u><u></u>=
</span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.postStop(TaskManager.scala:195)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.Actor$c=
lass.aroundPostStop(Actor.scala:475)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at org.apache.flink.r=
untime.taskmanager.TaskManager.aroundPostStop(TaskManager.scala:114)<u></u>=
<u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(Faul=
tHandling.scala:210)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.dungeon=
.FaultHandling$class.terminate(FaultHandling.scala:172)<u></u><u></u></span=
></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.terminate(ActorCell.scala:369)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.invokeAll$1(ActorCell.scala:462)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.actor.ActorCe=
ll.systemInvoke(ActorCell.scala:478)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.processAllSystemMessages(Mailbox.scala:279)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.run(Mailbox.scala:220)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at akka.dispatch.Mail=
box.exec(Mailbox.scala:231)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)<u></u><u></u=
></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)<u></u><u></u></span>=
</p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 at scala.concurrent.f=
orkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)<u></u><u></=
u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:52,528 INFO=C2=A0 org.apache.flink.yarn.YarnTaskManager=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Disass=
ociating from JobManager<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:53,242 INFO=C2=A0 org.apache.flink.runtime.blob.BlobCache=
=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=
=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Downloading fa6=
8a8a2d6075c8e3692e1f1ac34dc2dba3d201e from /<a href=3D"http://172.19.115.51=
:38505" target=3D"_blank">172.19.115.51:38505</a><u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:53,257 INFO=C2=A0 org.apache.flink.runtime.io.network.nett=
y.NettyClient=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Successful =
shutdown (took 10 ms).<u></u><u></u></span></p>
<p><span lang=3D"EN-US" style=3D"font-size:8.0pt;font-family:&quot;Courier =
New&quot;">09:56:53,263 INFO=C2=A0 org.apache.flink.runtime.io.network.nett=
y.NettyServer=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 - Successful =
shutdown (took 4 ms).<u></u><u></u></span></p>
<p><span lang=3D"EN-US"><u></u>=C2=A0<u></u></span></p>
</div>
<br>
<hr>
<font face=3D"Arial" color=3D"Gray" size=3D"1"><br>
L&#39;int=C3=A9grit=C3=A9 de ce message n&#39;=C3=A9tant pas assur=C3=A9e s=
ur internet, la soci=C3=A9t=C3=A9 exp=C3=A9ditrice ne peut =C3=AAtre tenue =
responsable de son contenu ni de ses pi=C3=A8ces jointes. Toute utilisation=
 ou diffusion non autoris=C3=A9e est interdite. Si vous n&#39;=C3=AAtes pas=
 destinataire de ce message,
 merci de le d=C3=A9truire et d&#39;avertir l&#39;exp=C3=A9diteur.<br>
<br>
The integrity of this message cannot be guaranteed on the Internet. The com=
pany that sent this message cannot therefore be held liable for its content=
 nor attachments. Any unauthorized use or dissemination is prohibited. If y=
ou are not the intended recipient
 of this message, then please delete it and notify the sender.<br>
</font>
</div>

</blockquote></div><br></div>

--089e01227cf078ee40051e5b5bee--