dev  

Messages by Thread

• [jira] [Created] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException sehaj pal singh sandhu (Jira)
• Stale PR Action running but the labels are missing Tom Cooper
  • Re: Stale PR Action running but the labels are missing Rui Fan
• [jira] [Created] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator Leonard Xu (Jira)
• [jira] [Created] (FLINK-37123) FlinkCDC YAML supports TIMESTAMP_TZ Wenkai Qi (Jira)
• [jira] [Created] (FLINK-37121) Fix syntax and examples in create table statement doc Mingcan Wang (Jira)
• [jira] [Created] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. ChaomingZhang (Jira)
• [jira] [Created] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM JunboWang (Jira)
• [jira] [Created] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37118) Enhance flink cdc metrics melin (Jira)
• [jira] [Created] (FLINK-37117) Add docs for async state SQL operator in 2.0 xuyang (Jira)
• [jira] [Created] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 lincoln lee (Jira)
• [jira] [Created] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow hql0312 (Jira)
• [jira] [Created] (FLINK-37113) Introduce document for datastream api v2 Weijie Guo (Jira)
• [jira] [Created] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 xuhuang (Jira)
• [jira] [Created] (FLINK-37111) Allow setting `sink.version` for StarRocks Pipeline connector yux (Jira)
• [jira] [Created] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. Jira
• [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (with Coordination) Sergio Chong Loo
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (with Coordination) Sergio Chong Loo
• [jira] [Created] (FLINK-37109) Increase state processor API performance when reading keyed rocksdb state Gary Lam (Jira)
• [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Sergio Chong Loo
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Sergio Chong Loo
• [DISCUSSION] flink-connector-hive first release of externalized connector Sergey Nuyanzin
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Lincoln Lee
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Jark Wu
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Leonard Xu
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector yuxia
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Ron Liu
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Yanquan Lv
• [jira] [Created] (FLINK-37108) Source/Sink test suites test invalid recovery Arvid Heise (Jira)
• [RESULT][VOTE] FLIP-496: SQL connector for keyed state data Gabor Somogyi
• [jira] [Created] (FLINK-37107) Allow buffer overdraft in async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37106) Consider extracting common methods in WindowJoinOperator xuyang (Jira)
• [VOTE] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API weijie guo
  • Re: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API Junrui Lee
  • RE: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API xie wenjin
• [VOTE] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
  • Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API weijie guo
  • Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API Junrui Lee
  • Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API Zakelly Lan
  • RE: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API wenjin
• [jira] [Created] (FLINK-37105) Shade Apache Calcite in Flink CDC Wenkai Qi (Jira)
• [jira] [Created] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform Wenkai Qi (Jira)
• [jira] [Created] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. zhuanshenbsj1 (Jira)
• [jira] [Created] (FLINK-37102) ClassNotFoundException for ParquetColumnarRowInputFormat Krish Narukulla (Jira)
• [jira] [Created] (FLINK-37101) Remove internal set methods in SerializerConfig Zhanghao Chen (Jira)
• [RESULT][VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• Community Health Initiative (CHI) 9th of January minutes David Radley
• [jira] [Created] (FLINK-37100) Fix test_netty_shuffle_memory_control.sh in CI for JDK11+ Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37099) Document possible Netty4 configurations to setup Pekko properly in JDK11+ Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37098) Can not select time attribute from a view Dawid Wysakowicz (Jira)
• PR introducing V1 and V2 state migration issue David Radley
  • Re: PR introducing V1 and V2 state migration issue Alexander Fedulov
• [jira] [Created] (FLINK-37097) Remove david radley (Jira)
• Flink v2 download name David Radley
• [jira] [Created] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year sukang (Jira)
• [jira] [Created] (FLINK-37095) test case that used AI model may met quota not enough exception. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37094) Adapt the external Hive connector to the removal of deprecated APIs in table module in 2.0 xuyang (Jira)
• [jira] [Created] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder Mingcan Wang (Jira)
• [jira] [Created] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test. Junrui Lee (Jira)
• [jira] [Created] (FLINK-37091) Remove deprecated CatalogLock interface dalongliu (Jira)
• [jira] [Created] (FLINK-37090) Introduce tpc-ds e2e case for adaptive broadcast join Junrui Lee (Jira)
• [jira] [Created] (FLINK-37089) Advanced scheduling for derived async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine baimafeimayf (Jira)
• [jira] [Created] (FLINK-37087) Add docs for alter materialized table as query dalongliu (Jira)
• [jira] [Created] (FLINK-37086) State leaks for JBBC state store after job is stopped Rui Fan (Jira)
• [jira] [Created] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery Weijie Guo (Jira)
• [jira] [Created] (FLINK-37084) NullPointerException occurs during handling timer of window in PyFlink Dian Fu (Jira)
• [VOTE] FLIP-496: SQL connector for keyed state data Gabor Somogyi
  • Re: [VOTE] FLIP-496: SQL connector for keyed state data Zakelly Lan
  • Re: [VOTE] FLIP-496: SQL connector for keyed state data Márton Balassi
  • Re: [VOTE] FLIP-496: SQL connector for keyed state data Ferenc Csaky
  • Re: [VOTE] FLIP-496: SQL connector for keyed state data Gabor Somogyi
