[DISCUSS] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice

Hi, I was looking into https://issues.apache.org/jira/browse/FLINK-23598 which already has a mergeable PR - https://github.com/apache/flink/pull/23563 open. According to the PR description, the method that appears to be problematic isn't being called from any other classes, but it might lead to p

Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter

Thank you, I tried with the new libraries you suggested. i am using flink 1.18 and java 11 org.apache.iceberg iceberg-flink 1.6.1 org.apache.iceberg iceberg-flink-runtime-1.18 1.6.1

[jira] [Created] (FLINK-36233) Reuseable view in Flink SQL

Yi Cai created FLINK-36233: -- Summary: Reuseable view in Flink SQL Key: FLINK-36233 URL: https://issues.apache.org/jira/browse/FLINK-36233 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-36232) Incorrect vararg handling in Python Table API

Dylan He created FLINK-36232: Summary: Incorrect vararg handling in Python Table API Key: FLINK-36232 URL: https://issues.apache.org/jira/browse/FLINK-36232 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36231) Optimize built-in function REGEXP_EXTRACT and REGEXP_REPLACE with regex cache

Dylan He created FLINK-36231: Summary: Optimize built-in function REGEXP_EXTRACT and REGEXP_REPLACE with regex cache Key: FLINK-36231 URL: https://issues.apache.org/jira/browse/FLINK-36231 Project: Flink

Flink Releases

Hi, I notice that https://nightlies.apache.org/flink/flink-docs-master/versions/ does not include 1.20. It seems that {{< all_versions >}} is not picking it up. I am happy to make the change, but could not see where to, Kind regards, David. Unless otherwise stated above: IBM Uni

[DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format #2

Hi All, I'm going to attempt to revive the discussion for FLIP-34440 since the original discussion thread has stalled. Fresh start! :) Let's start with discussing the approach as per the Flink contribution guides! First of all, I think it's imp

[jira] [Created] (FLINK-36228) MongoDB sink should be asynchronous

Jacob Jona Fahlenkamp created FLINK-36228: - Summary: MongoDB sink should be asynchronous Key: FLINK-36228 URL: https://issues.apache.org/jira/browse/FLINK-36228 Project: Flink Issue T