Hi Nagireddy, Pls try to use '-Dlog4j.configuration=file:/opt/test/flink/log4j.properties'.
Regards, Xiangyu Y SREEKARA BHARGAVA REDDY <ynagiredd...@gmail.com> 于2023年11月3日周五 19:45写道： > Yes, I went through that document. > > How can i override log4j.properties with my custom log4j.properties( > */opt/test/flink/log4j.properties*). > > is it possible right?. in flink didn't find it. > > Any through on the above. > > Regards, > Nagireddy Y. > > > > On Fri, Nov 3, 2023 at 12:18 PM xiangyu feng <xiangyu...@gmail.com> wrote: > >> Hi Nagireddy, >> >> You can configure logging for your 1.16 job according to this doc[1]. >> >> [1] >> https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/advanced/logging/ >> >> Regards >> Xiangyu, >> >> >> >> Y SREEKARA BHARGAVA REDDY <ynagiredd...@gmail.com> 于2023年11月3日周五 08:57写道： >> >>> Hi Xiangyu, >>> >>> I have one issue, >>> >>> I am using *Flink** 1.16* version, How can i specify log4j.properties >>> for the flink run command line along with my job. >>> every job i need to pass different log file. >>> >>> looks like below one is not working: -Dlog4j.configurationFile= >>> Please help me with correct config for the flink run command. >>> >>> Regards, >>> Nagireddy Y. >>> >>> >>> >>> >>> On Thu, Aug 3, 2023 at 7:24 AM xiangyu feng <xiangyu...@gmail.com> >>> wrote: >>> >>>> Hi ynagireddy4u, >>>> >>>> We have met this exception before. Usually it is caused by following >>>> reasons: >>>> >>>> 1), TaskManager is too busy with other works to send the heartbeat to >>>> JobMaster or TaskManager process might already exited; >>>> 2), There might be a network issues between this TaskManager and >>>> JobMaster; >>>> 3), In certain cases, JobMaster actor might also being too busy to >>>> process the RPC requests from TaskManager; >>>> >>>> Pls check if your problem fits the above situations. >>>> >>>> Best, >>>> Xiangyu >>>> >>>> >>>> Y SREEKARA BHARGAVA REDDY <ynagiredd...@gmail.com> 于2023年7月31日周一 >>>> 20:49写道： >>>> >>>>> Hi Team, >>>>> >>>>> Did any one face the below exception. >>>>> If yes, please share the resolution. >>>>> >>>>> >>>>> 2023-07-28 22:04:16 >>>>> j*ava.util.concurrent.TimeoutException: Heartbeat of TaskManager with >>>>> id >>>>> container_e19_1690528962823_0382_01_000005 timed out.* >>>>> at org.apache.flink.runtime.jobmaster. >>>>> JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster >>>>> .java:1147) >>>>> at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run( >>>>> HeartbeatMonitorImpl.java:109) >>>>> at >>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java: >>>>> 511) >>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:266) >>>>> at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync( >>>>> AkkaRpcActor.java:397) >>>>> at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage( >>>>> AkkaRpcActor.java:190) >>>>> at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor >>>>> .handleRpcMessage(FencedAkkaRpcActor.java:74) >>>>> at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage( >>>>> AkkaRpcActor.java:152) >>>>> at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) >>>>> at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) >>>>> at >>>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) >>>>> at akka.japi.pf >>>>> .UnitCaseStatement.applyOrElse(CaseStatements.scala:21) >>>>> at >>>>> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) >>>>> at >>>>> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) >>>>> at >>>>> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) >>>>> at akka.actor.Actor$class.aroundReceive(Actor.scala:517) >>>>> at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) >>>>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) >>>>> at akka.actor.ActorCell.invoke(ActorCell.scala:561) >>>>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) >>>>> at akka.dispatch.Mailbox.run(Mailbox.scala:225) >>>>> at akka.dispatch.Mailbox.exec(Mailbox.scala:235) >>>>> at >>>>> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >>>>> at >>>>> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool >>>>> .java:1339) >>>>> at >>>>> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >>>>> at >>>>> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread >>>>> .java:107) >>>>> >>>>> Any suggestions, please share with me. >>>>> >>>>> Regards, >>>>> Nagireddy Y >>>>> >>>>
