Beam Emitted Metrics Reference

2020-02-27 Thread Daniel Chen
Hi all, I some questions about the reference to the framework metrics emitted by Beam. I would like to leverage these metrics to allow better monitoring of by Beam jobs but cannot find any references to the description or a complete set of emitted metrics. Do we have this information documented

Integration of python/portable runner tests for Samza runner

2019-04-22 Thread Daniel Chen
Hi everyone, I'm working on improving the validation of the Python portable Samza runner. For java, we have the gradle task ( :validatesRunner) that runs the runner validation tests. I am looking for pointers on how to similarly integrate/enable the portability and Python tests for the Samza

Beam Contribution

2019-01-18 Thread Daniel Chen
Hello, I'm Daniel Chen from the Samza team at Linkedin. For my upcoming work on the Beam Samza runner, I would like to be added as a contributor in order to facilitate ticket tracking. My ASF jira username is dchen. Thanks, Daniel