flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sunny yun <seonhee....@gmail.com>
Subject Re: FLINK-6117 issue work around
Date Thu, 07 Sep 2017 01:28:49 GMT
Nico, thank you for your reply./I looked at the commit you cherry-picked and
nothing in there explains theerror you got./==> The commit I cherry-picked
makes setting of 'zookeeper.sasl.disable' work correctly. I changed
flink-dist_2.11-1.2.0.jar according to it.So now zookeeper.sasl problem is
gone.Yes, the error log I posted in the original message is completely
different one./Can you verify that nothing of your flink 1.3 tests
remains/==> Below is what I just reproduced. I have 4 nodes cluster with
non-secure.After run yarn-session.sh, JM process be created in flink-03 node
but TM process not.Standalone works well.Any clue would be really
appreciate. Thanks.[bistel@flink-01 ~]$ jps1888 ResourceManager2000
NodeManager2433 NameNode2546 DataNode2754 SecondaryNameNode2891 Jps1724
QuorumPeerMain[bistel@flink-02 ~]$ jps2018 Jps1721 NodeManager1881
DataNode1515 QuorumPeerMain[bistel@flink-03 ~]$ jps1521 QuorumPeerMain1975
Jps1724 NodeManager1885 DataNode[bistel@flink-04 ~]$ jps2090 Jps1515
QuorumPeerMain1789 NodeManager1950 DataNode[bistel@flink-01 ~]$
/usr/local/flink-1.2.0/bin/yarn-session.sh -n 42017-09-07 09:49:35,467 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: jobmanager.rpc.address, flink-012017-09-07
09:49:35,468 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.rpc.port, 61232017-09-07
09:49:35,468 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.heap.mb, 40962017-09-07
09:49:35,468 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.heap.mb, 81922017-09-07
09:49:35,468 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.numberOfTaskSlots, 42017-09-07
09:49:35,469 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.memory.preallocate,
false2017-09-07 09:49:35,469 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: parallelism.default, 42017-09-07 09:49:35,469 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: jobmanager.web.port, 80812017-09-07 09:49:35,469
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: fs.hdfs.hadoopconf,
/usr/local/hadoop/etc/hadoop/2017-09-07 09:49:35,470 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability, zookeeper2017-09-07 09:49:35,470
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: high-availability.zookeeper.quorum,
flink-01:2181,flink-02:2181,flink-03:2181,flink-04:21812017-09-07
09:49:35,470 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: high-availability.zookeeper.path.root,
/flink2017-09-07 09:49:35,470 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.path.namespace,
/cluster_one2017-09-07 09:49:35,470 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.storageDir,
hdfs:///flink/recovery2017-09-07 09:49:35,470 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.application-attempts, 102017-09-07 09:49:35,470
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: yarn.containers.vcores, 202017-09-07
09:49:35,471 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property:
yarn.application-master.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:35,471 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.taskmanager.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:35,471 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: zookeeper.sasl.disable, true2017-09-07 09:49:35,662
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: jobmanager.rpc.address, flink-012017-09-07
09:49:35,662 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.rpc.port, 61232017-09-07
09:49:35,662 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.heap.mb, 40962017-09-07
09:49:35,663 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.heap.mb, 81922017-09-07
09:49:35,663 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.numberOfTaskSlots, 42017-09-07
09:49:35,663 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.memory.preallocate,
false2017-09-07 09:49:35,663 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: parallelism.default, 42017-09-07 09:49:35,663 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: jobmanager.web.port, 80812017-09-07 09:49:35,663
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: fs.hdfs.hadoopconf,
/usr/local/hadoop/etc/hadoop/2017-09-07 09:49:35,664 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability, zookeeper2017-09-07 09:49:35,664
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: high-availability.zookeeper.quorum,
flink-01:2181,flink-02:2181,flink-03:2181,flink-04:21812017-09-07
09:49:35,664 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: high-availability.zookeeper.path.root,
/flink2017-09-07 09:49:35,664 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.path.namespace,
/cluster_one2017-09-07 09:49:35,664 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.storageDir,
hdfs:///flink/recovery2017-09-07 09:49:35,664 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.application-attempts, 102017-09-07 09:49:35,664
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: yarn.containers.vcores, 202017-09-07
09:49:35,664 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property:
yarn.application-master.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:35,665 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.taskmanager.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:35,665 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: zookeeper.sasl.disable, true2017-09-07 09:49:36,519
WARN  org.apache.hadoop.util.NativeCodeLoader                       - Unable
to load native-hadoop library for your platform... using builtin-java
classes where applicable2017-09-07 09:49:36,779 INFO 
org.apache.flink.runtime.security.modules.HadoopModule        - Hadoop user
set to bistel (auth:SIMPLE)2017-09-07 09:49:37,084 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: jobmanager.rpc.address, flink-012017-09-07
09:49:37,084 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.rpc.port, 61232017-09-07
09:49:37,084 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: jobmanager.heap.mb, 40962017-09-07
09:49:37,084 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.heap.mb, 81922017-09-07
09:49:37,084 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.numberOfTaskSlots, 42017-09-07
09:49:37,084 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: taskmanager.memory.preallocate,
false2017-09-07 09:49:37,085 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: parallelism.default, 42017-09-07 09:49:37,085 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: jobmanager.web.port, 80812017-09-07 09:49:37,085
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: fs.hdfs.hadoopconf,
/usr/local/hadoop/etc/hadoop/2017-09-07 09:49:37,085 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability, zookeeper2017-09-07 09:49:37,085
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: high-availability.zookeeper.quorum,
flink-01:2181,flink-02:2181,flink-03:2181,flink-04:21812017-09-07
09:49:37,085 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property: high-availability.zookeeper.path.root,
/flink2017-09-07 09:49:37,085 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.path.namespace,
/cluster_one2017-09-07 09:49:37,085 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: high-availability.zookeeper.storageDir,
hdfs:///flink/recovery2017-09-07 09:49:37,086 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.application-attempts, 102017-09-07 09:49:37,086
INFO  org.apache.flink.configuration.GlobalConfiguration            -
Loading configuration property: yarn.containers.vcores, 202017-09-07
09:49:37,086 INFO  org.apache.flink.configuration.GlobalConfiguration           
- Loading configuration property:
yarn.application-master.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:37,086 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: yarn.taskmanager.env.LD_LIBRARY_PATH,
/opt/tibco/TIBRV/8.0/lib2017-09-07 09:49:37,086 INFO 
org.apache.flink.configuration.GlobalConfiguration            - Loading
configuration property: zookeeper.sasl.disable, true2017-09-07 09:49:37,103
INFO  org.apache.flink.yarn.YarnClusterDescriptor                   - Using
values:2017-09-07 09:49:37,103 INFO 
org.apache.flink.yarn.YarnClusterDescriptor                   -  
TaskManager count = 42017-09-07 09:49:37,103 INFO 
org.apache.flink.yarn.YarnClusterDescriptor                   -   JobManager
memory = 10242017-09-07 09:49:37,103 INFO 
org.apache.flink.yarn.YarnClusterDescriptor                   -  
TaskManager memory = 10242017-09-07 09:49:37,118 INFO 
org.apache.hadoop.yarn.client.RMProxy                         - Connecting
to ResourceManager at flink-01/10.1.0.4:80322017-09-07 09:49:39,084 INFO 
org.apache.flink.yarn.Utils                                   - Copying from
file:/usr/local/flink-1.2.0/lib to
hdfs://flink-01:9000/user/bistel/.flink/application_1504745288687_0001/lib2017-09-07
09:49:43,419 INFO  org.apache.flink.yarn.Utils                                  
- Copying from file:/usr/local/flink-1.2.0/conf/log4j.properties to
hdfs://flink-01:9000/user/bistel/.flink/application_1504745288687_0001/log4j.properties2017-09-07
09:49:43,552 INFO  org.apache.flink.yarn.Utils                                  
- Copying from file:/usr/local/flink-1.2.0/lib/flink-dist_2.11-1.2.0.jar to
hdfs://flink-01:9000/user/bistel/.flink/application_1504745288687_0001/flink-dist_2.11-1.2.0.jar2017-09-07
09:49:43,816 INFO  org.apache.flink.yarn.Utils                                  
- Copying from /usr/local/flink-1.2.0/conf/flink-conf.yaml to
hdfs://flink-01:9000/user/bistel/.flink/application_1504745288687_0001/flink-conf.yaml2017-09-07
09:49:43,903 INFO  org.apache.flink.yarn.YarnClusterDescriptor                  
- Submitting application master application_1504745288687_00012017-09-07
09:49:44,011 INFO  org.apache.hadoop.yarn.client.api.impl.YarnClientImpl        
- Submitted application application_1504745288687_00012017-09-07
09:49:44,011 INFO  org.apache.flink.yarn.YarnClusterDescriptor                  
- Waiting for the cluster to be allocated2017-09-07 09:49:44,030 INFO 
org.apache.flink.yarn.YarnClusterDescriptor                   - Deploying
cluster, current state ACCEPTED2017-09-07 09:49:50,326 INFO 
org.apache.flink.yarn.YarnClusterDescriptor                   - YARN
application has been deployed successfully.Exception in thread "main"
java.lang.RuntimeException: Failed to retrieve JobManager address        at
org.apache.flink.client.program.ClusterClient.getJobManagerAddress(ClusterClient.java:248)
      
