Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

Hey Guyla , dev-team I deployed rc-2 with helm on AWS EKS with HA enabled (3 pods). The operator watches 3 namespaces. I successfully deployed an application cluster(Flink 1.17) via pod template. I encountered the following errors 1. org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.c

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

@Tamir: For 1: Do you get the same problems with 1.4.0 or is this a regression in 1.5.0? If you set the helm chart so the operator also watches its own namespaces like I mentioned in the jira do you still get the error? For 2: This error happens when you delete the FlinkDeployment? Can you open a

[jira] [Created] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received

Tamir Sagi created FLINK-32093: -- Summary: Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received Key: FLINK-32093 URL: https://issues.apache.org/

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

Hey Guyla, 1. The operator watches its own namespace as well. The error still happens(The only way to overcome this is to change kubernetes.rest-service.exposed.type to 'ClusterIP'). It seems connected to RestClient uses k8s client internally which needs NodeList permissions but instead of read

[jira] [Created] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

Martijn Visser created FLINK-32094: -- Summary: startScheduling.BATCH performance regression since May 11th Key: FLINK-32094 URL: https://issues.apache.org/jira/browse/FLINK-32094 Project: Flink

Re: [NOTICE] Flink master branch now uses Maven 3.8.6

Thanks Chesnay for the efforts. Happy to see we can use Maven 3.8 finnally. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期六, 2023年 5 月 13日 下午 4:37:58 主题: Re: [NOTICE] Flink master branch now uses Maven 3.8.6 Great news! We can finally get rid of additional setup to use

Re:Re: Re: [DISCUSS] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

Hi Jingsong, Thank you for your reply! We introduced `TwoPhaseCatalogTable` for two reasons: 1. The `TwoPhaseCatalogTable` of different data sources can have more operations, if through Catalog, there can only be simple create table and drop table, not flexible enough; For example, deleting a t

How to pass the TLS certs to the latest version of flink-connector-pulsar

I am trying to connect my Flink application to a Pulsar topic for ingesting data. The topic is active and i am able to ingest the data via a normal Java application. When i try to use the Flink application to ingest the data from the same topic, using the latest version of flink-connector-pulsar i

[jira] [Created] (FLINK-32095) HiveDialectITCase crashed with exit code 239

Weijie Guo created FLINK-32095: -- Summary: HiveDialectITCase crashed with exit code 239 Key: FLINK-32095 URL: https://issues.apache.org/jira/browse/FLINK-32095 Project: Flink Issue Type: Bug

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

Hi Gyula, Well, I don't understand this RBAC very well, but I got it to work with a simple one-line change, adding the line "- flinkdeployments/finalizers" to the flink.apache.org apiGroups section of the clusterrole like this: oc edit clusterrole flink-operator - apiGroups: - flink.apac