Regarding Flink Upgrades

Hi Community, Currently we are using version 1.12.7 and it is running without any issue. And we see that version 1.17 is set to release early next year. That means we would be 5 versions behind. 1) So how far can we lag behind the current flink version ? 2) If we face any issues like log4j that

Re: why select limit so slow on yarn cluster

Such sql should be finished quickly. Could you please look at which part cost much time? Starting the job or running the job or other stuff. And how about the network? Btw, what's the logic plan and physical plan? You can use `explain select * from scrm_admin_role limit 10` to show the plan.

Re: Flink SQL on Docker

Hi, sorry about the late response. Currently the sql client queries connect to a Kafka topic to read events, so I don't think it'll be reproducible. I'm using Flink 1.15, and running it in a Docker image on Mac OS with M1 chip. I also noticed that multiple queries in a sql client session continue

why select limit so slow on yarn cluster

I created a table using Flink SQL on yarn session. CREATE TEMPORARY TABLE `scrm_admin_role` ( > `id` bigint, > `role_name` string, > `sort` int, > `type` tinyint, > `status` tinyint, > `tenant_id` bigint, > `deleted` BOOLEAN, > `create_time` TIMESTAMP, > `update_time` TIMESTAMP,

Re: [Security] - Critical OpenSSL Vulnerability

Hi all, Looking at the blog with details https://www.openssl.org/blog/blog/2022/11/01/email-address-overflows it's shown that vulnerability has been downgraded to High. I don't think that warrants an emergency re-release of the images. Best regards, Martijn Op di 1 nov. 2022 om 15:06 schreef Ch

Re: [Security] - Critical OpenSSL Vulnerability

We just push new images with the same tags. On 01/11/2022 14:35, Matthias Pohl wrote: The Docker image for Flink 1.12.7 uses an older base image which comes with openssl 1.1.1k. There was a previous post in the OpenSSL mailing list reporting a low vulnerability being fixed with 3.0.6 and 1.1.1r

Re: [Security] - Critical OpenSSL Vulnerability

The Docker image for Flink 1.12.7 uses an older base image which comes with openssl 1.1.1k. There was a previous post in the OpenSSL mailing list reporting a low vulnerability being fixed with 3.0.6 and 1.1.1r (both versions being explicitly mentioned) [1]. Therefore, I understand the post in a way

Re: Could not find any factory for identifier 'filesystem'

the dependency flink-connector-files is needed. Best regards, Yuxia 发件人: "Pavel Penkov" 收件人: "User" 发送时间: 星期二, 2022年 11 月 01日 下午 6:06:43 主题: Could not find any factory for identifier 'filesystem' I'm trying to run a Flink job as a standalone program and getting the following error. C

Could not find any factory for identifier 'filesystem'

I'm trying to run a Flink job as a standalone program and getting the following error. Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'filesystem' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. Availab

[SUMMARY] Flink 1.17 Release Sync 11/1/2022

Hi devs and users, I'd like to share some highlights about the 1.17 release sync on 11/1/2022. - The release sync is scheduled for biweekly Tuesdays at 9am (Central European Standard Time) / 4pm (China Standard Time). - Retrospective for 1.16: a discussion [1] is opened by Matthias for collectin