at
org.apache.flink.yarn.cli.FlinkYarnSessionCli.run(FlinkYarnSessionCli.java:627)       
at
org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.java:476)       
at
org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.java:473)       
at
org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43)
      
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:1656)     
 
at
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)
      
at
org.apache.flink.yarn.cli.FlinkYarnSessionCli.main(FlinkYarnSessionCli.java:473)Caused
by: org.apache.flink.runtime.leaderretrieval.LeaderRetrievalException: Could
not retrieve the leader address and leader session ID.        at
org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalUtils.java:175)
      
at
org.apache.flink.client.program.ClusterClient.getJobManagerAddress(ClusterClient.java:242)
      
... 9 moreCaused by: java.util.concurrent.TimeoutException: Futures timed
out after [60000 milliseconds]        at
scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)       
at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)       
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190)       
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)       
at scala.concurrent.Await$.result(package.scala:190)        at
scala.concurrent.Await.result(package.scala)        at
org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalUtils.java:173)
      
... 10 more2017-09-07 09:50:51,519 INFO 
org.apache.flink.yarn.YarnClusterClient                       - Shutting
down YarnClusterClient from the client shutdown hook2017-09-07 09:50:51,519
INFO  org.apache.flink.yarn.YarnClusterClient                       -
Sending shutdown request to the Application Master2017-09-07 09:50:51,549
INFO  org.apache.flink.yarn.YarnClusterClient                       - Start
application client.2017-09-07 09:50:51,549 INFO 
org.apache.flink.yarn.YarnClusterClient                       - Starting
client actor system.2017-09-07 09:50:51,807 INFO 
akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger
started2017-09-07 09:50:51,836 INFO  Remoting                                            
        
