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
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
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