[jira] [Resolved] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

[ https://issues.apache.org/jira/browse/FLINK-38063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper resolved FLINK-38063. --- Resolution: Fixed > Update dependencies in the Flink Connector Kafka Project > -

[jira] [Created] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

Thomas Cooper created FLINK-38063: - Summary: Update dependencies in the Flink Connector Kafka Project Key: FLINK-38063 URL: https://issues.apache.org/jira/browse/FLINK-38063 Project: Flink Is

[jira] [Commented] (FLINK-38048) flink-connector-parent java version should be set to 11

[ https://issues.apache.org/jira/browse/FLINK-38048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003566#comment-18003566 ] Thomas Cooper commented on FLINK-38048: --- I opened a [PR|https://github.com/apache/

[jira] [Created] (FLINK-37983) Upgrade Kafka Client version to 3.9.1

Thomas Cooper created FLINK-37983: - Summary: Upgrade Kafka Client version to 3.9.1 Key: FLINK-37983 URL: https://issues.apache.org/jira/browse/FLINK-37983 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-37650) Enable Stale PR Github Action for Kafka Connector

Thomas Cooper created FLINK-37650: - Summary: Enable Stale PR Github Action for Kafka Connector Key: FLINK-37650 URL: https://issues.apache.org/jira/browse/FLINK-37650 Project: Flink Issue Typ

[jira] [Created] (FLINK-37600) Add a pre-commit git hook for running linting checks

Thomas Cooper created FLINK-37600: - Summary: Add a pre-commit git hook for running linting checks Key: FLINK-37600 URL: https://issues.apache.org/jira/browse/FLINK-37600 Project: Flink Issue

[jira] [Comment Edited] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939273#comment-17939273 ] Thomas Cooper edited comment on FLINK-36648 at 3/28/25 5:17 PM: --

[jira] [Commented] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939273#comment-17939273 ] Thomas Cooper commented on FLINK-36648: --- I pushed a [PR|https://github.com/apache/

[jira] [Comment Edited] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939240#comment-17939240 ] Thomas Cooper edited comment on FLINK-36648 at 3/28/25 4:23 PM: --

[jira] [Created] (FLINK-37583) Upgrade Kafka Client version to 4.0.0

Thomas Cooper created FLINK-37583: - Summary: Upgrade Kafka Client version to 4.0.0 Key: FLINK-37583 URL: https://issues.apache.org/jira/browse/FLINK-37583 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-37534) Add Linting checks to all PRs

[ https://issues.apache.org/jira/browse/FLINK-37534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-37534: -- Summary: Add Linting checks to all PRs (was: Add Liniting checks to all PRs ) > Add Linting

[jira] [Commented] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939240#comment-17939240 ] Thomas Cooper commented on FLINK-36648: --- [~kunni] now that the Flink 2.0.0 [PR|ht

[jira] [Commented] (FLINK-37534) Add Liniting checks to all PRs

[ https://issues.apache.org/jira/browse/FLINK-37534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937903#comment-17937903 ] Thomas Cooper commented on FLINK-37534: --- That is a good point, for the 1.x branche

[jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937857#comment-17937857 ] Thomas Cooper edited comment on FLINK-34992 at 3/24/25 11:25 AM: -

[jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937857#comment-17937857 ] Thomas Cooper edited comment on FLINK-34992 at 3/24/25 11:25 AM: -

[jira] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937857#comment-17937857 ] Thomas Cooper commented on FLINK-34992: --- The [2.0.0 Release Post|https://flink.ap

[jira] [Created] (FLINK-37533) Reduce Stale PR Action timeouts

Thomas Cooper created FLINK-37533: - Summary: Reduce Stale PR Action timeouts Key: FLINK-37533 URL: https://issues.apache.org/jira/browse/FLINK-37533 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37534) Add Liniting checks to all PRs

Thomas Cooper created FLINK-37534: - Summary: Add Liniting checks to all PRs Key: FLINK-37534 URL: https://issues.apache.org/jira/browse/FLINK-37534 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37026) Enable Stale PR Github Action

Thomas Cooper created FLINK-37026: - Summary: Enable Stale PR Github Action Key: FLINK-37026 URL: https://issues.apache.org/jira/browse/FLINK-37026 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-36675) Dynamic option hints will not take effect when restoring exec plan from json plan without setting 'table.plan.compile.catalog-objects' to 'all'

[ https://issues.apache.org/jira/browse/FLINK-36675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903063#comment-17903063 ] Thomas Cooper commented on FLINK-36675: --- This issue needs a description. What is t

[jira] [Commented] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data.

[ https://issues.apache.org/jira/browse/FLINK-36663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903051#comment-17903051 ] Thomas Cooper commented on FLINK-36663: --- Instead of pasting screen shots could you

[jira] [Commented] (FLINK-36664) [Window]The window with window_offset will lose data.

[ https://issues.apache.org/jira/browse/FLINK-36664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903042#comment-17903042 ] Thomas Cooper commented on FLINK-36664: --- Instead of pasting screen shots could you

[jira] [Commented] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902306#comment-17902306 ] Thomas Cooper commented on FLINK-36648: --- Has there been any progress on this? I ca

[jira] [Commented] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902317#comment-17902317 ] Thomas Cooper commented on FLINK-36648: --- I assume, as a minimum, we need to remove

[jira] [Updated] (FLINK-36830) Override json-path version used by Calcite Bridge

[ https://issues.apache.org/jira/browse/FLINK-36830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36830: -- Summary: Override json-path version used by Calcite Bridge (was: Overried json-path version u

[jira] [Created] (FLINK-36830) Overried json-path version used by Calcite Bridge

Thomas Cooper created FLINK-36830: - Summary: Overried json-path version used by Calcite Bridge Key: FLINK-36830 URL: https://issues.apache.org/jira/browse/FLINK-36830 Project: Flink Issue Typ

[jira] [Updated] (FLINK-36821) Upgrade Kafka Client version to 3.9.0

[ https://issues.apache.org/jira/browse/FLINK-36821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36821: -- Description: Currently, the Flink Kafka Connector uses Kafka client version 3.4.0. This has

[jira] [Created] (FLINK-36821) Upgrade Kafka Client version to 3.9.0

Thomas Cooper created FLINK-36821: - Summary: Upgrade Kafka Client version to 3.9.0 Key: FLINK-36821 URL: https://issues.apache.org/jira/browse/FLINK-36821 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-36810) Reflective access warning not addressed causing Flink failing to process job creation

[ https://issues.apache.org/jira/browse/FLINK-36810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901522#comment-17901522 ] Thomas Cooper commented on FLINK-36810: --- Are you setting the Java options needed f

[jira] [Commented] (FLINK-36646) Support Java 17+ job images more conveniently in the operator

[ https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894829#comment-17894829 ] Thomas Cooper commented on FLINK-36646: --- We could set the {{env.java.default-opts.

[jira] [Updated] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability

[ https://issues.apache.org/jira/browse/FLINK-36643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36643: -- Affects Version/s: 2.0.0 > Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability > -

[jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability

Thomas Cooper created FLINK-36643: - Summary: Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability Key: FLINK-36643 URL: https://issues.apache.org/jira/browse/FLINK-36643 Project: Flink

[jira] [Updated] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability

[ https://issues.apache.org/jira/browse/FLINK-36643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36643: -- Component/s: FileSystems > Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability > -

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CV

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CVE

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Issue Type: Improvement (was: Technical Debt) > Upgrade Calcite version to 1.38.0 > -

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Affects Version/s: 2.0-preview > Upgrade Calcite version to 1.38.0 > -

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CVE

[jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0

Thomas Cooper created FLINK-36602: - Summary: Upgrade Calcite version to 1.38.0 Key: FLINK-36602 URL: https://issues.apache.org/jira/browse/FLINK-36602 Project: Flink Issue Type: Technical Deb

[jira] [Comment Edited] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

[ https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892173#comment-17892173 ] Thomas Cooper edited comment on FLINK-33571 at 10/24/24 2:46 PM: -

[jira] [Comment Edited] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

[ https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892171#comment-17892171 ] Thomas Cooper edited comment on FLINK-33571 at 10/23/24 2:33 PM: -

[jira] [Comment Edited] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

[ https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892171#comment-17892171 ] Thomas Cooper edited comment on FLINK-33571 at 10/23/24 2:33 PM: -

[jira] [Commented] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

[ https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892171#comment-17892171 ] Thomas Cooper commented on FLINK-33571: --- So looks like there is now a json-path 2.

[jira] [Updated] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

[ https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36593: -- Component/s: API / Core > Upgrade io.airlift:aircompressor to mitigate CVE > -

[jira] [Commented] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

[ https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892169#comment-17892169 ] Thomas Cooper commented on FLINK-36593: --- Sorry [~pshangle], I already put a PR up

[jira] [Updated] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

[ https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36593: -- Description: The current version of the aircompressor library (0.21), used in the flink-runti

[jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

Thomas Cooper created FLINK-36593: - Summary: Upgrade io.airlift:aircompressor to mitigate CVE Key: FLINK-36593 URL: https://issues.apache.org/jira/browse/FLINK-36593 Project: Flink Issue Type