- Starting remoting2017-09-07 09:50:51,936 INFO  Remoting                                
                    
- Remoting started; listening on addresses
:[akka.tcp://flink@flink-01:45463]2017-09-07 09:50:51,954 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:52,967 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:53,986 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:55,007 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:56,026 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:57,047 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:58,067 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:50:59,087 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:51:00,107 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:51:01,127 INFO 
org.apache.flink.yarn.ApplicationClient                       - Sending
StopCluster request to JobManager.2017-09-07 09:51:01,944 WARN 
org.apache.flink.yarn.YarnClusterClient                       - Error while
stopping YARN cluster.java.util.concurrent.TimeoutException: Futures timed
out after [10000 milliseconds]        at
scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)       
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153)       
at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:169)       
at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:169)       
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)       
at scala.concurrent.Await$.ready(package.scala:169)        at
scala.concurrent.Await.ready(package.scala)        at
org.apache.flink.yarn.YarnClusterClient.shutdownCluster(YarnClusterClient.java:372)      

at
org.apache.flink.yarn.YarnClusterClient.finalizeCluster(YarnClusterClient.java:342)      

at
org.apache.flink.client.program.ClusterClient.shutdown(ClusterClient.java:208)       
at
org.apache.flink.yarn.YarnClusterClient$ClientShutdownHook.run(YarnClusterClient.java:446)2017-09-07
09:51:01,946 INFO  org.apache.flink.yarn.YarnClusterClient                      
- Deleted Yarn properties file at /tmp/.yarn-properties-bistel2017-09-07
09:51:01,946 INFO  org.apache.flink.yarn.YarnClusterClient                      
- Deleting files in
hdfs://flink-01:9000/user/bistel/.flink/application_1504745288687_00012017-09-07
09:51:02,146 INFO  org.apache.flink.yarn.ApplicationClient                      
- Sending StopCluster request to JobManager.2017-09-07 09:51:02,490 INFO 
org.apache.flink.yarn.YarnClusterClient                       - Application
application_1504745288687_0001 finished with state RUNNING and final state
UNDEFINED at 02017-09-07 09:51:02,490 INFO 
org.apache.flink.yarn.YarnClusterClient                       - YARN Client
is shutting down2017-09-07 09:51:02,598 INFO 
org.apache.flink.yarn.ApplicationClient                       - Stopped
Application client.2017-09-07 09:51:02,599 INFO 
org.apache.flink.yarn.ApplicationClient                       - Disconnect
from JobManager null.2017-09-07 09:51:02,633 INFO 
akka.remote.RemoteActorRefProvider$RemotingTerminator         - Shutting
down remote daemon.2017-09-07 09:51:02,635 INFO 
akka.remote.RemoteActorRefProvider$RemotingTerminator         - Remote
daemon shut down; proceeding with flushing remote transports.2017-09-07
09:51:02,651 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        
- Remoting shut down.[bistel@flink-01 ~]$ jps1888 ResourceManager2000
NodeManager2433 NameNode2546 DataNode2754 SecondaryNameNode3143 Jps1724
QuorumPeerMain[bistel@flink-02 ~]$ jps2018 Jps1721 NodeManager1881
DataNode1515 QuorumPeerMain[bistel@flink-03 ~]$ jps1521 QuorumPeerMain2054
YarnApplicationMasterRunner1724 NodeManager1885 DataNode2142
Jps[bistel@flink-04 ~]$ jps2090 Jps1515 QuorumPeerMain1789 NodeManager1950
DataNode
Nico Kruber wrote
> I looked at the commit you cherry-picked and nothing in there explains the
> error you got. This rather sounds like something might be mixed up between
> (remaining artefacts of) flink 1.3 and 1.2.Can you verify that nothing of
> your flink 1.3 tests remains, e.g. running JobManager or TaskManager
> instances? Also that you're not accidentally running the yarn-session.sh
> script of 1.3?NicoOn Wednesday, 6 September 2017 06:36:42 CEST Sunny Yun
> wrote:> Hi,> > Using flink 1.2.0, I faced to issue>
> https://issues.apache.org/jira/browse/FLINK-6117>
> https://issues.apache.org/jira/browse/FLINK-6117.> This issue is fixed at
> version 1.3.0. But I have some reason to trying to> find out work around.>
> > I did,> 1. change source according to>
> https://github.com/apache/flink/commit/eef85e095a8a0e4c4553631b74ba7b9f173ce>
> bf0 2. replace $FLINK_HOME/lib/flink-dist_2.11-1.2.0.jar> 3. set
> flink-conf.yaml "zookeeper.sasl.disable: true"> 4. run yarn-session.sh> >
> > Original problem-Authentication failed- seems to be passed.> But I got
> this error,> > Exception in thread "main" java.lang.RuntimeException:
> Failed to retrieve> JobManager address>         at>
> org.apache.flink.client.program.ClusterClient.getJobManagerAddress(ClusterCl>
> ient.java:248) at>
> org.apache.flink.yarn.cli.FlinkYarnSessionCli.run(FlinkYarnSessionCli.java:6>
> 27) at>
> org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.jav>
> a:476) at>
> org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.jav>
> a:473) at>
> org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurity>
> Context.java:43) at java.security.AccessController.doPrivileged(Native>
> Method) at javax.security.auth.Subject.doAs(Subject.java:422)>         at>
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.ja>
> va:1656) at>
> org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSec>
> urityContext.java:40) at>
> org.apache.flink.yarn.cli.FlinkYarnSessionCli.main(FlinkYarnSessionCli.java:>
> 473) Caused by:>
> org.apache.flink.runtime.leaderretrieval.LeaderRetrievalException: Could>
> not retrieve the leader address and leader session ID.>         at>
> org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderConnectionI>
> nfo(LeaderRetrievalUtils.java:175) at>
> org.apache.flink.client.program.ClusterClient.getJobManagerAddress(ClusterCl>
> ient.java:242) ... 9 more> Caused by:
> java.util.concurrent.TimeoutException: Futures timed out after> [60000
> milliseconds]>         at>
> scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)>        
> at>
> scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)>        
> at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190)> at>
> scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scal>
> a:53) at scala.concurrent.Await$.result(package.scala:190)>         at
> scala.concurrent.Await.result(package.scala)>         at>
> org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderConnectionI>
> nfo(LeaderRetrievalUtils.java:173) ... 10 more> > > I believe related
> setting(flink, hadoop, zookeeper) is correct. Because> yarn-session works
> smoothly with flink 1.3.2 in same environment.> > Does anyone have any
> inspiration for this error message?> > Thanks.> > ᐧsignature.asc (201
> bytes)
> &lt;http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/attachment/15426/0/signature.asc&gt;





--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Mime
View raw message