Hi, Have you replaced all of your old Flink binaries with freshly downloaded <https://flink.apache.org/downloads.html> Hadoop 2.7 versions? Are you sure that something hasn't mix in the process?
Does some simple word count example works on the cluster after the upgrade? Piotrek > On 21 Mar 2018, at 16:11, ashish pok <ashish...@yahoo.com> wrote: > > Hi All, > > We ran into a roadblock in our new Hadoop environment, migrating from 2.6 to > 2.7. It was supposed to be an easy lift to get a YARN session but doesnt seem > like :) We definitely are using 2.7 binaries but it looks like there is a > call here to a private methos which screams runtime incompatibility. > > Anyone has seen this and have pointers? > > Thanks, Ashish > Exception in thread "main" java.lang.IllegalAccessError: tried to access > method > org.apache.hadoop.yarn.client.ConfiguredRMFailoverProxyProvider.getProxyInternal()Ljava/lang/Object; > from class > org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider <> > at > org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider.init(RequestHedgingRMFailoverProxyProvider.java:75) > at > org.apache.hadoop.yarn.client.RMProxy.createRMFailoverProxyProvider(RMProxy.java:163) > at > org.apache.hadoop.yarn.client.RMProxy.createRMProxy(RMProxy.java:94) > at > org.apache.hadoop.yarn.client.ClientRMProxy.createRMProxy(ClientRMProxy.java:72) > at > org.apache.hadoop.yarn.client.api.impl.YarnClientImpl.serviceStart(YarnClientImpl.java:187) > at > org.apache.hadoop.service.AbstractService.start(AbstractService.java:193) > at > org.apache.flink.yarn.AbstractYarnClusterDescriptor.getYarnClient(AbstractYarnClusterDescriptor.java:314) > at > org.apache.flink.yarn.AbstractYarnClusterDescriptor.deployInternal(AbstractYarnClusterDescriptor.java:417) > at > org.apache.flink.yarn.AbstractYarnClusterDescriptor.deploySessionCluster(AbstractYarnClusterDescriptor.java:367) > at > org.apache.flink.yarn.cli.FlinkYarnSessionCli.run(FlinkYarnSessionCli.java:679) > at > org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.java:514) > at > org.apache.flink.yarn.cli.FlinkYarnSessionCli$1.call(FlinkYarnSessionCli.java:511) > 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:1698) > at > org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > at > org.apache.flink.yarn.cli.FlinkYarnSessionCli.main(FlinkYarnSessionCli.java:511) >
