Adding 3rd party moving average and other 'indicators'

Hello I'm currently trying to learn Flink. And so far am really impressed by it. However I've still got a lot to learn. So apologies if this a terribly newbie question. I have created a streaming example based on https://flink.apache.org/news/2015/02/09/streaming-example.html. Next I would

Re: Question regarding logging capabilities in flink

Hi, I think what I wanted to know was if I add some logging in my flink job, I do not see them on Yarn. For example, In the following snippet in WordCount example when I add Logging, I do not see this in yarn logs when I run the job. However, I see them as client log on my side but not on yarn.

RE: Question regarding logging capabilities in flink

Hi, http://hortonworks.com/blog/simplifying-user-logs-management-and-access-in-yarn/ -Message d'origine- De : m...@apache.org [mailto:m...@apache.org] Envoyé : vendredi 24 juin 2016 13:53 À : user@flink.apache.org Objet : Re: Question regarding logging capabilities in flink Hi, Flink

Re: Question regarding logging capabilities in flink

Hi, Flink prints the Yarn application id during deployment of the cluster. You can then query the logs from Yarn using the `yarn logs -applicationId ` command. Please have a look at https://hadoop.apache.org/docs/stable/hadoop-yarn/hadoop-yarn-site/YarnCommands.html#logs Cheers, Max On Thu,

Re: State key serializer has not been configured in the config.

+1 for a more helpful error message. @Jacob Would you mind opening a JIRA issue at https://issues.apache.org/jira/browse/FLINK? On Thu, Jun 23, 2016 at 11:31 AM, Chesnay Schepler wrote: > We should adjust the error message to contain the keyed stream thingy. > > > On