Re: Main class logs in Yarn Mode

I think you can try the application mode[1]. [1] https://ci.apache.org/projects/flink/flink-docs-master/deployment/#application-mode Best, Yangze Guo On Tue, Jan 12, 2021 at 5:23 PM bat man wrote: > > Thanks Yangze Gua. > Is there a way these can be redirected to a yarn logs. > > On Tue, 12 Ja

Re: Main class logs in Yarn Mode

Thanks Yangze Gua. Is there a way these can be redirected to a yarn logs. On Tue, 12 Jan 2021 at 2:35 PM, Yangze Guo wrote: > The main function of your WordCountExample is executed in your local > environment. So, the logs you are looking for ("Entering > application.") are be located in your co

Re: Main class logs in Yarn Mode

The main function of your WordCountExample is executed in your local environment. So, the logs you are looking for ("Entering application.") are be located in your console output and the "log/" directory of your Flink distribution. Best, Yangze Guo On Tue, Jan 12, 2021 at 4:50 PM bat man wrote:

Main class logs in Yarn Mode

Hi, I am running a sample job as below - public class WordCountExample { static Logger logger = LoggerFactory.getLogger(WordCountExample.class); public static void main(String[] args) throws Exception { final ExecutionEnvironment env = ExecutionEnvironment. getExecutionEnvironment(); logger.inf