• [jira] [Created] (FLINK-37083) SqlYARNApplicationITCase.testDeployScriptViaSqlClient failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37082) Disable adaptive join optimization when enable batch job progress recovery xingbe (Jira)
• [jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher zhang (Jira)
• [jira] [Created] (FLINK-37080) Flink CDC Postgres when start with latest status in stream phase and add new table, it will be too slow hql0312 (Jira)
• [jira] [Created] (FLINK-37079) ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient xuyang (Jira)
• [jira] [Created] (FLINK-37078) Update jackson-mapper-asl dependency Anupam Aggarwal (Jira)
• [RESULT][VOTE] FLIP-493: Add K8S conditions to CRD's Status Lajith Koova
• [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization Timo Walther
• Does Flink operator 1.1.0 support Flink 1.20? David Radley
  • Re: Does Flink operator 1.1.0 support Flink 1.20? Rui Fan
  • RE: Does Flink operator 1.1.0 support Flink 1.20? David Radley
• [jira] [Created] (FLINK-37077) CLONE - Upgrade Stateful Functions to Flink 1.16.1 Oleksandr Kazimirov (Jira)
• [jira] [Created] (FLINK-37076) Support PTF skeleton in planner Timo Walther (Jira)
• [jira] [Created] (FLINK-37075) Cross-team verification for FLINK-31836 Xintong Song (Jira)
• [jira] [Created] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" Xintong Song (Jira)
• [jira] [Created] (FLINK-37074) Cross-team verification for FLINK-31362 Xintong Song (Jira)
• [jira] [Created] (FLINK-37072) Cross-team verification for FLIP-472 Xintong Song (Jira)
• [jira] [Created] (FLINK-37071) Cross-team verification for FLIP-398 Xintong Song (Jira)
• [jira] [Created] (FLINK-37070) Cross-team verification for FLIP-461 Xintong Song (Jira)
• [jira] [Created] (FLINK-37069) Cross-team verification for "Disaggregated State Management" Xintong Song (Jira)
• [jira] [Created] (FLINK-37068) Cross-team verification for FLIP-473 Xintong Song (Jira)
• [jira] [Created] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” Xintong Song (Jira)
• [jira] [Created] (FLINK-37066) Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table Feng Jin (Jira)
• [jira] [Created] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint Ihor Mielientiev (Jira)
• [jira] [Created] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Feng Jin (Jira)
• [jira] [Created] (FLINK-37061) Cross-team verification for FLINK-32688 Xintong Song (Jira)
• [jira] [Created] (FLINK-37062) Cross-team verification for FLINK-36147 Xintong Song (Jira)
• [jira] [Created] (FLINK-37063) Cross-team verification for "Drop support for Java 8" Xintong Song (Jira)
• [jira] [Created] (FLINK-37060) Cross-team verification for FLIP-398 Xintong Song (Jira)
• [jira] [Created] (FLINK-37059) Cross-team verification for FLINK-4602 Xintong Song (Jira)
• [jira] [Created] (FLINK-37058) Cross-team verification for FLINK-35573 Xintong Song (Jira)
• [jira] [Created] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer" Xintong Song (Jira)
• [jira] [Created] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values" Xintong Song (Jira)
• [jira] [Created] (FLINK-37056) Cross-team verification for FLINK-23620 Xintong Song (Jira)
• [jira] [Created] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" Xintong Song (Jira)
• [jira] [Created] (FLINK-37054) Cross-team verification for FLINK-33750 Xintong Song (Jira)
• [jira] [Created] (FLINK-37053) Cross-team verification for FLINK-14068 Xintong Song (Jira)
• [jira] [Created] (FLINK-37052) Cross-team verification for FLINK-36245 Xintong Song (Jira)
• [jira] [Created] (FLINK-37051) Cross-team verification for FLINK-36369 Xintong Song (Jira)
• [jira] [Created] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" Xintong Song (Jira)
• [jira] [Created] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Xintong Song (Jira)
• [jira] [Created] (FLINK-37047) Cross-team verification for "Remove DataSet API" Xintong Song (Jira)
• [SUMMARY] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• [jira] [Created] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format. hzk (Jira)
• [jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37044) Support connectors and formats as plugins Karan Makhija (Jira)
• [jira] [Created] (FLINK-37043) [Umbrella] Test Flink Release 2.0 Xintong Song (Jira)
• [jira] [Created] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions ChaomingZhang (Jira)
• [jira] [Created] (FLINK-37036) CLONE - [Release-1.20] Prepare RC0 release Xintong Song (Jira)
• [jira] [Created] (FLINK-37041) CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin Xintong Song (Jira)
• [jira] [Created] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown Weijie Guo (Jira)
• [jira] [Created] (FLINK-37034) CLONE - [Release-1.20] Select executing Release Manager Xintong Song (Jira)
• [jira] [Created] (FLINK-37037) CLONE - [Release-1.20] Review Release Notes in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37038) CLONE - [Release-1.20] Cross team testing Xintong Song (Jira)
• [jira] [Created] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation Xintong Song (Jira)
• [jira] [Created] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37035) CLONE - [Release-1.20] Create a release branch Xintong Song (Jira)
• [jira] [Created] (FLINK-37033) CLONE - [Release-1.20] Create a new version in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
• [jira] [Created] (FLINK-37030) Support lazy initialization for state serializer in State V2 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37029) Fix the materialized table docs of full mode cron expression dalongliu (Jira)
• [jira] [Created] (FLINK-37028) Datastream Window operator with async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37027) Chinese document translation for additional TO_TIMESTAMP_LTZ() functions Yiyu Tian (Jira)
• [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
  • RE: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API wenjin
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Junrui Lee
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• [jira] [Created] (FLINK-37026) Enable Stale PR Github Action Thomas Cooper (Jira)
• [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 weijie guo
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Yuepeng Pan
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Junrui Lee
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xintong Song
• [jira] [Created] (FLINK-37025) Periodic SQL watermarks can travel back in time Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37023) JobManager rest API returns 500 error with CancellationException amjidc (Jira)
• Elastic Scaling in Apache Flink and minimum parallelism Pavel Dmitriev
  • Re: Elastic Scaling in Apache Flink and minimum parallelism Rui Fan
• [NOTICE] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• [jira] [Created] (FLINK-37022) When will flink cdc support jdk21? Is there a support plan for jdk21 in the community? Hui Wang (Jira)
• [jira] [Created] (FLINK-37021) Implement fast rescaling for ForStKeyedStateBackend Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37020) Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. hiliuxg (Jira)
• [jira] [Created] (FLINK-37019) Bump junit to 5.11 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event Sai Sharath Dandi (Jira)
• [DISCUSS] - Propagation of Startup Errors Luca Castelli
• [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Gyula Fóra
  • RE: [VOTE] CHI: Stale PR cleanup David Radley
  • Re: [VOTE] CHI: Stale PR cleanup Ron Liu
  • Re: [VOTE] CHI: Stale PR cleanup Rui Fan
  • Re: [VOTE] CHI: Stale PR cleanup Luke Chen
  • Re: [VOTE] CHI: Stale PR cleanup Ahmed Hamdy
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Hong
  • Re: [VOTE] CHI: Stale PR cleanup Sergey Nuyanzin
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Andrei Kaigorodov
  • Re: [VOTE] CHI: Stale PR cleanup Venkatakrishnan Sowrirajan
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
• [jira] [Created] (FLINK-37017) Supports complex DataTypes in Flink CDC Leonard Xu (Jira)
• [jira] [Created] (FLINK-37016) NPE when ClusterEntrypoing is shut down before initialization Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37014) Examples are wrong in materialized table statment doc Mingcan Wang (Jira)
• [jira] [Created] (FLINK-37013) Job failed to restart on time liting liu (Jira)
• [jira] [Created] (FLINK-37012) Fix exception caused by MetadataColumns causing argument type mismatch MOBIN (Jira)
• [jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. ChaomingZhang (Jira)
• [jira] [Created] (FLINK-37010) Unify KeyedProcessFunction and the async one Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37009) Migrate PruneAggregateCallRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-37008) Flink UI should show the type of checkpoint (full vs incremental) Ryan van Huuksloot (Jira)
• [jira] [Created] (FLINK-37007) FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• [jira] [Created] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor Weijie Guo (Jira)
• [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Junrui Lee
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Fabian Paul
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Timo Walther
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xintong Song
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• [jira] [Created] (FLINK-37006) Apply changes from FLINK-36277 to AdaptiveJoin Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible Piotr Nowojski (Jira)

• Earlier messages