request for link to join

2023-01-28 Thread Wai Chee Yau
hi can i please get an invite link to join Slack for Flink? thanks

Re: Using pyflink from flink distribution

2023-01-28 Thread Dian Fu
Hi Andrew, >> By pip installing apache-flink, this docker image will have the flink distro installed at /opt/flink and FLINK_HOME set to /opt/flink . BUT ALSO flink lib jars will be installed at e.g. /usr/

Re: Detect Table options override by Query Dynamic options

2023-01-28 Thread yuxia
Hi, Krzysztof Chmielewski. I'm afraid that there's no a way to detect in Table Factory as the passed catalog table has contained the overriden options by query dynamci option and seems we have no any flag to identify it in Table Factory. Best regards, Yuxia 发件人: "Krzysztof Chmielewski" 收

Re: Rescale Flink - Adjust Parallelism based on TPS

2023-01-28 Thread Zhanghao Chen
Hi Madan, The next release of Flink Kubernetes Operator will come with a built-in autoscaler. Unfortunately, there's no official support for autoscaling Flink applications on YARN yet. You can take a look at https://cwiki.apache.org/confluence/display/FLINK/FLIP-271%3A+Autoscaling and try buil