Hi, AFAIK there are no plans currently to release 1.14.4. The previous one (1.14.3) was released on Jan 20, so I'd 1.14.4 preparation to start in the next several weeks.
Regards, Roman On Tue, Feb 8, 2022 at 7:31 PM Sweta Kalakuntla <skalakun...@bandwidth.com> wrote: > I am facing the same issue, do we know when 1.14.4 will be released? > > Thanks. > > On Fri, Jan 21, 2022 at 3:28 AM Chesnay Schepler <ches...@apache.org> > wrote: > >> While FLINK-24550 was indeed fixed unfortunately a similar bug was also >> introduced (https://issues.apache.org/jira/browse/FLINK-25732). >> On 20/01/2022 21:18, Peter Westermann wrote: >> >> Just tried this again with Flink 1.14.3 since >> https://issues.apache.org/jira/browse/FLINK-24550 is listed as fixed. I >> am running into similar errors when calling the /v1/jobs/overview endpoint >> (without any running jobs): >> >> {"errors":["Internal server error.","<Exception on server >> side:\norg.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: >> Failed to serialize the result for RPC call : >> requestMultipleJobDetails.\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:417)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$sendAsyncResponse$2(AkkaRpcActor.java:373)\n\tat >> java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:930)\n\tat >> java.base/java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:946)\n\tat >> java.base/java.util.concurrent.CompletableFuture.handle(CompletableFuture.java:2266)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.sendAsyncResponse(AkkaRpcActor.java:365)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:332)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)\n\tat >> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)\n\tat >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)\n\tat >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)\n\tat >> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)\n\tat >> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)\n\tat >> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)\n\tat >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)\n\tat >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)\n\tat >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)\n\tat >> akka.actor.Actor.aroundReceive(Actor.scala:537)\n\tat >> akka.actor.Actor.aroundReceive$(Actor.scala:535)\n\tat >> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)\n\tat >> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)\n\tat >> akka.actor.ActorCell.invoke(ActorCell.scala:548)\n\tat >> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)\n\tat >> akka.dispatch.Mailbox.run(Mailbox.scala:231)\n\tat >> akka.dispatch.Mailbox.exec(Mailbox.scala:243)\n\tat >> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)\n\tat >> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)\n\tat >> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)\n\tat >> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)\n\tat >> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)\nCaused >> by: java.io.NotSerializableException: java.util.HashMap$Values\n\tat >> java.base/java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1185)\n\tat >> java.base/java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1553)\n\tat >> java.base/java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1510)\n\tat >> java.base/java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1433)\n\tat >> java.base/java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1179)\n\tat >> java.base/java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:349)\n\tat >> org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:632)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcSerializedValue.valueOf(AkkaRpcSerializedValue.java:66)\n\tat >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:400)\n\t... >> 30 more\n\nEnd of exception on server side>"]} >> >> >> >> >> >> >> >> Peter Westermann >> >> Team Lead – Realtime Analytics >> >> [image: cidimage001.jpg@01D78D4C.C00AC080] >> >> peter.westerm...@genesys.com >> >> [image: cidimage001.jpg@01D78D4C.C00AC080] >> >> [image: cidimage002.jpg@01D78D4C.C00AC080] <http://www.genesys.com/> >> >> >> >> >> >> *From: *Dawid Wysakowicz <dwysakow...@apache.org> >> <dwysakow...@apache.org> >> *Date: *Thursday, October 14, 2021 at 10:00 AM >> *To: *Peter Westermann <no.westerm...@genesys.com> >> <no.westerm...@genesys.com>, user@flink.apache.org >> <user@flink.apache.org> <user@flink.apache.org> >> *Subject: *Re: Issue with Flink UI for Flink 1.14.0 >> >> I am afraid it is a bug in flink 1.14. I created a ticket for it >> FLINK-24550[1]. I believe we should pick it up soonish. Thanks for >> reporting the issue! >> >> Best, >> >> Dawid >> >> [1] https://issues.apache.org/jira/browse/FLINK-24550 >> >> On 13/10/2021 20:32, Peter Westermann wrote: >> >> Hello, >> >> >> >> I just started testing Flink 1.14.0 and noticed some weird behavior. This >> is for a Flink cluster with zookeeper for HA and two job managers (one >> leader, one backup). The UI on the leader works fine. The UI on the other >> job manager does not load any job-specific data. Same applies to the REST >> interface. If I requests job data from /v1/jobs/{jobId}, I get the expected >> response on the leader but on the other job manager, I only get an >> exception stack trace: >> >> >> >> {"errors":["Internal server error.","<Exception on server >> side:\njava.util.concurrent.CancellationException\n\tat >> java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2276)\n\tat >> org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.getExecutionGraphInternal(DefaultExecutionGraphCache.java:98)\n\tat >> org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.getExecutionGraphInfo(DefaultExecutionGraphCache.java:67)\n\tat >> org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.handleRequest(AbstractExecutionGraphHandler.java:81)\n\tat >> org.apache.flink.runtime.rest.handler.AbstractRestHandler.respondToRequest(AbstractRestHandler.java:83)\n\tat >> org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:195)\n\tat >> org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83)\n\tat >> java.util.Optional.ifPresent(Optional.java:159)\n\tat >> org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)\n\tat >> org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80)\n\tat >> org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)\n\tat >> org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)\n\tat >> org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:238)\n\tat >> org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:71)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1368)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1234)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1280)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:507)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:446)\n\tat >> org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:276)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:719)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)\n\tat >> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)\n\tat >> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)\n\tat >> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)\n\tat >> java.lang.Thread.run(Thread.java:748)\n\nEnd of exception on server side>"]} >> >> >> >> >> >> Peter Westermann >> >> Team Lead – Realtime Analytics >> >> [image: cidimage001.jpg@01D78D4C.C00AC080] >> >> peter.westerm...@genesys.com >> >> [image: cidimage001.jpg@01D78D4C.C00AC080] >> >> [image: cidimage002.jpg@01D78D4C.C00AC080] <http://www.genesys.com/> >> >> >> >> >>
