Re: how to enable debugging mode for python worker harness

! On Mon, Mar 18, 2024 at 6:24 PM XQ Hu via user wrote: > I did not do anything special but ran `docker-compose -f > docker-compose.yaml up` from your repo. > > On Sun, Mar 17, 2024 at 11:38 PM Lydian Lee > wrote: > >> Hi XQ, >> >> The code is simplified from my prev

Creating custom metrics with labels (python SDK + Flink Runner)

Hi, I am using beam python SDK with flink runner, and I am trying to add custom labels to the metrics. It seems like the provided function (link ) doesn't allow me to add labels. ``` @staticmethod def

Re: how to enable debugging mode for python worker harness

gt; Maybe this is related to your Mac setting? > > On Sun, Mar 17, 2024 at 8:34 AM Lydian Lee > wrote: > >> >> Hi, >> >> Just FYI, the similar things works on a different image with the one I >> built using my company’s image as base image. I’ve only replace

Re: how to enable debugging mode for python worker harness

manager. Otherwise, it > won't be able to launch a Docker container for reading kafka messages. > > Cheers, > Jaehyeon > > > On Sun, 17 Mar 2024 at 18:21, Lydian Lee wrote: > >> Hi, >> >> I have an issue when setting up a POC of Python SDK with Flink run

how to enable debugging mode for python worker harness

Hi, I have an issue when setting up a POC of Python SDK with Flink runner to run in docker-compose. The python worker harness was not returning any error but: ``` python-worker-harness-1 | 2024/03/17 07:10:17 Executing: python -m apache_beam.runners.worker.sdk_worker_main

Request to join slack channel

Hi, Can I get the invitation to join slack channel ? The ASF slack seems required invitation to be able to join. Thanks