Hi XQ
I haven't changed anything and the issue would persist on my end. The print
stuff is called only when self.verbose is True and, by default, it is False.
BTW Do you have any idea about the error message? I haven't seen such error.
Cheers,
Jaehyeon
On Sun, 12 May 2024, 12:15 am XQ Hu via us
Do you still have the same issue? I tried to follow your setup.sh to
reproduce this but somehow I am stuck at the word_len step. I saw you also
tried to use `print(kafka_kv)` to debug it. I am not sure about your
current status.
On Fri, May 10, 2024 at 9:18 AM Jaehyeon Kim wrote:
> Hello,
>
> I'
Hello,
I'm playing with deploying a python pipeline to a flink cluster on
kubernetes via flink kubernetes operator. The pipeline simply calculates
average word lengths in a fixed time window of 5 seconds and it works with
the embedded flink cluster.
First, I created a k8s cluster (v1.25.3) on min