Re: [DISCUSS] Externalized Google Cloud Connectors

Hi Lorenzo, Bahir is retired, see the homepage. It plays no role (anymore). > This, unfortunately, is the tradeoff for developing the connectors outside of Apache in exchange for development velocity. I understand that. It can be considered to develop the connectors outside of the Flink project

[jira] [Created] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor

Kirill Plugatarev created FLINK-35006: - Summary: Use try with-resource for StandaloneAutoscalerExecutor Key: FLINK-35006 URL: https://issues.apache.org/jira/browse/FLINK-35006 Project: Flink

[jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT

Martijn Visser created FLINK-35007: -- Summary: Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT Key: FLINK-35007 URL: https://issues.apache.org/jira/browse/FLINK-35007 Project: Flin

Re: [FYI] The Azure CI for PRs is currently not triggered

The CI is back to normal since this morning. Thanks to the collaboration with Robert and Mathias. For more information, see the issue link in Matthias message. On Thu, Apr 4, 2024, 08:23 Matthias Pohl wrote: > Hi everyone, > just for your information: The Azure CI for PRs is currently not wor

[jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

Martijn Visser created FLINK-35008: -- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector Key: FLINK-35008 URL: https://issues.apache.org/jira/browse/FLINK-35008

[jira] [Created] (FLINK-35009) Change on getTransitivePredecessors breaks connectors

Martijn Visser created FLINK-35009: -- Summary: Change on getTransitivePredecessors breaks connectors Key: FLINK-35009 URL: https://issues.apache.org/jira/browse/FLINK-35009 Project: Flink Iss

[jira] [Created] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector

Zhongqiang Gong created FLINK-35010: --- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector Key: FLINK-35010 URL: https://issues.apache.org/jira/browse/FLINK-35010

Re: [VOTE] FLIP-437: Support ML Models in Flink SQL

Hi Dev, Thanks all for voting. I'm closing the vote and the result will be posted in a separate email. Thanks, Hao On Wed, Apr 3, 2024 at 10:24 AM Hao Li wrote: > Thanks David Radley and David Moravek for the comments. I'll reply in the > discussion thread. > > Hao > > On Wed, Apr 3, 2024 at 5

[RESULT][VOTE] FLIP-437: Support ML Models in Flink SQL

Hi Dev, I'm happy to announce that FLIP-437: Support ML Models in Flink SQL [1] has been accepted with 7 approving votes (6 binding) [2] Timo Walther (binding) Jark Wu (binding) Yu Chen (non-binding) Piotr Nowojski (binding) Leonard Xu (binding) Martijn Visser (binding) David Moravek (binding) T

[jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

Jiabao Sun created FLINK-35011: -- Summary: The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector Key: FLINK-35011 URL: https://issues.apache.org/jira/browse/FLINK-35011

[jira] [Created] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

Ryan Skraba created FLINK-35012: --- Summary: ChangelogNormalizeRestoreTest.testRestore failure Key: FLINK-35012 URL: https://issues.apache.org/jira/browse/FLINK-35012 Project: Flink Issue Type: B

[jira] [Created] (FLINK-35013) Support temporary model

Hao Li created FLINK-35013: -- Summary: Support temporary model Key: FLINK-35013 URL: https://issues.apache.org/jira/browse/FLINK-35013 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35014) SqlNode to operation conversion for models

Hao Li created FLINK-35014: -- Summary: SqlNode to operation conversion for models Key: FLINK-35014 URL: https://issues.apache.org/jira/browse/FLINK-35014 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

Zhenqiu Huang created FLINK-35015: - Summary: Flink Parquet Reader doesn't honor parquet configuration Key: FLINK-35015 URL: https://issues.apache.org/jira/browse/FLINK-35015 Project: Flink Is

[jira] [Created] (FLINK-35016) Catalog changes for model CRUD

Hao Li created FLINK-35016: -- Summary: Catalog changes for model CRUD Key: FLINK-35016 URL: https://issues.apache.org/jira/browse/FLINK-35016 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-35018) ML_EVALUATE function

Hao Li created FLINK-35018: -- Summary: ML_EVALUATE function Key: FLINK-35018 URL: https://issues.apache.org/jira/browse/FLINK-35018 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35017) ML_PREDICT function

Hao Li created FLINK-35017: -- Summary: ML_PREDICT function Key: FLINK-35017 URL: https://issues.apache.org/jira/browse/FLINK-35017 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35019) Support show create model syntax

Hao Li created FLINK-35019: -- Summary: Support show create model syntax Key: FLINK-35019 URL: https://issues.apache.org/jira/browse/FLINK-35019 Project: Flink Issue Type: Sub-task Reporte

[jira] [Created] (FLINK-35020) Model Catalog implementation in Hive etc

Hao Li created FLINK-35020: -- Summary: Model Catalog implementation in Hive etc Key: FLINK-35020 URL: https://issues.apache.org/jira/browse/FLINK-35020 Project: Flink Issue Type: Sub-task

Two potential bugs in Flink ML

Hi Flink Dev Team, I have two possible bugs to report for Flink ML Iteration. Flink v1.17.2 Flink ML v2.3.0 Java 11 Bug # 1 Implementing a UDF KeyedRichCoProcessFunction or CoFlatMapFunction inside IterationBody yields a “java.lang.ClassCastException: org.apache.flink.iteration.IterationRecord c