dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Created] (FLINK-35296) Flink mysql-cdc connector stops reading data
Gang Yang (Jira)
[jira] [Created] (FLINK-35295) Improve jdbc connection pool initialization failure message
Xiao Huang (Jira)
[jira] [Created] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode
Xiao Huang (Jira)
[jira] [Created] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource
xingbe (Jira)
[jira] [Created] (FLINK-35292) Set dummy savepoint path during last-state upgrade
Gyula Fora (Jira)
[VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
yue ma
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Zakelly Lan
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Yanfei Lei
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Rui Fan
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Yuan Mei
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Hangxiang Yu
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Stefan Richter
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Roc Marshal
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Muhammet Orazov
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Yun Tang
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Gabor Somogyi
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
gongzhongqiang
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Roman Khachatryan
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Piotr Nowojski
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
ConradJam
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
周仁祥
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Keith Lee
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Ahmed Hamdy
Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Aleksandr Pilipenko
[RESULT][VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Xia Sun
[jira] [Created] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme
LiuZeshan (Jira)
[jira] [Created] (FLINK-35290) Wrong Instant type conversion TableAPI to Datastream in thread mode
Wouter Zorgdrager (Jira)
[jira] [Created] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode
Kanthi Vaidya (Jira)
[jira] [Created] (FLINK-35288) Flink Restart Strategy does not work as documented
Keshav Kansal (Jira)
[jira] [Created] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8
Mingliang Liu (Jira)
[jira] [Created] (FLINK-35286) Cannot discover Hive connector outside Hive catalog
Ryan Goldenberg (Jira)
[jira] [Created] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor
Trystan (Jira)
[jira] [Created] (FLINK-35284) Streaming File Sink end-to-end test times out
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35283) Add support unique Kafka producer client ids
Francis (Jira)
[VOTE] FLIP-454: New Apicurio Avro format
David Radley
Re: [VOTE] FLIP-454: New Apicurio Avro format
Nic Townsend
Re: [VOTE] FLIP-454: New Apicurio Avro format
Mark Nuttall
Re: [VOTE] FLIP-454: New Apicurio Avro format
Jeyhun Karimov
Re: [VOTE] FLIP-454: New Apicurio Avro format
Ahmed Hamdy
Re: [VOTE] FLIP-454: New Apicurio Avro format
Danny Cranmer
Re: [VOTE] FLIP-454: New Apicurio Avro format
Danny Cranmer
RE: [VOTE] FLIP-454: New Apicurio Avro format
David Radley
Re: [VOTE] FLIP-454: New Apicurio Avro format
Danny Cranmer
[jira] [Created] (FLINK-35282) Support for Apache Beam > 2.49
APA (Jira)
[jira] [Created] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once
Hongshun Wang (Jira)
[DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Muhammet Orazov
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Muhammet Orazov
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Péter Váry
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ferenc Csaky
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Péter Váry
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ahmed Hamdy
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Leonard Xu
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Hongshun Wang
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ahmed Hamdy
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ahmed Hamdy
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
lorenzo . affetti
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ahmed Hamdy
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Muhammet Orazov
Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
lorenzo . affetti
[jira] [Created] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API
Martijn Visser (Jira)
Discussion: Condition field in the CR status
Lajith Koova
Re: Discussion: Condition field in the CR status
Gyula Fóra
Re: Discussion: Condition field in the CR status
Jeyhun Karimov
Re: Discussion: Condition field in the CR status
Lajith Koova
RE: Discussion: Condition field in the CR status
David Radley
Re: Discussion: Condition field in the CR status
Lajith Koova
Re: Discussion: Condition field in the CR status
Lajith Koova
[jira] [Created] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob
Alan Zhang (Jira)
[RESULT][VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD
Mate Czagany
[jira] [Created] (FLINK-35278) Occasional NPE on k8s operator status replacement
Jira
[jira] [Created] (FLINK-35277) Fix the error in the `asncdcaddremove.sql` script for the DB2 test container.
wenli xiao (Jira)
[jira] [Created] (FLINK-35276) SortCodeGeneratorTest.testMultiKeys fails on negative zero
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35275) ArrayContainsFunction uses wrong DataType to create element getter
PengFei Li (Jira)
[DISCUSS] FLIP-444: Native file copy support
Piotr Nowojski
Re: [DISCUSS] FLIP-444: Native file copy support
Roman Khachatryan
Re: [DISCUSS] FLIP-444: Native file copy support
Stefan Richter
Re: [DISCUSS] FLIP-444: Native file copy support
Muhammet Orazov
Re: [DISCUSS] FLIP-444: Native file copy support
Hong Liang
Re: [DISCUSS] FLIP-444: Native file copy support
Aleksandr Pilipenko
Re: [DISCUSS] FLIP-444: Native file copy support
Zakelly Lan
Re: [DISCUSS] FLIP-444: Native file copy support
Piotr Nowojski
Re: [DISCUSS] FLIP-444: Native file copy support
Zakelly Lan
Re: [DISCUSS] FLIP-444: Native file copy support
Ahmed Hamdy
Re: [DISCUSS] FLIP-444: Native file copy support
Keith Lee
Re: [DISCUSS] FLIP-444: Native file copy support
Hangxiang Yu
Re: [DISCUSS] FLIP-444: Native file copy support
Piotr Nowojski
Re: [DISCUSS] FLIP-444: Native file copy support
Hangxiang Yu
Re: [DISCUSS] FLIP-444: Native file copy support
lorenzo . affetti
Re: [DISCUSS] FLIP-444: Native file copy support
Piotr Nowojski
Re: [DISCUSS] FLIP-444: Native file copy support
lorenzo . affetti
[jira] [Created] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT
Xin Gong (Jira)
[jira] [Created] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone
Biao Geng (Jira)
[VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Qingsheng Ren
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Muhammet Orazov
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Jeyhun Karimov
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Ahmed Hamdy
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Jingsong Li
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Qingsheng Ren
Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
gongzhongqiang
RE: Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1
Xiqian YU
[jira] [Created] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column
yux (Jira)
[jira] [Created] (FLINK-35271) Add doc for syntax `describe job 'xxx'`
xuyang (Jira)
[Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Timo Walther
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Muhammet Orazov
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Timo Walther
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg
Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Lincoln Lee
[jira] [Created] (FLINK-35270) Enrich information in logs, making it easier for debugging
Haifei Chen (Jira)
[jira] [Created] (FLINK-35269) Fix logging level for errors in AWS connector sinks
Aleksandr Pilipenko (Jira)
[DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Jeyhun Karimov
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Muhammet Orazov
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Muhammet Orazov
RE: [DISCUSS] FLIP-451: Refactor Async sink API
David Radley
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Hong Liang
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Leonard Xu
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Leonard Xu
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Ahmed Hamdy
Re: [DISCUSS] FLIP-451: Refactor Async sink API
Leonard Xu
[DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Yanfei Lei
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Roman Khachatryan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Stefan Richter
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Yanfei Lei
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Zakelly Lan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Zakelly Lan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Rui Fan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Rui Fan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Zakelly Lan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Zakelly Lan
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [DISCUSS] FLIP-443: Interruptible watermark processing
Zakelly Lan
Flink stateful functions and Agentic Architecture
David Carroll
Re: Flink stateful functions and Agentic Architecture
Yunfeng Zhou
[jira] [Created] (FLINK-35268) Support TTL for Async State API
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35267) Create documentation for FlinkStateSnapshot CR
Mate Czagany (Jira)
[jira] [Created] (FLINK-35266) Add e2e tests for FlinkStateSnapshot CRs
Mate Czagany (Jira)
[jira] [Created] (FLINK-35265) Implement FlinkStateSnapshot custom resource
Mate Czagany (Jira)
[jira] [Created] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect
yux (Jira)
[jira] [Created] (FLINK-35263) FLIP-446: Kubernetes Operator State Snapshot CRD
Mate Czagany (Jira)
[jira] [Created] (FLINK-35262) Bridge between AsyncKeyedStateBackend and AsyncExecutionController
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal comparison
yux (Jira)
[jira] [Created] (FLINK-35260) Translate "Watermark alignment "page into Chinese
hongxu han (Jira)
[jira] [Created] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field
Wenkai Qi (Jira)
[jira] [Created] (FLINK-35258) Broken links to Doris in Flink CDC Documentation
Qingsheng Ren (Jira)
[jira] [Created] (FLINK-35257) optimize the handling of schema.change.behavior as EXCEPTION
yanghuai (Jira)
[jira] [Created] (FLINK-35256) Pipeline transform ignores column type nullability
yux (Jira)
[jira] [Created] (FLINK-35255) DataSinkWriterOperator should override snapshotState和processWatermark method
yanghuai (Jira)
[jira] [Created] (FLINK-35254) build_wheels_on_macos failed
Weijie Guo (Jira)
[jira] [Created] (FLINK-35253) State Processor API
Juan Zifeng (Jira)
[jira] [Created] (FLINK-35252) Update the operators marked as deprecated in the instance program on the official website
hongxu han (Jira)
[jira] [Created] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint
Qingsheng Ren (Jira)
[jira] [Created] (FLINK-35250) Translate the "Flink Operations Playground" page into Chinese
Juan Zifeng (Jira)
[jira] [Created] (FLINK-35249) Support DataGeneratorSource in PyFlink
Wei Yuan (Jira)
[RESULT][VOTE] FLIP-399: Flink Connector Doris
wudi
[jira] [Created] (FLINK-35248) Support table/column comment to modify DDL
melin (Jira)
[jira] [Created] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21
Mason Chen (Jira)
[jira] [Created] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
[jira] [Created] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Xie Yi (Jira)
[jira] [Created] (FLINK-35244) Move package for flink-connector-tidb-cdc test
Xie Yi (Jira)
[jira] [Created] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents
yux (Jira)
[jira] [Created] (FLINK-35242) Add fine-grained schema evolution strategy
yux (Jira)
[VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Xia Sun
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Muhammet Orazov
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Rui Fan
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Ron Liu
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Zhu Zhu
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Lijie Wang
Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
yuxia
[jira] [Created] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ
Alexey Leonov-Vendrovskiy (Jira)
[jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning
Ufuk Celebi (Jira)
[jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization
zhangdingxin (Jira)
[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
Joao Boto
Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
Yuepeng Pan
Re: Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
João Boto
Re: Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
Yuepeng Pan
Re: [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
Muhammet Orazov
Re: [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
lorenzo . affetti
Re: [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
João Boto
Earlier messages
Later messages