Re: after upgrade flink1.12 to flink1.13.1, flink web-ui's taskmanager detail page error
Thanks for the report, Yidan. It will be fixed in FLINK-23024 and hopefully fixed in 1.13.2. Best, Yangze Guo On Fri, Jun 18, 2021 at 10:00 AM yidan zhao wrote: > > Yeah, I also think it is a bug. > > Arvid Heise 于2021年6月17日周四 下午10:13写道： > > > > Hi Yidan, > > > > could you check if the bucket exist and is accessible? Seems like this > > directory cannot be created > > bos://flink-bucket/flink/ha/opera_upd_FlinkTestJob3/blob. > > > > The second issue looks like a bug. I will create a ticket. > > > > On Wed, Jun 16, 2021 at 5:21 AM yidan zhao wrote: > >> > >> does anyone has idea? Here I give another exception stack. > >> > >> > >> Unhandled exception. > >> org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Failed > >> to serialize the result for RPC call : requestTaskManagerDetailsInfo. > >> at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:404) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$sendAsyncResponse$0(AkkaRpcActor.java:360) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836) > >> ~[?:1.8.0_251] at > >> java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:848) > >> ~[?:1.8.0_251] at > >> java.util.concurrent.CompletableFuture.handle(CompletableFuture.java:2168) > >> ~[?:1.8.0_251] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.sendAsyncResponse(AkkaRpcActor.java:352) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:319) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.actor.Actor$class.aroundReceive(Actor.scala:517) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.actor.ActorCell.invoke(ActorCell.scala:561) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.Mailbox.run(Mailbox.scala:225) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.Mailbox.exec(Mailbox.scala:235) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] at > >> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > >> [flink-dist_2.11-1.13.1.jar:1.13.1] Caused by: > >> java.io.NotSerializableException: > >> org.apache.flink.runtime.resourcemanager.TaskManagerInfoWithSlots at > >> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) > >> ~[?:1.8.0_251] at > >> java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348) > >> ~[?:1.8.0_251] at > >> org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:624) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcSerializedValue.valueOf(AkkaRpcSerializedValue.java:66) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at > >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:387) > >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] ... 27 more > >> > >> yidan zhao 于2021年6月11日周五 下午4:10写道： > >> > > >> > I upgrade flink
Re: after upgrade flink1.12 to flink1.13.1, flink web-ui's taskmanager detail page error
Yeah, I also think it is a bug. Arvid Heise 于2021年6月17日周四 下午10:13写道： > > Hi Yidan, > > could you check if the bucket exist and is accessible? Seems like this > directory cannot be created > bos://flink-bucket/flink/ha/opera_upd_FlinkTestJob3/blob. > > The second issue looks like a bug. I will create a ticket. > > On Wed, Jun 16, 2021 at 5:21 AM yidan zhao wrote: >> >> does anyone has idea? Here I give another exception stack. >> >> >> Unhandled exception. >> org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Failed >> to serialize the result for RPC call : requestTaskManagerDetailsInfo. >> at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:404) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$sendAsyncResponse$0(AkkaRpcActor.java:360) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836) >> ~[?:1.8.0_251] at >> java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:848) >> ~[?:1.8.0_251] at >> java.util.concurrent.CompletableFuture.handle(CompletableFuture.java:2168) >> ~[?:1.8.0_251] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.sendAsyncResponse(AkkaRpcActor.java:352) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:319) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.actor.Actor$class.aroundReceive(Actor.scala:517) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.actor.ActorCell.invoke(ActorCell.scala:561) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.Mailbox.run(Mailbox.scala:225) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.Mailbox.exec(Mailbox.scala:235) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >> [flink-dist_2.11-1.13.1.jar:1.13.1] at >> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >> [flink-dist_2.11-1.13.1.jar:1.13.1] Caused by: >> java.io.NotSerializableException: >> org.apache.flink.runtime.resourcemanager.TaskManagerInfoWithSlots at >> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) >> ~[?:1.8.0_251] at >> java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348) >> ~[?:1.8.0_251] at >> org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:624) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcSerializedValue.valueOf(AkkaRpcSerializedValue.java:66) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] at >> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:387) >> ~[flink-dist_2.11-1.13.1.jar:1.13.1] ... 27 more >> >> yidan zhao 于2021年6月11日周五 下午4:10写道： >> > >> > I upgrade flink from 1.12 to 1.13.1, and the rest api >> > (http://xxx:8600/#/task-manager/xxx:34575-c53c6c/metrics) failed. >> > My standalone cluster include 30 Jobmanagers and 30 Taskmanagers, and >> > I found the api only works in the one jobmanager when it is the rest >> > api leader. >> > >> > for example, jobmanager1(http://jobmanager1:8600/#/...) and >> >
Re: after upgrade flink1.12 to flink1.13.1, flink web-ui's taskmanager detail page error
does anyone has idea? Here I give another exception stack. Unhandled exception. org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Failed to serialize the result for RPC call : requestTaskManagerDetailsInfo. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:404) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$sendAsyncResponse$0(AkkaRpcActor.java:360) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836) ~[?:1.8.0_251] at java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:848) ~[?:1.8.0_251] at java.util.concurrent.CompletableFuture.handle(CompletableFuture.java:2168) ~[?:1.8.0_251] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.sendAsyncResponse(AkkaRpcActor.java:352) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:319) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.1.jar:1.13.1] at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.1.jar:1.13.1] Caused by: java.io.NotSerializableException: org.apache.flink.runtime.resourcemanager.TaskManagerInfoWithSlots at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) ~[?:1.8.0_251] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348) ~[?:1.8.0_251] at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:624) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcSerializedValue.valueOf(AkkaRpcSerializedValue.java:66) ~[flink-dist_2.11-1.13.1.jar:1.13.1] at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:387) ~[flink-dist_2.11-1.13.1.jar:1.13.1] ... 27 more yidan zhao 于2021年6月11日周五 下午4:10写道： > > I upgrade flink from 1.12 to 1.13.1, and the rest api > (http://xxx:8600/#/task-manager/xxx:34575-c53c6c/metrics) failed. > My standalone cluster include 30 Jobmanagers and 30 Taskmanagers, and > I found the api only works in the one jobmanager when it is the rest > api leader. > > for example, jobmanager1(http://jobmanager1:8600/#/...) and > jobmanager2(http://jobmanager2:8600/#/...)。The overview works all, but > the taskmanager detail page has this issue. > > Here is the error log: > > > 2021-06-10 13:00:27,395 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - > > 2021-06-10 13:00:27,399 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - > Preconfiguration: > 2021-06-10 13:00:27,400 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - > > > RESOURCE_PARAMS extraction logs: > jvm_params: -Xmx2093796552 -Xms2093796552
after upgrade flink1.12 to flink1.13.1, flink web-ui's taskmanager detail page error
I upgrade flink from 1.12 to 1.13.1, and the rest api (http://xxx:8600/#/task-manager/xxx:34575-c53c6c/metrics) failed. My standalone cluster include 30 Jobmanagers and 30 Taskmanagers, and I found the api only works in the one jobmanager when it is the rest api leader. for example, jobmanager1(http://jobmanager1:8600/#/...) and jobmanager2(http://jobmanager2:8600/#/...)。The overview works all, but the taskmanager detail page has this issue. Here is the error log: 2021-06-10 13:00:27,395 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - 2021-06-10 13:00:27,399 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - Preconfiguration: 2021-06-10 13:00:27,400 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - RESOURCE_PARAMS extraction logs: jvm_params: -Xmx2093796552 -Xms2093796552 -XX:MaxMetaspaceSize=536870912 dynamic_configs: -D jobmanager.memory.off-heap.size=268435456b -D jobmanager.memory.jvm-overhead.min=322122552b -D jobmanager.memory.jvm-metaspace.size=536870912b -D jobmanager.memory.heap.size=2093796552b -D jobmanager.memory.jvm-overhead.max=322122552b logs: INFO [] - Loading configuration property: taskmanager.numberOfTaskSlots, 20 INFO [] - Loading configuration property: cluster.evenly-spread-out-slots, true INFO [] - Loading configuration property: parallelism.default, 1 INFO [] - Loading configuration property: jobmanager.memory.process.size, 3gb INFO [] - Loading configuration property: jobmanager.memory.jvm-metaspace.size, 512mb INFO [] - Loading configuration property: jobmanager.memory.jvm-overhead.fraction, 0.1 INFO [] - Loading configuration property: jobmanager.memory.jvm-overhead.min, 192mb INFO [] - Loading configuration property: jobmanager.memory.jvm-overhead.max, 512mb INFO [] - Loading configuration property: jobmanager.memory.off-heap.size, 256mb INFO [] - Loading configuration property: taskmanager.memory.process.size, 20gb INFO [] - Loading configuration property: taskmanager.memory.jvm-metaspace.size, 512mb INFO [] - Loading configuration property: taskmanager.memory.jvm-overhead.fraction, 0.1 INFO [] - Loading configuration property: taskmanager.memory.jvm-overhead.min, 192mb INFO [] - Loading configuration property: taskmanager.memory.jvm-overhead.max, 512mb INFO [] - Loading configuration property: taskmanager.memory.segment-size, 32kb INFO [] - Loading configuration property: taskmanager.memory.managed.fraction, 0.4 INFO [] - Loading configuration property: taskmanager.memory.managed.size, 64mb INFO [] - Loading configuration property: taskmanager.memory.network.fraction, 0.1 INFO [] - Loading configuration property: taskmanager.memory.network.min, 1gb INFO [] - Loading configuration property: taskmanager.memory.network.max, 2gb INFO [] - Loading configuration property: taskmanager.memory.framework.off-heap.size, 256mb INFO [] - Loading configuration property: taskmanager.memory.task.off-heap.size, 512mb INFO [] - Loading configuration property: taskmanager.memory.framework.heap.size, 256mb INFO [] - Loading configuration property: high-availability, zookeeper INFO [] - Loading configuration property: high-availability.storageDir, bos://flink-bucket/flink/ha INFO [] - Loading configuration property: high-availability.zookeeper.quorum, bjhw-aisecurity-cassandra01.bjhw:9681,bjhw-aisecurity-cassandra02.bjhw:9681,bjhw-aisecurity-cassandra03.bjhw:9681,bjhw-aisecurity-cassandra04.bjhw:9681,bjhw-aisecurity-cassandra05.bjhw:9681 INFO [] - Loading configuration property: high-availability.zookeeper.path.root, /flink INFO [] - Loading configuration property: high-availability.cluster-id, opera_upd_FlinkTestJob3 INFO [] - Loading configuration property: web.checkpoints.history, 100 INFO [] - Loading configuration property: state.checkpoints.num-retained, 100 INFO [] - Loading configuration property: state.checkpoints.dir, bos://flink-bucket/flink/default-checkpoints INFO [] - Loading configuration property: state.savepoints.dir, bos://flink-bucket/flink/default-savepoints INFO [] - Loading configuration property: jobmanager.execution.failover-strategy, region INFO [] - Loading configuration property: web.submit.enable, false INFO [] - Loading configuration property: jobmanager.archive.fs.dir, bos://flink-bucket/flink/completed-jobs/opera_upd_FlinkTestJob3 INFO [] - Loading configuration property: historyserver.archive.fs.dir, bos://flink-bucket/flink/completed-jobs/opera_upd_FlinkTestJob3 INFO [] - Loading configuration property: historyserver.archive.fs.refresh-interval, 1 INFO [] - Loading configuration property: rest.port, 8600 INFO [] - Loading configuration property: historyserver.web.port, 8700 INFO [] - Loading configuration property: high-availability.jobmanager.port, 9318 INFO [] - Loading configuration property: blob.server.port, 9320 INFO [] - Loading configuration property:
