[jira] [Resolved] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils

2025-09-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-37711. - Fix Version/s: 2.2.0 Resolution: Fixed > Remove unused getJobGraph f

[jira] [Assigned] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils

2025-09-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-37711: --- Assignee: Jiaan Geng > Remove unused getJobGraph from PipelineExecutorUt

[jira] [Resolved] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable

2025-09-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38386. - Fix Version/s: 2.2.0 Resolution: Fixed > Cannot attach type annotati

[jira] [Assigned] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector

2025-09-24 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-18563: Assignee: Bowen Li > Add Support for Azure Cosmos DB DataStream Connec

[jira] [Closed] (FLINK-34697) Finalize release 1.19.0

2025-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34697. --- Resolution: Fixed > Finalize release 1.19.0 > --- > >

[jira] [Assigned] (FLINK-37795) Physical rewrite for ml_evaluate

2025-09-24 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-37795: - Assignee: Hao Li > Physical rewrite for ml_evalu

[jira] [Created] (FLINK-38428) Support to call vector search with literal value

2025-09-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-38428: - Summary: Support to call vector search with literal value Key: FLINK-38428 URL: https://issues.apache.org/jira/browse/FLINK-38428 Project: Flink Issue

[jira] [Created] (FLINK-38427) Support to serde vector search execnode

2025-09-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-38427: - Summary: Support to serde vector search execnode Key: FLINK-38427 URL: https://issues.apache.org/jira/browse/FLINK-38427 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38423) Add vector search connector API

2025-09-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-38423: - Summary: Add vector search connector API Key: FLINK-38423 URL: https://issues.apache.org/jira/browse/FLINK-38423 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38422) FLIP-540: Support VECTOR_SEARCH in Flink SQL

2025-09-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-38422: - Summary: FLIP-540: Support VECTOR_SEARCH in Flink SQL Key: FLINK-38422 URL: https://issues.apache.org/jira/browse/FLINK-38422 Project: Flink Issue Type

[jira] [Closed] (FLINK-38420) Initial BlueGreenDeployment code contribution

2025-09-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-38420. -- Fix Version/s: kubernetes-operator-1.14.0 Resolution: Fixed merged to main

[jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments

2025-09-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-38395: --- Fix Version/s: kubernetes-operator-1.14.0 > Enable/fix the Flink Operator e2e tests for Blue/Gr

[jira] [Created] (FLINK-38420) Initial BlueGreenDeployment code contribution

2025-09-24 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-38420: -- Summary: Initial BlueGreenDeployment code contribution Key: FLINK-38420 URL: https://issues.apache.org/jira/browse/FLINK-38420 Project: Flink Issue Type: Sub

[jira] [Updated] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled

2025-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38415: --- Labels: pull-request-available (was: ) > IndexOutOfBoundsException occasionally occ

[jira] [Closed] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor

2025-09-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38417. Resolution: Fixed Fixed in master: 04e6437dd4d06b59b3f87651e2043559f3df827e > Ensure attrib

[jira] [Created] (FLINK-38419) Update official Flink docker images

2025-09-23 Thread Derek Chen-Becker (Jira)
Derek Chen-Becker created FLINK-38419: - Summary: Update official Flink docker images Key: FLINK-38419 URL: https://issues.apache.org/jira/browse/FLINK-38419 Project: Flink Issue Type

[jira] [Updated] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor

2025-09-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38417: --- Labels: pull-request-available (was: ) > Ensure attribute ordering when managing j

[jira] [Commented] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors

2025-09-23 Thread Muhammad (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1801#comment-1801 ] Muhammad commented on FLINK-38413: -- I have created an initial PR [here,|h

[jira] [Commented] (FLINK-24636) Move cluster deletion operation cache into ResourceManager

2025-09-23 Thread Nishita Pattanayak (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18022219#comment-18022219 ] Nishita Pattanayak commented on FLINK-24636: [~chesnay] If this is

[jira] [Closed] (FLINK-38353) FLIP-483: Add support for children Spans

2025-09-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-38353. -- Release Note: Users can now control the level of details of checkpoint spans via

[jira] [Closed] (FLINK-38363) WindowedStream.trigger supports trigger with async state

2025-09-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-38363. --- Fix Version/s: 2.2.0 Resolution: Fixed > WindowedStream.trigger supports trigger with as

[jira] [Updated] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled

2025-09-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-38415: Description: h1. 1. Exception: Following is the exception stack: {code:java

[jira] [Commented] (FLINK-36684) Support read changelog as append only mode for MySQL CDC connector

2025-09-23 Thread Muhammad (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18022128#comment-18022128 ] Muhammad commented on FLINK-36684: -- [~Runking] Was there any specific reason for

[jira] [Created] (FLINK-38415) IndexOutOfBoundsException occasionally occursIndexOutOfBoundsException in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled

2025-09-23 Thread Rui Fan (Jira)
URL: https://issues.apache.org/jira/browse/FLINK-38415 Project: Flink Issue Type: Bug Affects Versions: 2.1.0, 2.0.0, 1.20.3 Reporter: Rui Fan Assignee: Rui Fan Following is the exception stack: {code:java} java.lang.IndexOutOfBoundsException

[jira] [Updated] (FLINK-38315) Performance regression since August 21

2025-09-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-38315: Fix Version/s: (was: 2.2.0) > Performance regression since August

[jira] [Created] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support

2025-09-23 Thread Poorvank Bhatia (Jira)
Poorvank Bhatia created FLINK-38414: --- Summary: Add Vitess Pipeline Connector with Parallel Shard Reading Support Key: FLINK-38414 URL: https://issues.apache.org/jira/browse/FLINK-38414 Project

[jira] [Created] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration

2025-09-23 Thread Gustavo de Morais (Jira)
Gustavo de Morais created FLINK-38412: - Summary: Refactor MultiJoin test with state ttl to avoid state expiration Key: FLINK-38412 URL: https://issues.apache.org/jira/browse/FLINK-38412 Project

[jira] [Closed] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites

2025-09-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38410. Resolution: Fixed Fixed in master: f0da73ec7b9f00d50e7292a190b5e52f91b090b9 > Log test id

[jira] [Closed] (FLINK-38315) Performance regression since August 21

2025-09-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-38315. --- Resolution: Won't Fix > Performance regression since A

[jira] [Commented] (FLINK-38315) Performance regression since August 21

2025-09-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18022081#comment-18022081 ] Zakelly Lan commented on FLINK-38315: - I failed to reproduce this at my local

[jira] [Closed] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join

2025-09-22 Thread Xuyang Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuyang Zhong closed FLINK-38224. Resolution: Fixed > Retract sink should not accept duplicate changes produced by delta j

[jira] [Updated] (FLINK-37921) Refactor current implementation to reduce code duplication

2025-09-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37921: --- Labels: pull-request-available (was: ) > Refactor current implementation to reduce c

[jira] [Resolved] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules

2025-09-22 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv resolved FLINK-38393. Fix Version/s: cdc-3.5.0 Resolution: Fixed Fixed in master via

[jira] [Resolved] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-22 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv resolved FLINK-38398. Fix Version/s: cdc-3.5.0 Resolution: Fixed Fixed in master via

[jira] [Updated] (FLINK-38394) Upgrade Flink CDC to Flink 2

2025-09-22 Thread Mohsen Rezaei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohsen Rezaei updated FLINK-38394: -- Description: Potentially this means removing all {{SourceFunction}} implementations in favor

[jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization

2025-09-22 Thread Gustavo de Morais (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gustavo de Morais updated FLINK-37859: -- Description: We currently always rely on a chain of binary joins operators for

[jira] [Commented] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys

2025-09-22 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021911#comment-18021911 ] Sergey Nuyanzin commented on FLINK-38401: - Merge

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2025-09-22 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021887#comment-18021887 ] Zakelly Lan commented on FLINK-16686: - I've submitted a PR to fix

[jira] [Assigned] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2025-09-22 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-16686: --- Assignee: Zakelly Lan > [State TTL] Make user class loader available in native Rock

[jira] [Updated] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2025-09-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16686: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was

[jira] [Resolved] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally

2025-09-22 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38396. - Fix Version/s: 2.2.0 Resolution: Fixed Merged as

[jira] [Created] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites

2025-09-22 Thread Gustavo de Morais (Jira)
Gustavo de Morais created FLINK-38410: - Summary: Log test id on failure for RestoreTestBase and SemanticTestBase suites Key: FLINK-38410 URL: https://issues.apache.org/jira/browse/FLINK-38410

[jira] [Updated] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used

2025-09-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38409: --- Labels: pull-request-available (was: ) > Showcase in Helm chart values.yaml t

[jira] [Created] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core

2025-09-22 Thread Ruan Hang (Jira)
Ruan Hang created FLINK-38404: - Summary: JobMasterTest failed in test_cron_adaptive_scheduler core Key: FLINK-38404 URL: https://issues.apache.org/jira/browse/FLINK-38404 Project: Flink Issue

[jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021779#comment-18021779 ] Ruan Hang commented on FLINK-38403: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-09-22 Thread haiqingchen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021801#comment-18021801 ] haiqingchen commented on FLINK-38110: - [~ouyangwuli] could you help review the

[jira] [Commented] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021785#comment-18021785 ] Ruan Hang commented on FLINK-38408: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021783#comment-18021783 ] Ruan Hang commented on FLINK-38402: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021782#comment-18021782 ] Ruan Hang commented on FLINK-38404: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021780#comment-18021780 ] Ruan Hang commented on FLINK-38405: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021781#comment-18021781 ] Ruan Hang commented on FLINK-38402: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-38407) GroupAggregateRestoreTest failed in test_cron_azure table

2025-09-22 Thread Ruan Hang (Jira)
Ruan Hang created FLINK-38407: - Summary: GroupAggregateRestoreTest failed in test_cron_azure table Key: FLINK-38407 URL: https://issues.apache.org/jira/browse/FLINK-38407 Project: Flink Issue

[jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021778#comment-18021778 ] Ruan Hang commented on FLINK-38272: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core

2025-09-22 Thread Ruan Hang (Jira)
Ruan Hang created FLINK-38406: - Summary: DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Key: FLINK-38406 URL: https://issues.apache.org/jira/browse/FLINK-38406 Project: Flink

[jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021777#comment-18021777 ] Ruan Hang commented on FLINK-38402: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table

2025-09-22 Thread Ruan Hang (Jira)
Ruan Hang created FLINK-38405: - Summary: ChangelogNormalizeRestoreTest failed in test_cron_azure table Key: FLINK-38405 URL: https://issues.apache.org/jira/browse/FLINK-38405 Project: Flink

[jira] [Resolved] (FLINK-38370) CommitterOperator does not checkpoint all pending committables

2025-09-22 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-38370. Release Note: Fix an issue in the Sink V2 sink framework for batch pipelines

[jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline

2025-09-22 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021770#comment-18021770 ] Ruan Hang commented on FLINK-38272: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys

2025-09-22 Thread Gustavo de Morais (Jira)
Gustavo de Morais created FLINK-38401: - Summary: Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys Key: FLINK-38401 URL: https://issues.apache.org/jira/browse/FLINK-38401 Project: Flink

[jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-21 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv updated FLINK-38398: --- Priority: Blocker (was: Major) > Improve postgresSQL field Type supported ‘Temporal types Mapp

[jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37892: --- Labels: pull-request-available (was: ) > SplitFetcherManagerT

[jira] [Assigned] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-21 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv reassigned FLINK-38398: -- Assignee: ouyangwulin > Improve postgresSQL field Type supported ‘Temporal types Mapp

[jira] [Updated] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38399: --- Labels: pull-request-available (was: ) > As long as the join key includes one of

[jira] [Updated] (FLINK-38363) WindowedStream.trigger supports trigger with async state

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38363: --- Labels: pull-request-available (was: ) > WindowedStream.trigger supports trigger w

[jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

2025-09-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-38400: Fix Version/s: 1.20.4 > STDDEV/VAR function with FILTER condition may cause wrong res

[jira] [Created] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

2025-09-21 Thread lincoln lee (Jira)
lincoln lee created FLINK-38400: --- Summary: STDDEV/VAR function with FILTER condition may cause wrong result Key: FLINK-38400 URL: https://issues.apache.org/jira/browse/FLINK-38400 Project: Flink

[jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

2025-09-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-38400: Fix Version/s: (was: 1.20.4) > STDDEV/VAR function with FILTER condition may cause wr

[jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

2025-09-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-38400: Description: As reported in https://issues.apache.org/jira/browse/CALCITE-7192, the following

[jira] [Created] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join

2025-09-21 Thread Xuyang Zhong (Jira)
Xuyang Zhong created FLINK-38399: Summary: As long as the join key includes one of the indexes from the source, the join can be converted into a delta join Key: FLINK-38399 URL: https://issues.apache.org/jira

[jira] [Assigned] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join

2025-09-21 Thread Xuyang Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuyang Zhong reassigned FLINK-38399: Assignee: Xuyang Zhong > As long as the join key includes one of the indexes from

[jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-21 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-38398: Description: # After support timetype, serialization of time type, PostgresTypeUtils

[jira] [Commented] (FLINK-38190) Support async function in Python DataStream API

2025-09-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021726#comment-18021726 ] Dian Fu commented on FLINK-38190: - [~kaiqidong] Sure. > Support async func

[jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38398: --- Labels: pull-request-available (was: ) > Improve postgresSQL field Type suppor

[jira] [Created] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

2025-09-21 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-38398: --- Summary: Improve postgresSQL field Type supported ‘Temporal types Mapping’ Key: FLINK-38398 URL: https://issues.apache.org/jira/browse/FLINK-38398 Project: Flink

[jira] [Commented] (FLINK-38397) Runtime Exception in Planner

2025-09-21 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021686#comment-18021686 ] Gabor Somogyi commented on FLINK-38397: --- The issue is that order_by keeps

[jira] [Updated] (FLINK-38397) Runtime Exception in Planner

2025-09-21 Thread Ahmad Humayun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmad Humayun updated FLINK-38397: -- Environment: python 3.10.12 apache-flink 2.0.0 was:   {code:java} python 3.10.12 apache

[jira] [Created] (FLINK-38397) Runtime Exception in Planner

2025-09-21 Thread Ahmad Humayun (Jira)
Ahmad Humayun created FLINK-38397: - Summary: Runtime Exception in Planner Key: FLINK-38397 URL: https://issues.apache.org/jira/browse/FLINK-38397 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38110: --- Labels: pull-request-available (was: ) > PostgreSQL connector reads Chinese columns w

[jira] [Updated] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally

2025-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38396: --- Labels: pull-request-available (was: ) > DefaultKubernetesArtifactUploaderTest fa

[jira] [Created] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally

2025-09-21 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-38396: --- Summary: DefaultKubernetesArtifactUploaderTest fails locally Key: FLINK-38396 URL: https://issues.apache.org/jira/browse/FLINK-38396 Project: Flink

[jira] [Assigned] (FLINK-38332) Upgrade pemja to 0.5.5

2025-09-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-38332: --- Assignee: Xuannan Su > Upgrade pemja to 0.5.5 > -- > >

[jira] [Commented] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI

2025-09-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019046#comment-18019046 ] RocMarshal commented on FLINK-22258: FYI: The first section about backend sid

[jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink

2025-09-20 Thread Kaiqi Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019021#comment-18019021 ] Kaiqi Dong commented on FLINK-38319: Can I give it a try? thank

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-09-20 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-38109: - Affects Version/s: 2.1.0 (was: 1.11.0) > BlobServer isn't as

[jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext

2025-09-20 Thread Matt Cuento (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Cuento updated FLINK-38345: Description: `org.apache.flink.connector.base.source.hybrid.HybridSource` upon recovery from a

[jira] [Resolved] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES

2025-09-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38313. - Resolution: Fixed > Add support for DISTRIBUTION in MATERIALIZED TAB

[jira] [Updated] (FLINK-37209) Add Embedding AI Model for Qwen

2025-09-20 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv updated FLINK-37209: --- Fix Version/s: (was: cdc-3.5.0) > Add Embedding AI Model for Q

[jira] [Resolved] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields

2025-09-20 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-37245. Resolution: Duplicate > RowData#createFieldGetter can resurrect null values

[jira] [Updated] (FLINK-37736) Introduce Flink CDC metrics doc

2025-09-20 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv updated FLINK-37736: --- Fix Version/s: (was: cdc-3.5.0) > Introduce Flink CDC metrics

[jira] [Created] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables

2025-09-20 Thread Ramin Gharib (Jira)
Ramin Gharib created FLINK-38355: Summary: [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Key: FLINK-38355 URL: https://issues.apache.org/jira/browse/FLINK-38355 Project: Flink

[jira] [Updated] (FLINK-35229) join An error occurred when the table was empty

2025-09-20 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuannan Su updated FLINK-35229: --- Fix Version/s: 1.20.4 (was: 1.20.3) > join An error occurred when the ta

[jira] [Closed] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-09-20 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-38109. Resolution: Fixed [{{deee02b}}|https://github.com/apache/flink/commit

[jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted.

2025-09-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-38344: --- Description: When the {{{}historyserver.web.tmpdir{}}}configuration points to a non-system

[jira] [Updated] (FLINK-38332) Upgrade pemja to 0.5.5

2025-09-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-38332: Fix Version/s: 2.0.1 1.20.3 2.2.0 2.1.1

[jira] [Created] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version

2025-09-20 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-38364: --- Summary: Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Key: FLINK-38364 URL: https://issues.apache.org/jira/browse/FLINK-38364

[jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1)

2025-09-20 Thread Sergei Morozov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Morozov updated FLINK-38218: --- Description:   {*}Steps to reproduce{*}: # Prepare tables {{{}A{}}}, {{B}} and {{C}} to be

[jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility

2025-09-20 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019636#comment-18019636 ] Thomas Cooper commented on FLINK-38284: --- [~taron] Now that Hadoop 3.4.2 is

[jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2

2025-09-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020267#comment-18020267 ] Martijn Visser commented on FLINK-38350: [~pashley] I would love for u

[jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility

2025-09-20 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020693#comment-18020693 ] Thomas Cooper commented on FLINK-38284: --- [~pashley] If you can get the ha

[jira] [Commented] (FLINK-38385) Bump byte-buddy to 1.17.6

2025-09-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021473#comment-18021473 ] Sergey Nuyanzin commented on FLINK-38385: - Merge

  1   2   3   4   5   6   7   8   9   10   >