[jira] [Created] (FLINK-35566) Consider promoting TypeSerializer from PublicEvolving to Public

Martijn Visser created FLINK-35566: -- Summary: Consider promoting TypeSerializer from PublicEvolving to Public Key: FLINK-35566 URL: https://issues.apache.org/jira/browse/FLINK-35566 Project: Flink

[jira] [Updated] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35378: --- Summary: [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction (was:

[jira] [Closed] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35378. -- Fix Version/s: 1.20.0 Resolution: Fixed Fixed in apache/flink:master f0b01277dd23dd0edc

[jira] [Commented] (FLINK-35630) Kafka source may reset the consume offset to earliest when the partition leader changes

[ https://issues.apache.org/jira/browse/FLINK-35630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855813#comment-17855813 ] Martijn Visser commented on FLINK-35630: [~tanjialiang] Do you have a reproducib

[jira] [Commented] (FLINK-35626) Add support for FIPS

[ https://issues.apache.org/jira/browse/FLINK-35626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855815#comment-17855815 ] Martijn Visser commented on FLINK-35626: Realistically I don't think that we wil

[jira] [Updated] (FLINK-35626) Add support for FIPS

[ https://issues.apache.org/jira/browse/FLINK-35626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35626: --- Priority: Not a Priority (was: Minor) > Add support for FIPS > > >

[jira] [Updated] (FLINK-35626) Add support for FIPS

[ https://issues.apache.org/jira/browse/FLINK-35626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35626: --- Component/s: Documentation > Add support for FIPS > > >

[jira] [Commented] (FLINK-35631) KafkaSource parameter partition.discovery.interval.ms with a default value of 5 minutes does not take effect

[ https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855909#comment-17855909 ] Martijn Visser commented on FLINK-35631: [~elon] Have you validated this with ho

[jira] [Commented] (FLINK-35631) KafkaSource parameter partition.discovery.interval.ms with a default value of 5 minutes does not take effect

[ https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856151#comment-17856151 ] Martijn Visser commented on FLINK-35631: [~renqs] Given that you worked on the F

[jira] [Reopened] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-20539: > Type mismatch when using ROW in computed column > --

[jira] [Commented] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859658#comment-17859658 ] Martijn Visser commented on FLINK-20539: [~xuyangzhong] [~qingyue] I've re-opene

[jira] [Closed] (FLINK-35686) Flink-connector-jdbc v3.2.0 support flink 1.17.x

[ https://issues.apache.org/jira/browse/FLINK-35686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35686. -- Resolution: Information Provided As can be seen on https://flink.apache.org/downloads/#apache

[jira] [Assigned] (FLINK-35706) FLIP-463: Schema Definition in CREATE TABLE AS Statement

[ https://issues.apache.org/jira/browse/FLINK-35706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-35706: -- Assignee: Sergio Peña > FLIP-463: Schema Definition in CREATE TABLE AS Statement > --

[jira] [Commented] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860386#comment-17860386 ] Martijn Visser commented on FLINK-20539: [~xuyangzhong] Have you been able to ta

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860823#comment-17860823 ] Martijn Visser commented on FLINK-34554: [~loserwang1024] I think that would req

[jira] [Commented] (FLINK-35611) Release Testing Instructions: Verify [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861334#comment-17861334 ] Martijn Visser commented on FLINK-35611: [~fanrui] It doesn't need release testi

[jira] [Closed] (FLINK-35611) Release Testing Instructions: Verify [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35611. -- Resolution: Information Provided > Release Testing Instructions: Verify [FLIP-453] Promote Uni

[jira] [Assigned] (FLINK-35726) Data Stream to Table API converts Map to RAW 'java.util.Map'

[ https://issues.apache.org/jira/browse/FLINK-35726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-35726: -- Assignee: (was: Martijn Visser) > Data Stream to Table API converts Map to RAW 'j

[jira] [Assigned] (FLINK-35726) Data Stream to Table API converts Map to RAW 'java.util.Map'

[ https://issues.apache.org/jira/browse/FLINK-35726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-35726: -- Assignee: Martijn Visser > Data Stream to Table API converts Map to RAW 'java.util.Ma

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861371#comment-17861371 ] Martijn Visser commented on FLINK-35720: Have you performed the additional requi

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862401#comment-17862401 ] Martijn Visser commented on FLINK-35720: [~nferrario] There is always some state

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862404#comment-17862404 ] Martijn Visser commented on FLINK-35720: [~nferrario] I don't run into any probl

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862455#comment-17862455 ] Martijn Visser commented on FLINK-35720: [~nferrario] Have you also included org

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862473#comment-17862473 ] Martijn Visser commented on FLINK-35720: Can you provide a reproducer in code? T

[jira] [Commented] (FLINK-34268) Add a test to verify if restore test exists for ExecNode

[ https://issues.apache.org/jira/browse/FLINK-34268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862976#comment-17862976 ] Martijn Visser commented on FLINK-34268: Removed the exclusions on the tests in

[jira] [Commented] (FLINK-35749) Kafka sink component will lose data when kafka cluster is unavailable for a while

[ https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862991#comment-17862991 ] Martijn Visser commented on FLINK-35749: [~zjmean] It would be good to verify if

[jira] [Commented] (FLINK-35763) Bump Java version

[ https://issues.apache.org/jira/browse/FLINK-35763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863210#comment-17863210 ] Martijn Visser commented on FLINK-35763: [~911432] The documentation doesn't sta

[jira] [Closed] (FLINK-35763) Bump Java version

[ https://issues.apache.org/jira/browse/FLINK-35763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35763. -- Resolution: Invalid > Bump Java version > - > > Key: FLINK-357

[jira] [Created] (FLINK-35785) Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"

Martijn Visser created FLINK-35785: -- Summary: Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode" Key: FLINK-35785 URL: https://issues.apache.o

[jira] [Updated] (FLINK-35785) Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"

[ https://issues.apache.org/jira/browse/FLINK-35785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35785: --- Description: Tested with Flink 1.20 RC0 Reproducer: {code:sql} CREATE TABLE `product` (

[jira] [Closed] (FLINK-35785) Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"

[ https://issues.apache.org/jira/browse/FLINK-35785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35785. -- Resolution: Cannot Reproduce [~Weijie Guo] [~ferenc-csaky] I'm not sure why, but after manuall

[jira] [Updated] (FLINK-35749) Kafka sink component will lose data when kafka cluster is unavailable for a while

[ https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35749: --- Affects Version/s: kafka-3.2.0 > Kafka sink component will lose data when kafka cluster is u

[jira] [Commented] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

[ https://issues.apache.org/jira/browse/FLINK-35794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864088#comment-17864088 ] Martijn Visser commented on FLINK-35794: [~kornys] This would potentially affect

[jira] [Commented] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

[ https://issues.apache.org/jira/browse/FLINK-35794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864150#comment-17864150 ] Martijn Visser commented on FLINK-35794: [~kornys] The CI uses run-nightly-tests

[jira] [Comment Edited] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

[ https://issues.apache.org/jira/browse/FLINK-35794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864150#comment-17864150 ] Martijn Visser edited comment on FLINK-35794 at 7/9/24 11:03 AM: -

[jira] [Commented] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

[ https://issues.apache.org/jira/browse/FLINK-35794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864159#comment-17864159 ] Martijn Visser commented on FLINK-35794: Yeah, but in that case you're running a

[jira] [Closed] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

[ https://issues.apache.org/jira/browse/FLINK-35794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35794. -- Resolution: Won't Fix > Ability to skip kubernetes tests in e2e nightly test script >

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864495#comment-17864495 ] Martijn Visser commented on FLINK-25217: [~fsk119]  Since Flink 1.15 actually. 

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: Anupam (was: Jeyhun Karimov) > Add JSON_QUOTE and JSON_UNQUOTE function >

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: (was: Anupam) > Add JSON_QUOTE and JSON_UNQUOTE function >

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: Anupam Aggarwal > Add JSON_QUOTE and JSON_UNQUOTE function > --

[jira] [Assigned] (FLINK-35789) Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS)

[ https://issues.apache.org/jira/browse/FLINK-35789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-35789: -- Assignee: Sergio Peña > Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (C

[jira] [Commented] (FLINK-35796) Ensure that MailboxExecutor.submit is used correctly

[ https://issues.apache.org/jira/browse/FLINK-35796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864668#comment-17864668 ] Martijn Visser commented on FLINK-35796: [~arvid] Will you backport it also to t

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865378#comment-17865378 ] Martijn Visser commented on FLINK-35826: [~xuyangzhong] given that you worked on

[jira] [Assigned] (FLINK-35829) StreamPhysicalWindowTableFunction doesn't always require watermark

[ https://issues.apache.org/jira/browse/FLINK-35829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-35829: -- Assignee: xuyang > StreamPhysicalWindowTableFunction doesn't always require watermark

[jira] [Updated] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-35832: --- Affects Version/s: 1.19.1 1.18.1 1.17.2

[jira] [Commented] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866644#comment-17866644 ] Martijn Visser commented on FLINK-35832: Thanks for helping with the fix! Will w

[jira] [Commented] (FLINK-35861) The dependency of kafka sql connector seems wrong

[ https://issues.apache.org/jira/browse/FLINK-35861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867027#comment-17867027 ] Martijn Visser commented on FLINK-35861: The docs are correct imho; the Maven de

[jira] [Commented] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868001#comment-17868001 ] Martijn Visser commented on FLINK-35877: This is tagged for Shaded, but it's not

[jira] [Created] (FLINK-34413) Drop support for HBase v1

Martijn Visser created FLINK-34413: -- Summary: Drop support for HBase v1 Key: FLINK-34413 URL: https://issues.apache.org/jira/browse/FLINK-34413 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815719#comment-17815719 ] Martijn Visser commented on FLINK-34252: [~fanrui] I'm curious on your thoughts

[jira] [Updated] (FLINK-34244) Upgrade Confluent Platform to latest compatible version

[ https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34244: --- Fix Version/s: kafka-3.1.1 > Upgrade Confluent Platform to latest compatible version > -

[jira] [Created] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft

Martijn Visser created FLINK-34415: -- Summary: Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Key: FLINK-34415 URL: https://issues.apache.org/jira/browse/FLINK-34415 Project: Flink

[jira] [Updated] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft

[ https://issues.apache.org/jira/browse/FLINK-34415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34415: --- Description: The current Flink Kafka connector still uses Zookeeper for Kafka-based testing.

[jira] [Assigned] (FLINK-34413) Drop support for HBase v1

[ https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34413: -- Assignee: Ferenc Csaky > Drop support for HBase v1 > - > >

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815943#comment-17815943 ] Martijn Visser commented on FLINK-33365: [~rahulchundeth] See the Dev mailing li

[jira] [Closed] (FLINK-34244) Upgrade Confluent Platform to latest compatible version

[ https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34244. -- Resolution: Fixed Fixed in apache/flink-connector-kafka main: cfb275b478ff97e9105c5ffaf20224f

[jira] [Assigned] (FLINK-34192) Update flink-connector-kafka to be compatible with updated SinkV2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34192: -- Assignee: Jiabao Sun > Update flink-connector-kafka to be compatible with updated Sin

[jira] [Commented] (FLINK-34282) Create a release branch

[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816015#comment-17816015 ] Martijn Visser commented on FLINK-34282: [~mapohl] You mean force-pushing `dev-1

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816643#comment-17816643 ] Martijn Visser commented on FLINK-18356: Let's try it at least > flink-table-pl

[jira] [Created] (FLINK-34432) Re-enable forkReuse for flink-table-planner

Martijn Visser created FLINK-34432: -- Summary: Re-enable forkReuse for flink-table-planner Key: FLINK-34432 URL: https://issues.apache.org/jira/browse/FLINK-34432 Project: Flink Issue Type: T

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816899#comment-17816899 ] Martijn Visser commented on FLINK-18356: Filed https://issues.apache.org/jira/br

[jira] [Assigned] (FLINK-34432) Re-enable forkReuse for flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-34432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34432: -- Assignee: Martijn Visser > Re-enable forkReuse for flink-table-planner >

[jira] [Closed] (FLINK-34193) Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka

[ https://issues.apache.org/jira/browse/FLINK-34193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34193. -- Fix Version/s: kafka-3.1.1 Assignee: jiabao.sun Resolution: Fixed Fixed in apa

[jira] [Closed] (FLINK-34192) Update flink-connector-kafka to be compatible with updated SinkV2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34192. -- Fix Version/s: kafka-3.1.1 Resolution: Fixed Fixed in apache/flink-connector-kafka mai

[jira] [Commented] (FLINK-34282) Create a release branch

[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816945#comment-17816945 ] Martijn Visser commented on FLINK-34282: Nice, thanks [~jingge]! > Create a rel

[jira] [Created] (FLINK-34435) Bump org.yaml:snakeyaml from 1.31 to 2.2 for flink-connector-elasticsearch

Martijn Visser created FLINK-34435: -- Summary: Bump org.yaml:snakeyaml from 1.31 to 2.2 for flink-connector-elasticsearch Key: FLINK-34435 URL: https://issues.apache.org/jira/browse/FLINK-34435 Projec

[jira] [Closed] (FLINK-34432) Re-enable forkReuse for flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-34432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34432. -- Fix Version/s: 1.20.0 Resolution: Fixed Fixed in apache/flink:master 403694e7b9c213386f

[jira] [Updated] (FLINK-32261) Add MAP_UNION support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32261: --- Fix Version/s: (was: 1.19.0) > Add MAP_UNION support in SQL & Table API > --

[jira] [Assigned] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-21672: -- Assignee: David Radley > End to end tests (streaming) aren't Java vendor neutral (sun

[jira] [Assigned] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-21672: -- Assignee: david radley (was: David Radley) > End to end tests (streaming) aren't Jav

[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818008#comment-17818008 ] Martijn Visser commented on FLINK-21672: I've assigned the ticket to you [~david

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818372#comment-17818372 ] Martijn Visser commented on FLINK-34459: Should it? It would potentially result

[jira] [Created] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

Martijn Visser created FLINK-34461: -- Summary: MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17 Key: FLINK-34461 URL: https://issues.apache.org/jira/browse/FLINK-34461 Project: Flink

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818393#comment-17818393 ] Martijn Visser commented on FLINK-34459: I still am not convinced this is an act

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818450#comment-17818450 ] Martijn Visser commented on FLINK-34459: I think it should be a FLIP and a discu

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818490#comment-17818490 ] Martijn Visser commented on FLINK-34470: [~dongwoo.kim] Can you please verify th

[jira] [Updated] (FLINK-33899) Java 17 and 21 support for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-33899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33899: --- Fix Version/s: mongodb-1.0.3 > Java 17 and 21 support for mongodb connector > --

[jira] [Commented] (FLINK-33899) Java 17 and 21 support for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-33899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818512#comment-17818512 ] Martijn Visser commented on FLINK-33899: Also added to apache/flink-connector-mo

[jira] [Closed] (FLINK-34314) Update CI Node Actions from NodeJS 16 to NodeJS 20

[ https://issues.apache.org/jira/browse/FLINK-34314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34314. -- Resolution: Fixed Fixed in apache/flink-connector-shared-utils:ci_utils ec546068089dac4c41928

[jira] [Created] (FLINK-34515) Document new FLIP process

Martijn Visser created FLINK-34515: -- Summary: Document new FLIP process Key: FLINK-34515 URL: https://issues.apache.org/jira/browse/FLINK-34515 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-34515) Document new FLIP process

[ https://issues.apache.org/jira/browse/FLINK-34515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34515. -- Resolution: Fixed > Document new FLIP process > - > >

[jira] [Commented] (FLINK-34515) Document new FLIP process

[ https://issues.apache.org/jira/browse/FLINK-34515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820631#comment-17820631 ] Martijn Visser commented on FLINK-34515: FLIP page updated, see https://cwiki.a

[jira] [Commented] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820634#comment-17820634 ] Martijn Visser commented on FLINK-33856: [~hejufang001] I got pinged by [~pnowoj

[jira] [Comment Edited] (FLINK-25442) HBaseConnectorITCase.testTableSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820586#comment-17820586 ] Martijn Visser edited comment on FLINK-25442 at 2/26/24 8:50 AM: -

[jira] [Commented] (FLINK-34525) When redundant task managers are enabled, it will still take a considerable amount of time to restart a job if a task manager is killed.

[ https://issues.apache.org/jira/browse/FLINK-34525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821041#comment-17821041 ] Martijn Visser commented on FLINK-34525: [~easonqin] This isn't really a complet

[jira] [Assigned] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34513: -- Assignee: Martijn Visser > GroupAggregateRestoreTest.testRestore fails >

[jira] [Assigned] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34513: -- Assignee: Bonnie Varghese (was: Martijn Visser) > GroupAggregateRestoreTest.testRest

[jira] [Commented] (FLINK-34541) Flink uses insecure http confluent endpoint in its build

[ https://issues.apache.org/jira/browse/FLINK-34541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821886#comment-17821886 ] Martijn Visser commented on FLINK-34541: There's only one test that still uses t

[jira] [Updated] (FLINK-34541) Flink uses insecure http confluent endpoint in its build

[ https://issues.apache.org/jira/browse/FLINK-34541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34541: --- Component/s: Tests (was: Build System) > Flink uses insecure http confl

[jira] [Updated] (FLINK-34541) Flink uses insecure http confluent endpoint in its build

[ https://issues.apache.org/jira/browse/FLINK-34541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34541: --- Issue Type: Technical Debt (was: Bug) > Flink uses insecure http confluent endpoint in its

[jira] [Updated] (FLINK-34541) Flink uses insecure http confluent endpoint in its build

[ https://issues.apache.org/jira/browse/FLINK-34541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34541: --- Priority: Minor (was: Major) > Flink uses insecure http confluent endpoint in its build > -

[jira] [Commented] (FLINK-34552) Support message deduplication for input data sources

[ https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822172#comment-17822172 ] Martijn Visser commented on FLINK-34552: A couple of points from my point of vie

[jira] [Comment Edited] (FLINK-34552) Support message deduplication for input data sources

[ https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822172#comment-17822172 ] Martijn Visser edited comment on FLINK-34552 at 2/29/24 3:13 PM: -

[jira] [Updated] (FLINK-32714) JDBC: Add dialect for OceanBase database

[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32714: --- Fix Version/s: jdbc-3.2.0 > JDBC: Add dialect for OceanBase database > -

[jira] [Closed] (FLINK-32714) JDBC: Add dialect for OceanBase database

[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32714. -- Resolution: Fixed Fixed in apache/flink-connector-jdbc:main 786bd15951887a98f3a4962ba95e4e99b

[jira] [Assigned] (FLINK-32714) JDBC: Add dialect for OceanBase database

[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-32714: -- Assignee: He Wang > JDBC: Add dialect for OceanBase database > --

[jira] [Updated] (FLINK-34575) Vulnerabilities in commons-compress 1.24.0; upgrade to 1.26.0 needed.

[ https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34575: --- Issue Type: Technical Debt (was: Bug) > Vulnerabilities in commons-compress 1.24.0; upgrade

[jira] [Commented] (FLINK-34575) Vulnerabilities in commons-compress 1.24.0; upgrade to 1.26.0 needed.

[ https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823322#comment-17823322 ] Martijn Visser commented on FLINK-34575: Thanks for filing the ticket, I've chan

[jira] [Closed] (FLINK-34413) Drop support for HBase v1

[ https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34413. -- Fix Version/s: hbase-4.0.0 Resolution: Fixed Fixed in apache/flink-connector-hbase:main

  1   2   3   4   5   6   7   8   9   10   >