dev  

Messages by Thread

• [jira] [Created] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference featzhang (Jira)
• [jira] [Created] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component Sergey Nuyanzin (Jira)
• Re: [jira] [Updated] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema Matthias Pohl
• [jira] [Created] (FLINK-38855) Upgrade jackson to 2.20.1 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38854) Enrich upsert keys across equivalence relations in MultiJoin Anton Borisov (Jira)
• [jira] [Created] (FLINK-38853) Enhance the standardization of the REST API JSON schema Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type dylanhz (Jira)
• [jira] [Created] (FLINK-38851) [Connector/JDBC] Support passing arbitrary database options to JDBC Catalog CHANHAE OH (Jira)
• [jira] [Created] (FLINK-38850) [Connector/JDBC] Support PostgreSQL uuid type CHANHAE OH (Jira)
• [jira] [Created] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations Matt Cuento (Jira)
  • Re: [jira] [Created] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations MD
• [jira] [Created] (FLINK-38848) Catalog#getTable should indicate if it's for writing He Qi (Jira)
• [jira] [Created] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId Di Wu (Jira)
• [jira] [Created] (FLINK-38846) Binlog client use LinkedList to store binlog content Jira
• [jira] [Created] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector tchivs (Jira)
• [jira] [Created] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart RocMarshal (Jira)
• [jira] [Created] (FLINK-38842) FileSink may leave orphaned temporary files in COS after restoring from a checkpoint, due to missing cleanup logic for temporary files in the checkpointed state. linguoxuan (Jira)
• [VOTE] Release flink-shaded 21.0, release candidate #2 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Mate Czagany
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Martijn Visser
• [jira] [Created] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy dylanhz (Jira)
• [jira] [Created] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
• [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Leonard Xu
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
• [jira] [Created] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Yanquan Lv (Jira)
• Re: [DISCUSS] Release flink-shaded 21.0 Martijn Visser
• [VOTE] Release flink-shaded 21.0, release candidate #1 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #1 Martijn Visser via dev
• [jira] [Created] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• [jira] [Created] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. peiyu (Jira)
• [jira] [Created] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38834) Support modify column type DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization peiyu (Jira)
• [jira] [Created] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
• [jira] [Created] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• Follow-up: ASF Account Application for Chen Rui rui chen
• [jira] [Created] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type dylanhz (Jira)
• [jira] [Created] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• [jira] [Created] (FLINK-38824) Incorrect default values for primitive types dylanhz (Jira)
• [Result][Vote] FLIP-556: Introduce BITMAP Data Type dylanhz
• Vendor-specific repos (re: flink-connector-aws) Rich Bowen
  • Re: Vendor-specific repos (re: flink-connector-aws) Robert Metzger
  • Re: Vendor-specific repos (re: flink-connector-aws) tison
  • Re: Vendor-specific repos (re: flink-connector-aws) tison
  • Re: Vendor-specific repos (re: flink-connector-aws) Rich Bowen
• [jira] [Created] (FLINK-38823) Error running wide table task peiyu (Jira)
• [jira] [Created] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding featzhang (Jira)
• [jira] [Created] (FLINK-38821) Add TaskManager creation/deletion metrics to Active Resource Manager moonyoung (Jira)
• [jira] [Created] (FLINK-38820) Move ptf rules to rule folder Hao Li (Jira)
• Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Timo Walther
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ron Liu
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Arvid Heise
  • [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re:[DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Xuyang
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re:Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Xuyang
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Timo Walther
  • Re:Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Xuyang
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re:Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Xuyang
• [jira] [Created] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors Santwana Verma (Jira)
• Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl via dev
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [jira] [Created] (FLINK-38818) [posgtresql]Build createTableEventCache using TableSchemas from split and Make transform operator stateless ouyangwulin (Jira)
• [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Rui Fan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) yuanfeng hu
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) gongzhongqiang
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Matt Cuento
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) 董书佑
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) dylanhz
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Wei Zhong
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Leonard Xu
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Mang Zhang
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Zhanghao Chen
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Ferenc Csaky
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Efrat Levitan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Maximilian Michels
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Sergey Nuyanzin
  • RE: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Zakelly Lan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Weiqing Yang
• [jira] [Created] (FLINK-38817) Out of order data seen while running tpc-ds queries Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 david radley (Jira)
• [jira] [Created] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager dengxaing (Jira)
• [jira] [Created] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Zhu Zhu
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Lei Yang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Lei Yang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Gyula Fóra
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Shengkai Fang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Gyula Fóra
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Gyula Fóra
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement gyula . fora
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
• Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li via dev
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
• [jira] [Created] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• [jira] [Created] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• [VOTE] FLIP-556: Introduce BITMAP Data Type dylanhz
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Lincoln Lee
  • Re:Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Xuyang
  • Re: Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Yuepeng Pan
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Zhe Wang
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Ron Liu
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Hao Li via dev
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Shengkai Fang
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type dylanhz
• [jira] [Created] (FLINK-38811) Translate async function doc to Chinese Hao Li (Jira)
• [jira] [Created] (FLINK-38810) Use splittable timers in Interval Join Roman Khachatryan (Jira)
• Request to review GCP fix from FLINK-38225 Alex Nitavsky
• [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Martijn Visser
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Gabor Somogyi
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Tom Cooper
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Tom Cooper
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Hang Ruan
• [jira] [Created] (FLINK-38809) Update testcontainers to 2.0.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-38808) Support partition transforms in Iceberg sink ChaoFang (Jira)
• [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Pan Yuepeng
  • Re:[DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Mang Zhang
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner yuanfeng hu
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
• Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
• Re: Optional configuration parameters for better performance Aleksandr Savonin
  • Re: Optional configuration parameters for better performance Rahul Teke
  • Re: Optional configuration parameters for better performance Rahul Teke
  • Re: Optional configuration parameters for better performance Aleksandr Savonin
  • Re: Optional configuration parameters for better performance Rahul Teke
• [jira] [Created] (FLINK-38807) Add state SQL metadata type inference Gabor Somogyi (Jira)
• Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder David Anderson
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
• [jira] [Created] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule yux (Jira)
• [jira] [Created] (FLINK-38805) Flaky test cases in JDBC connector. RocMarshal (Jira)
• [jira] [Created] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down Rui Fan (Jira)
• [jira] [Created] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. david radley (Jira)

• Later messages