[jira] [Commented] (FLINK-11498) Getting java.lang.InstantiationError when trying to install flink 1.7.1 version through ansible

["sambi reddy (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757529#comment-16757529 ] 

sambi reddy commented on FLINK-11498:
-------------------------------------

First, I tried to install 1.7.1 version on the cluster which is running 1.3.2, seeing the above error, tried to install it on fresh boxes but still seeing the same issue.

> Getting java.lang.InstantiationError when trying to install flink 1.7.1 version through ansible
> -----------------------------------------------------------------------------------------------
>
>                 Key: FLINK-11498
>                 URL: https://issues.apache.org/jira/browse/FLINK-11498
>             Project: Flink
>          Issue Type: Bug
>    Affects Versions: 1.7.1
>         Environment: Openstack
>            Reporter: sambi reddy
>            Priority: Major
>             Fix For: 1.7.1
>
>   Original Estimate: 5h
>  Remaining Estimate: 5h
>
> We trying to install flink on our cloud with the help ansible automation. we were running 1.3.2 since past two years. using the similar kind of automation with few config changes and trying to start the cluster but failing to do so.
> Error we are seeing in the logs.
> {noformat}
> Starting the SlotManager.
> Fatal error occurred in the cluster entrypoint.
> java.lang.InstantiationError: org.apache.flink.runtime.blob.BlobKey
> at sun.reflect.GeneratedSerializationConstructorAccessor43.newInstance(Unknown Source)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
> at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1006)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2011)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
> at java.util.ArrayList.readObject(ArrayList.java:791)
> at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1058)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2136)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2245)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2245)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
> at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:524)
> at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:503)
> at org.apache.flink.runtime.state.RetrievableStreamStateHandle.retrieveState(RetrievableStreamStateHandle.java:58)
> at org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.recoverJobGraph(ZooKeeperSubmittedJobGraphStore.java:202)
> at org.apache.flink.runtime.dispatcher.Dispatcher.recoverJob(Dispatcher.java:696)
> at org.apache.flink.runtime.dispatcher.Dispatcher.recoverJobGraphs(Dispatcher.java:681)
> at org.apache.flink.runtime.dispatcher.Dispatcher.recoverJobs(Dispatcher.java:662)
> at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$null$26(Dispatcher.java:821)
> at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:72)
> at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602)
> at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
> at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
> at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
> at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Shutting down BLOB cache
> Stopped BLOB server at 0.0.0.0:44036{noformat}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)