dev  

Messages by Thread

• Proposal to start a Flink digest blog. David Radley
• Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
• [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Robin Moffatt via dev
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Leonard Xu
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Ryan van Huuksloot via dev
• [jira] [Created] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss ConfX (Jira)
• [jira] [Created] (FLINK-38869) InitializationContext for KafkaSubscriber Efrat Levitan (Jira)
• [DISCUSSION] Question on FLIP-450 network buffer removal and high-throughput regression in Flink 2.0 Han You via dev
• [jira] [Created] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 Ferenc Csaky (Jira)
• [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline Daniel Rossos via dev
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline Sergio Chong Loo
• [jira] [Created] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath James Kan (Jira)
• [jira] [Created] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode Matt Cuento (Jira)
• [jira] [Created] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation Vishal Kamlapure (Jira)
• [jira] [Created] (FLINK-38864) HTTP Connector : Add IGNORE_STATUS_CODE http-completion-state david radley (Jira)
• [jira] [Created] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" Roman Grebennikov (Jira)
• [jira] [Created] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) Efrat Levitan (Jira)
• [jira] [Created] (FLINK-38861) Update Documentation to cover new CREATE/ALTER operations for MATERIALIZED TABLEs Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38860) Remove flink shaded guava usage from operator Gyula Fora (Jira)
• [jira] [Created] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode Gyula Fora (Jira)
• [jira] [Created] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication Gyula Fora (Jira)
• [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)
• [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
• [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)
• [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
• [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)
• [jira] [Created] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors Santwana Verma (Jira)
• [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
• [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
• [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 Yuepeng Pan
• [jira] [Created] (FLINK-38807) Add state SQL metadata type inference Gabor Somogyi (Jira)
• [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)
• [jira] [Created] (FLINK-38802) DDL with duplicated keys in table options should fail Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository RocMarshal (Jira)
• [jira] [Created] (FLINK-38800) Add a maven submodule for Flink MCP server. ChaomingZhang (Jira)
• [jira] [Created] (FLINK-38799) Rename "LoadingWeight" to "ResourceUnitCount" Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases Avi Sanwal (Jira)
• [jira] [Created] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self Wren (Jira)
• [ANNOUNCE] Apache Flink Agents 0.1.1 released wenjin
• [jira] [Created] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38795) Do not use "--host" CLI param for standalone job Ferenc Csaky (Jira)
• [Proposal] Dual-Sync Checkpoint Plugin for Geo-Redundant Flink MUKUL GUPTA via dev
• [jira] [Created] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38792) Properly support configuration parameters for Flink CDC UDFs Hans-Peter Grahsl (Jira)
• [jira] [Created] (FLINK-38791) Add suppotr for ALTER MATERIALIZED TABLE MODIFY Sergey Nuyanzin (Jira)
• [RESULT][VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 wenjin
• [jira] [Created] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2 Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38789) Consistently use AssertJ-related assertion APIs to implement assertions in the HTTP connector david radley (Jira)
• FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
• Minio going maintainace support only Samrat Deb
  • Re: Minio going maintainace support only Gabor Somogyi
  • Re: Minio going maintainace support only Ferenc Csaky
  • Re: Minio going maintainace support only Gabor Somogyi
• [jira] [Created] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation supreetha (Jira)
• [jira] [Created] (FLINK-38787) Add Metrics for FlinkBlueGreenDeployment resources Daniel Rossos (Jira)
• [jira] [Created] (FLINK-38786) Does support oracle-cdc partitioned table now ? laixiong (Jira)
• [jira] [Created] (FLINK-38785) Quotes removal doesn't remove them properly Muhammad (Jira)
• [jira] [Created] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 Muhammad (Jira)
• [jira] [Created] (FLINK-38783) Caused by: java.util.ConcurrentModificationException huyuliang (Jira)
• [jira] [Created] (FLINK-38782) Mongodb CDC need a config to filter large size column Joekwal (Jira)
• [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
  • Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Zander Matheson
• [jira] [Created] (FLINK-38781) pass format options to the http response david radley (Jira)
• [jira] [Created] (FLINK-38780) Potential State Incompatibility Issue in Paimon Sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38779) YAML Pipeline router supports RegEx based routing Xiqian Yu (Jira)
  • Re: [jira] [Created] (FLINK-38779) YAML Pipeline router supports RegEx based routing Hari Krishnan U
• [jira] [Created] (FLINK-38778) Web UI for applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38777) HistoryServer supports application archives Yi Zhang (Jira)
• [jira] [Created] (FLINK-38776) Incorrect auxiliary group field names dylanhz (Jira)
• [jira] [Created] (FLINK-38775) Flink 2.2: update reference data for Migration Tests Ruan Hang (Jira)
• [ANNOUNCE] Apache Flink 2.2.0 released Hang Ruan
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Ron Liu
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Jacky Lau
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Matt Cuento
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Hao Li via dev
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Weiqing Yang
• [jira] [Created] (FLINK-38774) Fixed incorrect handling of hidden directories when obtaining partition structure huyuliang (Jira)
• [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Eugene
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Dian Fu
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Hao Li via dev
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Xuannan Su
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Zhu Zhu
• [jira] [Created] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context Hao Li (Jira)
• [jira] [Created] (FLINK-38772) CliClientITCase is broken in IDE Sergey Nuyanzin (Jira)

• Earlier messages