dev  

Messages by Thread

• [jira] [Created] (FLINK-37269) Add new DESCRIPTOR data type Timo Walther (Jira)
• [jira] [Created] (FLINK-37268) Add async state word count example Yanfei Lei (Jira)
• [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Martijn Visser
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Yanquan Lv
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Cong Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Lincoln Lee
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner weijie guo
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
• [jira] [Created] (FLINK-37267) Support WITH ORDINALITY for UNNEST Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37266) Python CLI arguments doesn't work in session mode Dian Fu (Jira)
• RabbitMQ Connector upgrade Fabrizzio Chávez Tejada
  • Re: RabbitMQ Connector upgrade Yanquan Lv
• [jira] [Created] (FLINK-37265) document of python elasticsearch connector exeample has a mistake Zhang Hechuan (Jira)
• [jira] [Created] (FLINK-37264) two bugs of DSv2 xuhuang (Jira)
• [jira] [Created] (FLINK-37263) AggregateITCase.testConstantGroupKeyWithUpsertSink failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option yux (Jira)
• [jira] [Created] (FLINK-37261) Provide JSON series functions in YAML pipeline JunboWang (Jira)
• [jira] [Created] (FLINK-37260) Change MySQL Connector address 911432 (Jira)
• [jira] [Created] (FLINK-37259) StreamCheckpointingITCase times out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-37258) Order Flink Job list in Flink UI with start time Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-37257) Add an API on keyedStream to allow users to customize the hash method from key to parallelism. Jinkun Liu (Jira)
• [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Xiqian YU
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 gongzhongqiang
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Robert Metzger
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 weijie guo
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
• [jira] [Created] (FLINK-37256) Firing timers can block recovery process Piotr Nowojski (Jira)
• Cancel flink-connector-mongodb v2.0.0 release candidate #1 Jiabao Sun
  • Re: Cancel flink-connector-mongodb v2.0.0 release candidate #1 Leonard Xu
• [jira] [Created] (FLINK-37255) Unsupported options: scan.partition.record-size Jiabao Sun (Jira)
• [jira] [Created] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常 caixiaowei (Jira)
• [DISCUSS] FLINK-20625: Reviewer needed for pubsub source refactor PR Claire McCarthy
• [jira] [Created] (FLINK-37253) Display state size in application status and deployment metrics Maximilian Michels (Jira)
• [jira] [Created] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37251) Add download link for pipeline connector. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37250) The flink application does not start because of an error in the configs Dmitriy Linevich (Jira)
• [jira] [Created] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37248) Scala was removed in flink 2.0 911432 (Jira)
• [jira] [Created] (FLINK-37247) Implement common Hadoop file system integration tests for GCS. Chris Nauroth (Jira)
• [DISCUSS] Operator 1.10 - error with FINISHED jobs that lead to no clean-up Luca Castelli
• [jira] [Created] (FLINK-37246) Delegation Token expire after enable delegation token framework Zhenqiu Huang (Jira)
• [DISCUSS] Improvements to SQL State Compatibility by Increasing Schema Evolution Capabilities Eric Xiao
• [RESULT][VOTE] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• [VOTE] Release flink-connector-hive, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-connector-hive, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-hive, release candidate #2 Lincoln Lee
  • Re: [VOTE] Release flink-connector-hive, release candidate #2 Jark Wu
  • Re: [VOTE] Release flink-connector-hive, release candidate #2 Leonard Xu
  • Re: [VOTE] Release flink-connector-hive, release candidate #2 Sergey Nuyanzin
• Re: [VOTE] Release flink-connector-hive, release candidate #1 Sergey Nuyanzin
• [jira] [Created] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• [jira] [Created] (FLINK-37244) ScyllaDB support in Cassandra connector. Maxim Korolyov (Jira)
• [jira] [Created] (FLINK-37243) Ensure that async callbacks happen on known thread Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37242) Enable setting custom labels for flink-operator-webhook-service thanh tung dao (Jira)
• [RESULT][VOTE] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• [jira] [Created] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase Jira
• Flink Operator 1.11 release planning Gyula Fóra
  • Re: Flink Operator 1.11 release planning Ferenc Csaky
  • Re: Flink Operator 1.11 release planning Tom Cooper
  • Re: Flink Operator 1.11 release planning ConradJam
  • Re: Flink Operator 1.11 release planning Peter Huang
  • Re: Flink Operator 1.11 release planning Sharath
  • Re: Flink Operator 1.11 release planning Maximilian Michels
  • Re: Flink Operator 1.11 release planning Rui Fan
  • Re: Flink Operator 1.11 release planning yuanfeng hu
  • RE: Flink Operator 1.11 release planning David Radley
  • Re: Flink Operator 1.11 release planning Gyula Fóra
  • RE: Flink Operator 1.11 release planning David Radley
