dev  

Messages by Thread

• [jira] [Created] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37202) Introduce TDengine connector kevinmen (Jira)
  • Re: [jira] [Created] (FLINK-37202) Introduce TDengine connector David Radley
• [jira] [Created] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. Wenkai Qi (Jira)
• [jira] [Created] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37198) AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row. Juliusz Nadberezny (Jira)
• [jira] [Created] (FLINK-37197) Release flink-connector-mongodb v2.0.0 for Flink 1.20 Jiabao Sun (Jira)
• [Discuss] Flink CDC 3.4 Kick Off Yanquan Lv
  • Re: [Discuss] Flink CDC 3.4 Kick Off ConradJam
  • Re: [Discuss] Flink CDC 3.4 Kick Off Leonard Xu
  • Re: [Discuss] Flink CDC 3.4 Kick Off Ferenc Csaky
• [SUMMARY] Flink 2.0 Release Sync 01/22/2015 Xintong Song
• [ANNOUNCE] Release 2.0.0, release candidate #0 Xintong Song
• [jira] [Created] (FLINK-37196) Build documentation github action can't work Weijie Guo (Jira)
• [jira] [Created] (FLINK-37195) TimestampAdd / TimestampDiff series function not available in cluster yux (Jira)
• [jira] [Created] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-37193) Ingress recreated after perform a change to CRD Jira
• [jira] [Created] (FLINK-37192) [pyflink] Replace deprecated avro-python3 with avro Mina Asham (Jira)
• [jira] [Created] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes Leonard Xu (Jira)
• [jira] [Created] (FLINK-37190) Make Kudu `FlushMode` configurable in Flink SQL Ferenc Csaky (Jira)
• [ANNOUNCE] Apache Flink CDC 3.3.0 released Hang Ruan
  • Re: [ANNOUNCE] Apache Flink CDC 3.3.0 released Leonard Xu
• [jira] [Created] (FLINK-37189) Incorrect version string of maven-enforcer-plugin requireJavaVersion xuhuang (Jira)
• [RESULT] [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Hang Ruan
• [jira] [Created] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" Feng Jin (Jira)
• [jira] [Created] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s Feng Jin (Jira)
• [jira] [Created] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37185) NoClassDefFoundError raised from ORC tests Weijie Guo (Jira)
• [KINDELY REMINDER] Flink 2.0 Release Sync 01/22/2025 Xintong Song
• [jira] [Created] (FLINK-37184) Support ZStandard compressed input in new File API Joery (Jira)
• [jira] [Created] (FLINK-37183) Usrlib symlinks are not followed Joery (Jira)
• [jira] [Created] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes. Ao Li (Jira)
• [jira] [Created] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37180) Implement StreamOperator for PTF Timo Walther (Jira)
• [jira] [Created] (FLINK-37179) [ArgoCD] App Out Of sync after update to v1.6.0 Jira
• [ANNOUNCE] Flink 2.0 feature freeze Xintong Song
• [jira] [Created] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37177) Update chinese documentation of json function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37176) setup_hugo.sh doesn't work on macbook Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37175) Support JSON built-in function for JSON_OBJECT Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37174) SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed xuyang (Jira)
• [jira] [Created] (FLINK-37173) Failed to pass license check in JDK11 build Weijie Guo (Jira)
• [jira] [Created] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running xuyang (Jira)
• [jira] [Created] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules xuyang (Jira)
• [jira] [Created] (FLINK-37170) Disable 1.18 CI Matthias Pohl (Jira)
• [jira] [Created] (FLINK-37169) Broken links to connector JARs in documentation xxchan (Jira)
• [jira] [Created] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered Shuyi Chen (Jira)
• [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Hang Ruan
  • Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Xingbo Huang
  • Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 weijie guo
• [jira] [Created] (FLINK-37166) FlinkConfigManager version prefix logic not safe Gyula Fora (Jira)
• [jira] [Created] (FLINK-37167) Fix operand reordering in SqlValidatorImpl for tableCharacteristics Timo Walther (Jira)
• [jira] [Created] (FLINK-37165) The starrocks connector is found to be missing some options. sukang (Jira)
• [jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37162) Add Data Sources Documentation Yanquan Lv (Jira)
• [DISCUSS] Release Flink CDC version 3.3.0 Hang Ruan
  • Re: [DISCUSS] Release Flink CDC version 3.3.0 Leonard Xu
  • Re: [DISCUSS] Release Flink CDC version 3.3.0 Yanquan Lv
• [jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" Junrui Lee (Jira)
• [jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• [jira] [Created] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37157) Enable daily benchmark for Java 21 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks. cheng qian (Jira)
• [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yanquan Lv
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yanquan Lv
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Venkatakrishnan Sowrirajan
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
• [jira] [Created] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison Chang (Jira)
• Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Gyula Fóra
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Tom Cooper
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Luke Chen
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Samrat Deb
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Maximilian Michels
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexis Sarda-Espinosa
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) ConradJam
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Tom Cooper
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) gyula . fora
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Maximilian Michels
  • Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Márton Balassi
• [jira] [Created] (FLINK-37154) Support reading binary data from Kafka Dian Fu (Jira)
• [jira] [Created] (FLINK-37153) Monitor late event count in temporal join Jira
• [jira] [Created] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37151) Remove reduandant testing dependencies of Flink UI Ao Yuchen (Jira)
• [jira] [Created] (FLINK-37150) Adjust the documentation of the configuration file to remove the support for the old configuration file." Junrui Lee (Jira)
• [jira] [Created] (FLINK-37149) Add Adaptive Batch Execution Documentation Junrui Lee (Jira)
• [RESULT][VOTE] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• [RESULT][VOTE] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• [jira] [Created] (FLINK-37148) Add documentation for datastream v2 api Weijie Guo (Jira)
• [jira] [Created] (FLINK-37147) The where condition run time advance caused a program error lixu (Jira)
• [jira] [Created] (FLINK-37146) Prometheus Push Gateway not work on 1.18.1 Naijie Liu (Jira)
• [jira] [Created] (FLINK-37145) testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37143) Update version of flink-connector-kafka to 4.0-SNAPSHOT Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37144) Update flink-connector-kafka version to 3.4-SNAPSHOT Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37142) Update version of flink-connector-kafka to 4.0-SNAPSHOT Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37141) The version of the Flink Operator in operatorhub.io is old 1.6.0 Hector Miuler Malpica Gallegos (Jira)
• [ANNOUNCE] Flink master branch default JDK changed to JDK 17 Martijn Visser
• [jira] [Created] (FLINK-37140) Create InternalTimerServiceAsyncImpl when restore async operator Yanfei Lei (Jira)
• [NOTICE] Release 2.0 Feature Freeze on Jan 20 Xintong Song
• [jira] [Created] (FLINK-37139) Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios Lei Yang (Jira)
• [SUMMARY] Flink 2.0 Release Sync 01/15/2025 Xintong Song
• [jira] [Created] (FLINK-37138) testDeployScriptViaSqlClient failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37137) testGenerateStreamGraphJson failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API xuhuang (Jira)
• [jira] [Created] (FLINK-37135) FLIP-500: Support Join Extension in DataStream V2 API xuhuang (Jira)
• [jira] [Created] (FLINK-37134) Cross-team verification for FLIP-492 Feng Jin (Jira)
• [jira] [Created] (FLINK-37133) Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s Feng Jin (Jira)
• [jira] [Created] (FLINK-37132) Add schema validation in Multi Transform MOBIN (Jira)
• [jira] [Created] (FLINK-37131) checkpoint tolerable-failed invalid altenchen (Jira)
• [jira] [Created] (FLINK-37130) Provide a util converting future of StateIterator to Iterable Zakelly Lan (Jira)
• Re: StreamingFilSink with FlinkRunner Taher Koitawala
  • Re: StreamingFilSink with FlinkRunner Taher Koitawala
• [jira] [Created] (FLINK-37129) AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37128) Skip binlog replay filter when skip backfill JunboWang (Jira)
• [jira] [Created] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37126) Add Validator for Autoscler yuanfenghu (Jira)
• 退订 王飞
  • 退订 cun8cun8
  • 退订 乔志权
  • 退订 cun8cun8
  • 退订 李乐
  • 退订 李乐
  • 退订 于峰13
  • 退订 peibin wang
• [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
  • Re: Stale PR Action running but the labels are missing Rui Fan
  • RE: Stale PR Action running but the labels are missing David Radley
  • RE: Stale PR Action running but the labels are missing Tom Cooper
  • Re: Stale PR Action running but the labels are missing Rui Fan
  • Re: Stale PR Action running but the labels are missing Tom Cooper
  • Re: Stale PR Action running but the labels are missing Rui Fan
  • Re: Stale PR Action running but the labels are missing Tom Cooper
  • RE: Stale PR Action running but the labels are missing David Radley
• [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
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Eric Xiao
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
  • Re: [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) Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Alexis Sarda-Espinosa
  • Re: [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) Gyula Fóra
  • Re: [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) Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Rui Fan
  • Re: [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
  • Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Rui Fan
• [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
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector David Radley
  • Re: [DISCUSSION] flink-connector-hive first release of externalized connector Ahmed Hamdy
  • Re:Re: [DISCUSSION] flink-connector-hive first release of externalized connector Xuyang

• Earlier messages
• Later messages