issues  

Messages by Thread

• • Re: [PR] [FLINK-38822] Introduce URL_DECODE_RECURSIVE function for recursive URL decoding [flink] via GitHub
• [jira] [Updated] (FLINK-39236) Adapt binary delta join runtime operator to structure of cascade delta join ASF GitHub Bot (Jira)
• [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
  • Re: [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
  • Re: [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
  • Re: [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
• Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Xin Gao (Jira)
• [jira] [Updated] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft ASF GitHub Bot (Jira)
• [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
  • Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• [jira] [Closed] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• Re: [PR] [FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink [flink-connector-elasticsearch] via GitHub
• [jira] [Closed] (FLINK-39222) Missing licences in HTTP connector files Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39235) Allow constants to be added to the json response in the HTTP Connector David Radley (Jira)
  • [jira] [Updated] (FLINK-39235) Allow constants to be added to the json response in the HTTP Connector David Radley (Jira)
• [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
  • Re: [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
• [PR] [FLINK-39200][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader [flink-cdc] via GitHub
• [jira] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• [jira] [Updated] (FLINK-39237) Docs training links should not depend on the Flink release branch Yu Tang (Jira)
  • [jira] [Updated] (FLINK-39237) Docs training links should not depend on the Flink release branch ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39237) Docs training links should not depend on the Flink release branch Yu Tang (Jira)
• [jira] [Commented] (FLINK-39030) Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs Liu (Jira)
• [jira] [Created] (FLINK-39236) Adapt binary delta join runtime operator to structure of cascade delta join Xuyang Zhong (Jira)
• [jira] [Commented] (FLINK-39050) Support configurable handling strategy for null rowtime field in watermark generation Liu (Jira)
• [jira] [Commented] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern Liu (Jira)
• [jira] [Commented] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• [jira] [Commented] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
• Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink] via GitHub
• [jira] [Created] (FLINK-39235) add David Radley (Jira)
• [jira] [Assigned] (FLINK-39235) add David Radley (Jira)
• [jira] [Updated] (FLINK-39232) CDC Transform matches first matching rule and deprecate partial filtering ASF GitHub Bot (Jira)
• [PR] [FLINK-39232] Modify Transform rules applying logic to first match only [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39232] Modify Transform rules applying logic to first match only [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39234) KafkaWriterFaultToleranceITCase flakiness due to NotLeaderOrFollowerException Efrat Levitan (Jira)
• [jira] [Commented] (FLINK-39051) Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF Liu (Jira)
• [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39232) CDC Transform matches first matching rule and deprecate partial filtering Xiqian Yu (Jira)
• [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
  • Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• [I] [Tech Debt] Fix GitHub Actions security by replacing the pull_request_target trigger in CI workflows [flink-agents] via GitHub
• Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-39055) [Iceberg] Support default column values in Iceberg sink connector Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-39228) [starrocks] Escape quoted default/comment literals in DDL ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• [jira] [Commented] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• [jira] [Assigned] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure Mingliang Zhu (Jira)
• Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• [jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed Liu (Jira)
• [jira] [Comment Edited] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• [jira] [Commented] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• [jira] [Assigned] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• [jira] [Created] (FLINK-39230) CDC Pipeline transform should handle partially-applied filters on UPDATE events Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE David Anderson (Jira)
  • [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• [jira] [Commented] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder David Anderson (Jira)
• Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• [jira] [Reopened] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
• [jira] [Closed] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
  • [jira] [Closed] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
• [PR] [hotfix] Update weekly CI releases [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] Update weekly CI versions [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager Zhanghao Chen (Jira)
• [jira] [Updated] (FLINK-39229) [JUnit5 Migration] Module: flink-protobuf ASF GitHub Bot (Jira)
• [PR] [FLINK-39229][test] Migrate tests of flink-protobuf to JUnit5 [flink] via GitHub
  • Re: [PR] [FLINK-39229][test] Migrate tests of flink-protobuf to JUnit5 [flink] via GitHub
• [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
  • Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
  • Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
  • [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
  • Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
  • Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39229) [JUnit5 Migration] Module: flink-protobuf Zhanghao Chen (Jira)
• [jira] [Assigned] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
  • [jira] [Assigned] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
  • Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
  • Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
• Re: [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] via GitHub
• Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
  • Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• [jira] [Created] (FLINK-39228) [starrocks] Escape quoted default/comment literals in DDL Mingliang Zhu (Jira)
• [jira] [Comment Edited] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Comment Edited] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• [PR] [starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
• [jira] [Resolved] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• [jira] [Created] (FLINK-39227) FLIP-566 Introduce a new IMMUTABLE columns constraint Xuyang Zhong (Jira)
• [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
  • [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
  • [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• [jira] [Created] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39225) Add retry with default value fallback for triton inference failures featzhang (Jira)
• [jira] [Updated] (FLINK-38857) Introduce a Triton inference module for batch-oriented AI inference featzhang (Jira)
• [jira] [Created] (FLINK-39224) Support PostgreSQL jsonb type CHANHAE OH (Jira)
• [jira] [Commented] (FLINK-29855) UDF randomly processed input data twice huyuliang (Jira)
• [jira] [Created] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
  • [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• [jira] [Resolved] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. Yanquan Lv (Jira)
• Re: [PR] [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist [flink-cdc] via GitHub
• [jira] [Comment Edited] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference Dian Fu (Jira)
  • [jira] [Comment Edited] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference Dian Fu (Jira)
• [jira] [Resolved] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Yanquan Lv (Jira)
• Re: [PR] [FLINK-38774] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager VISHAL B (Jira)
  • [jira] [Comment Edited] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-39222) Missing licences in HTTP connector files ASF GitHub Bot (Jira)
• [PR] [FLINK-39222] Add licenses to files and correct Flink version [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39222] Add licenses to files and correct Flink version [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39222] Add licenses to files and correct Flink version [flink-connector-http] via GitHub
• [jira] [Created] (FLINK-39222) Missing licences in HTTP connector files David Radley (Jira)
• [jira] [Assigned] (FLINK-39222) Missing licences in HTTP connector files David Radley (Jira)
• Re: [PR] Bump com.microsoft.sqlserver:mssql-jdbc from 10.2.1.jre8 to 11.1.0.jre8-preview in /flink-connector-jdbc-sqlserver [flink-connector-jdbc] via GitHub
  • Re: [PR] Bump com.microsoft.sqlserver:mssql-jdbc from 10.2.1.jre8 to 11.1.0.jre8-preview in /flink-connector-jdbc-sqlserver [flink-connector-jdbc] via GitHub
  • Re: [PR] Bump com.microsoft.sqlserver:mssql-jdbc from 10.2.1.jre8 to 11.1.0.jre8-preview in /flink-connector-jdbc-sqlserver [flink-connector-jdbc] via GitHub
• [PR] [hotfix] Fix Azure ChatModel class path in ResourceName. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix Azure ChatModel class path in ResourceName. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix Azure ChatModel class path in ResourceName. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix Azure ChatModel class path in ResourceName. [flink-agents] via GitHub
• [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
• [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
• [jira] [Commented] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs Gyula Komlossi (Jira)
• [jira] [Updated] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs ASF GitHub Bot (Jira)
• [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
  • Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
  • Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub

• Earlier messages
• Later messages