issues  

Messages by Thread

• • Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
  • Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
  • Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
• [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
  • Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
  • Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
• [PR] [FLINK-39166] Add bucket-level configuration support to Native S3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39166] Add bucket-level configuration support to Native S3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39166] Add bucket-level configuration support to Native S3 FileSystem [flink] via GitHub
• Re: [PR] [FLINK-39265][postgres] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering [flink-cdc] via GitHub
• [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] via GitHub
  • Re: [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] via GitHub
  • Re: [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] via GitHub
  • Re: [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] via GitHub
  • Re: [PR] [FLINK-39095][table][planner] Display ChangelogMode in execution plan for streaming queries [flink] via GitHub
• [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
• [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• [jira] [Created] (FLINK-39274) TM It is impossible to bypass the KDC login process, yet the TOKEN issued by AM has not been actually utilized. ruiliang (Jira)
• [jira] [Resolved] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase Yanquan Lv (Jira)
• [PR] [FLINK-39273][table-common] Fix argument name conflict when UDF method contains lambda expression [flink] via GitHub
  • Re: [PR] [FLINK-39273][table-common] Fix argument name conflict when UDF method contains lambda expression [flink] via GitHub
• [jira] [Updated] (FLINK-39273) UDF throws "Argument name conflict" when eval method contains lambda expression dylanhz (Jira)
  • [jira] [Updated] (FLINK-39273) UDF throws "Argument name conflict" when eval method contains lambda expression dylanhz (Jira)
  • [jira] [Updated] (FLINK-39273) UDF throws "Argument name conflict" when eval method contains lambda expression ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39273) ScalarFunction throws "Argument name conflict" when eval method contains lambda expression dylanhz (Jira)
• Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• [I] [Feature] Support TTL on Short Term Memory [flink-agents] via GitHub
  • Re: [I] [Feature] Support TTL on Short Term Memory [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-39272) Changing of REFRESH_MODE for CREATE OF ALTER MATERIALIZED TABLE should fail Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39272) Changing of REFRESH_MODE for CREATE OF ALTER MATERIALIZED TABLE should fail Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39218) Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin (Jira)
• [jira] [Updated] (FLINK-39272) Changing of REFRESH_MODE for CREATE OF ALTER MATERIALIZED TABLE should fail ASF GitHub Bot (Jira)
• [PR] [FLINK-39272][table] Changing of `REFRESH_MODE` for `CREATE OF ALTER MATERIALIZED TABLE` should fail [flink] via GitHub
  • Re: [PR] [FLINK-39272][table] Changing of `REFRESH_MODE` for `CREATE OF ALTER MATERIALIZED TABLE` should fail [flink] via GitHub
  • Re: [PR] [FLINK-39272][table] Changing of `REFRESH_MODE` for `CREATE OF ALTER MATERIALIZED TABLE` should fail [flink] via GitHub
• [jira] [Created] (FLINK-39272) Changing of REFRESH_MODE for CREATE OF ALTER MATERIALIZED TABLE should fail Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39000] [runtime] Avoid redundant seeks during operator list state restore [flink] via GitHub
• [jira] [Resolved] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable Yuepeng Pan (Jira)
• [PR] [Tech Debt]Add cross-language resource consistency checking tool [flink-agents] via GitHub
  • Re: [PR] [Tech Debt]Add cross-language resource consistency checking tool [flink-agents] via GitHub
• [PR] [hotfix][flink-autoscaler] Skip redundant overrides in JobAutoScalerImpl when job is not running [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][flink-autoscaler] Skip redundant overrides in JobAutoScalerImpl when job is not running [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][flink-autoscaler] Skip redundant overrides in JobAutoScalerImpl when job is not running [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-39244) Support precision 0-9 for TO_TIMESTAMP_LTZ function Timo Walther (Jira)
• [jira] [Assigned] (FLINK-39244) Support precision 0-9 for TO_TIMESTAMP_LTZ function Timo Walther (Jira)
• [jira] [Updated] (FLINK-39271) Harden session job deletion flow ASF GitHub Bot (Jira)
• [PR] [FLINK-39271] Harden session job deletion flow [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39271) Harden session job deletion flow Gyula Fora (Jira)
• [PR] [FLINK-39270] Fix savepoint/last-state upgrade state loss under slow JM [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39270) Fix savepoint/last-state upgrade state loss under slow JM Gyula Fora (Jira)
• [jira] [Updated] (FLINK-39270) Fix savepoint/last-state upgrade state loss under slow JM Gyula Fora (Jira)
  • [jira] [Updated] (FLINK-39270) Fix savepoint/last-state upgrade state loss under slow JM ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
