Re: Flink 1.11 not showing logs
Posted by
Yang Wang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-1-11-not-showing-logs-tp39115p39120.html
Hi Diwakar Jha,
From the logs you have provided, everything seems working as expected. The JobManager and TaskManager
java processes have been started with correct dynamic options, especially for the logging.
Could you share the content of $FLINK_HOME/conf/log4j.properties? I think there's something wrong with the
log4j config file. For example, it is a log4j1 format. But we are using log4j2 in Flink 1.11.
Best,
Yang
Hi
I'm running Flink 1.11 on EMR 6.1.0. I can see my job is running fine but i'm not seeing any taskmanager/jobmanager logs.
I see the below error in stdout.
18:29:19.834 [flink-akka.actor.default-dispatcher-28] ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler - Failed to transfer file from TaskExecutor container_1604033334508_0001_01_000004.
java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: The file LOG does not exist on the TaskExecutor.
I'm stuck at this step for a couple of days now and not able to migrate to Flink 1.11. I would appreciate it if anyone can help me.
i have the following setup :
a) i'm deploying flink using yarn. I have attached yarn application id logs.
c) stsd setup
metrics.reporters: stsd
metrics.reporter.stsd.factory.class: org.apache.flink.metrics.statsd.StatsDReporterFactory
metrics.reporter.stsd.host: localhost
metrics.reporter.stsd.port: 8125