@zorro786 I checked and I'm afraid but supporting metrics pusher in detached 
mode does not seem to be possible without a modification of the upstream flink. 
Indeed, in this mode even flink accumulators are not available so we will have 
no access to the metrics at all, it is not just a matter of terminating the 
pusher thread or avoiding the thread (with DAG modification) as I first 
thought. To help you understand the architecture, here is a diagram (that is 
part of my upcoming presentation at the apacheCon)
![metrics inside the runner 
15](https://user-images.githubusercontent.com/8821084/44571479-264cfe80-a781-11e8-9f40-a766fdad5abf.png)



[ Full content available at: https://github.com/apache/beam/pull/4548 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to