Flink Kubernetes Session sample from Documentation

2023-04-04 Thread Le Xu
Hello! I'm trying out the Kubernetes sample described in the official doc but I am not able to submit job with the following error: ---

Failed docker-entrypoint.sh in Flink-Operator Logs

2023-04-04 Thread Ivan Webber via user
I’ve noticed that all jobs I start with `flink-operator` have the following message at the top of their logs for both jobmanager and taskmanager pods: ``` sed: couldn't open temporary file /opt/flink/conf/sedRTwsr1: Read-only file system sed: couldn't open temporary file /opt/flink/conf/sedcDS3

[SUMMARY] Flink 1.18 Release Sync 4/4/2023

2023-04-04 Thread Jing Ge via user
Dear devs and users, Today was the kickoff meeting for Flink 1.18 release cycle. I'd like to share the info synced in the meeting. Meeting schedule: Zoom will be used with a 40 mins limit for each meeting. That should be fine for now. We will check it again if we have an issue with the time limi

Re:Re: How to set reblance in Flink Sql like Streaming api?

2023-04-04 Thread hjw
Hi Shammon Are you suggesting that I use over and partition by , right? if it is like this, I must define a agg_func on a specific column. For Example,I have a product table. Before partition by : select user,product,amount FROM product After partition by : select user,product,amount, FIRST_VA