[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sambi reddy updated FLINK-11498:
--------------------------------
Summary: Getting java.lang.InstantiationError when trying to install flink
1.7.1 version (was: Getting java.lang.InstantiationError when trying to
install flink 1.7.1 version through ansible)
> Getting java.lang.InstantiationError when trying to install flink 1.7.1
> version
> --------------------------------------------------------------------------------
>
> 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 are trying to install flink on our cloud with the help of ansible
> automation. we were running 1.3.2 since past two years. using the similar
> kind of automation with few config changes, deployed the latest version and
> trying to install it but failing to start cluster.
> 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)
