Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
Description
In Flink codebase, the org.apache.flink.client.program.ContextEnvironment has a static Logger defined in the class, however, it doesn’t use it to print any logs. Instead, it prints logs with System.out and passes the Logger to ShutdownHookUtil.addShutdownHook and jobExecutionResultFuture.whenComplete for logging any hook errors. If customer integrated the CLI (‘FlinkYarnSessionCli’ in their case) into a multi-threaded program to submit jobs in parallel, does it lead to any logs missing/override/disorder problems?
It is always helpful to log the status information during the job submit process.