• [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
  • Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
  • Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
  • Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
  • Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
• [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
  • [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
  • [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt ASF GitHub Bot (Jira)
• [PR] Announce Flink Agents 0.2.1 [flink-web] via GitHub
• [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
  • Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
• [jira] [Updated] (FLINK-39269) Keep doc for deprecated config option Qinghui Xu (Jira)
• [jira] [Created] (FLINK-39269) Keep doc for deprecated config option Qinghui Xu (Jira)
• Re: [PR] Rebuild website [flink-web] via GitHub
  • Re: [PR] Rebuild website [flink-web] via GitHub
  • Re: [PR] Rebuild website [flink-web] via GitHub
  • Re: [PR] Rebuild website [flink-web] via GitHub
• Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-39183) Support BITMAP type in Calcite parser lincoln lee (Jira)
• [jira] [Closed] (FLINK-39183) Support BITMAP type in Calcite parser lincoln lee (Jira)
• [I] [Bug] In MCPServer#listPrompts, Flink Agents unconditionally passes arg.required() to new MCPPrompt.PromptArgument(...). Later Boolean unboxing triggers a NullPointerException: [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
• Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38592) [Phase 1] Native Flink S3 FileSystem Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Timo Walther (Jira)
  • [jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Liu (Jira)
• Re: [I] [Tech Debt] Reduce size of flink-agents wheel [flink-agents] via GitHub
• [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-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-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-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-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-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
• [PR] [hotfix] Fix mismatch version. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix mismatch version. [flink-agents] via GitHub
• [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
  • Re: [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication Yanquan Lv (Jira)
• Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [PR] Clear stale savepointTriggerId on B/G transition abort [flink-kubernetes-operator] via GitHub
  • Re: [PR] Clear stale savepointTriggerId on B/G transition abort [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
• [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
  • Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
  • Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
  • Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
• [jira] [Created] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Liu (Jira)
• Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39267) Support dynamically updating checkpoint configuration at runtime via REST API Liu (Jira)
• [jira] [Created] (FLINK-39267) Support dynamically updating checkpoint configuration at runtime via REST API Liu (Jira)
• Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager ASF GitHub Bot (Jira)
• [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
  • Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• [PR] [hotfix][docs] Restore target.utilization.boundary in configuration docs [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-38930) Filtering record before processing without spilling strategy ASF GitHub Bot (Jira)
• [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
• [jira] [Updated] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled ASF GitHub Bot (Jira)
• [PR] [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled [flink] via GitHub
  • Re: [PR] [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled [flink] via GitHub
• Re: [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage [flink] via GitHub
• [jira] [Resolved] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• [jira] [Updated] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• [jira] [Assigned] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• [jira] [Comment Edited] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Rui Fan (Jira)
• [jira] [Assigned] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Rui Fan (Jira)
• [jira] [Updated] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• [jira] [Commented] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• [jira] [Resolved] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering Di Wu (Jira)
  • [jira] [Updated] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering Di Wu (Jira)
• [jira] [Updated] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type Dian Fu (Jira)
• [jira] [Commented] (FLINK-38587) docker entrypoint script cannot handle FLINK_PROPERTIES that include spaces Jira
• [jira] [Resolved] (FLINK-39230) CDC Pipeline transform should handle partially-applied filters on UPDATE events Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-39184) Introduce Bitmap type for DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-39264) Add docs for application management Yi Zhang (Jira)
• [jira] [Commented] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Samrat Deb (Jira)
• [jira] [Commented] (FLINK-38545) Update Pulsar connector to Flink 1.20 Fabrizzio Chavez (Jira)
  • [jira] [Commented] (FLINK-38545) Update Pulsar connector to Flink 1.20 Ferenc Csaky (Jira)
  • [jira] [Commented] (FLINK-38545) Update Pulsar connector to Flink 1.20 Fabrizzio Chavez (Jira)
• [jira] [Resolved] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• [jira] [Commented] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• [jira] [Assigned] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Barak (Jira)
• [jira] [Closed] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-39263) Support custom codecs in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• [jira] [Created] (FLINK-39262) Support dynamic namespace selection in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• [jira] [Updated] (FLINK-39262) Support dynamic namespace selection in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• [jira] [Created] (FLINK-39261) Add FROM_CHANGELOG built-in process table function (4.1.3.1 upsert stream to upsert stream) Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-39259) Add TO_CHANGELOG built-in process table function (4.2.2.2 upsert/retract stream, flat mode) Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-39259) Add TO_CHANGELOG built-in process table function (4.2.2.2 upsert/retract stream, flat mode) Timo Walther (Jira)
• [jira] [Assigned] (FLINK-39260) Support multi-compression format python files Dian Fu (Jira)

• Earlier messages
• Later messages