• [jira] [Created] (FLINK-37240) Changing column nullability throws StateMigrationException in a SQL pipeline with a JOIN Eric Xiao (Jira)
• Minutes for 9th Community Health Initiative (CHI) Eastern time zone. David Radley
• [jira] [Created] (FLINK-37239) Improve documentation for multiple built-in functions Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-37237) Enforce SQL PRIMARY KEY definition for Kudu tables and remove table option Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37236) Make Flink operator compatible with 2.0 preview Gyula Fora (Jira)
• [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
  • Re: [VOTE] Release 1.20.1, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release 1.20.1, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.20.1, release candidate #1 David Radley
  • Re: [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
  • Re: [VOTE] Release 1.20.1, release candidate #1 Maximilian Michels
  • Re: [VOTE] Release 1.20.1, release candidate #1 weijie guo
  • RE: [VOTE] Release 1.20.1, release candidate #1 David Radley
  • Re: [VOTE] Release 1.20.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Release 1.20.1, release candidate #1 Rui Fan
  • Re: [VOTE] Release 1.20.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
• [jira] [Created] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8 Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37234) Add timeout for test case to avoid Infinite waiting Yanquan Lv (Jira)
• [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
  • Re: [VOTE] Release 1.19.2, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release 1.19.2, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.2, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
  • Re: [VOTE] Release 1.19.2, release candidate #1 Maximilian Michels
  • Re: [VOTE] Release 1.19.2, release candidate #1 Márton Balassi
  • Re: [VOTE] Release 1.19.2, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 1.19.2, release candidate #1 Robert Metzger
  • Re: [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
• [jira] [Created] (FLINK-37233) Flink-CDC Documentation change request 911432 (Jira)
• [jira] [Created] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side Matthias Pohl (Jira)
• Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
  • Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Fabian Hüske
  • Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
  • Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
  • Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Timo Walther
  • Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
• [VOTE] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
  • Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Natea Eshetu Beshada
  • Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Fabian Hüske
  • Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Timo Walther
  • Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Martijn Visser
  • Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Venkatakrishnan Sowrirajan
• Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re:Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Xuyang
  • Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Becket Qin
• [jira] [Created] (FLINK-37231) Add doc for newly added source metric statistics Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37230) Consolidate Kudu connector table options Ferenc Csaky (Jira)
• Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Matthias Pohl
• [jira] [Created] (FLINK-37229) Add DELETING/DELETED lifecycle states Gyula Fora (Jira)
• [jira] [Created] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20 sigalit (Jira)
• [jira] [Created] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner xiangyu feng (Jira)
• Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Becket Qin
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Becket Qin
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• [jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37225) Remove remaining test resources of Gelly Zhanghao Chen (Jira)
• Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Zhanghao Chen
• [jira] [Created] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. Yanquan Lv (Jira)
• 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
  • 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 Becket Qin
  • 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 Becket Qin
• Minutes for 8th Community Health Initiative (CHI) Western time zone. David Radley
• [jira] [Created] (FLINK-37222) Table planner exception when sql client submit job Zakelly Lan (Jira)
  • Re: [jira] [Created] (FLINK-37222) Table planner exception when sql client submit job Sebastien Pereira
• 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) 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) 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
• [jira] [Created] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator Ben Brandt (Jira)
• [jira] [Created] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads Matthias Pohl (Jira)
• [jira] [Created] (FLINK-37219) Support value state in PTFs Timo Walther (Jira)
• Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Timo Walther
  • Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Fabian Hüske
  • Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Martijn Visser
  • Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• [jira] [Created] (FLINK-37218) Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. Junrui Lee (Jira)
• [jira] [Created] (FLINK-37217) In `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly yuanfenghu (Jira)

• Later messages