Re: Adding Context To Logs

2016-06-02 Thread Chesnay Schepler
the job name is straight up not accessible from within a function. Until recently it wasn't even accessible /anywhere/ on the TaskManager. To get the job name in a function you would have to pass it from the TaskManager to the task, to the operator and (probably) to the RuntimeContext. If you

Re: Adding Context To Logs

2016-06-02 Thread Kostas Kloudas
Hello Paul, If I understand correctly, your issues seem to be related to: https://issues.apache.org/jira/browse/FLINK-1502?jql=assignee%20in%20(Zentol)%20AND%20text%20~%20%22metrics%22

Adding Context To Logs

2016-06-02 Thread Hamilton, Paul
Hi, We are trying to rework the way our Flink jobs (and really it becomes how the operators within the jobs) log. Specifically we are trying to add contextual information to the log messages so that it is easier to filter and search for a specific jobs logs after they have been send through to