【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS.

Hi team, I had starting the SQL Gateway with the HiveServer2 Endpoint, and then I submit SQL with Apache Hive Beeline, but I get the following exception: java.lang.UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. at org.apache.flink.table.endpoint.hive.HiveS

Re: [Security] - Critical OpenSSL Vulnerability

Could we also get an emergency patch to 1.12 version as well , because upgrading flink to a newer version on production in a short time would be high in effort and longer in duration as well . Thanks, Prasanna On Tue, Nov 1, 2022 at 11:30 AM Prasanna kumar < prasannakumarram...@gmail.com> wrote:

Re: [Security] - Critical OpenSSL Vulnerability

If flink version 1.12 also affected ? Thanks, Prasanna. On Tue, Nov 1, 2022 at 10:40 AM Mason Chen wrote: > Hi Tamir and Martjin, > > We have also noticed this internally. So far, we have found that the > *latest* Flink Java 11/Scala 2.12 docker images *1.14, 1.15, and 1.16* > are affected, whi

Re: [Security] - Critical OpenSSL Vulnerability

Hi Tamir and Martjin, We have also noticed this internally. So far, we have found that the *latest* Flink Java 11/Scala 2.12 docker images *1.14, 1.15, and 1.16* are affected, which all have the *openssl 3.0.2 *dependency. It would be good to discuss an emergency release when this patch comes out

Re: OutOfMemoryError (java heap space) on small, local test

Thanks Leonard for taking a look. It seems odd that returning a list of objects can cause a fatal error such as this, and since I am new to Flink and also relatively new to Python, I assume that I am doing something wrong as returning a list of objects is a fairly common data modelling scenario. P

Passive lineage collection?

Hey all, We've got a number of flink jobs deployed and I'm wrestling with how best to collect data lineage information from them. Our most common connector on either end is Kafka, as either a source or a sink. I've found that I can subclass the Kafka record de/serializers and collect topics off of

Re: [Security] - Critical OpenSSL Vulnerability

Hi Tamir, That depends on a) if Flink is vulnerable and b) if yes, how vulnerable that would be. Best regards, Martijn Op ma 31 okt. 2022 om 19:22 schreef Tamir Sagi > Hey all, > > Following that link > https://mta.openssl.org/pipermail/openssl-announce/2022-October/000238.html > > due to cri

[Security] - Critical OpenSSL Vulnerability

Hey all, Following that link https://mta.openssl.org/pipermail/openssl-announce/2022-October/000238.html due to critical vulnerability , there will be an important release of OpenSSl v3.0.7 tomorrow November 1st. Is there any plan to update Flink with the newest version? Thanks. Tamir Confid

[ANNOUNCE] Starting with Flink 1.17 release sync

Hi everyone, We want to let you know that with Flink 1.16 now available, we'll focus on the Flink 1.17 release. [1] As part of that release, we'll continue with our release sync meetings. At first, they will be every 2 weeks and when the feature freeze gets closer, we'll move to weekly meetings.

Re: OutOfMemoryError (java heap space) on small, local test

Hi, Matt I’ve checked your job is pretty simple, I've CC Xingbo who is a PyFlink expert to help take a quick look. Best， Leonard > 2022年10月31日 上午11:47，Matt Fysh 写道： > > Hi there, > > I am running a local test with: > * source = env.from_collection > * sink = datastream.execute_and_collect

Re: flink-table-api-scala-bridge sources

Thanks for reporting the issue; I've filed a ticket (FLINK-29803). On 25/10/2022 09:40, Clemens Valiente wrote: Hi everyone I noticed when going through the scala datastream/table api bridge in my IDE I cannot see the source of the code. I believe it is because the Sources are missing on mave