dev
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/12/30
Re: Resolving Flink Backpressure
Samrat Deb
2024/12/30
[jira] [Created] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in
Yanquan Lv (Jira)
2024/12/30
Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Hongshun Wang
2024/12/30
Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Ahmed Hamdy
2024/12/30
Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables
Lincoln Lee
2024/12/30
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/30
Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables
Ron Liu
2024/12/30
[jira] [Created] (FLINK-36981) The bug of transform merging with route in YAML task
Wenkai Qi (Jira)
2024/12/30
[jira] [Created] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka"
sukang (Jira)
2024/12/29
[REMINDER] 2 weeks away from release 2.0 feature freeze
Xintong Song
2024/12/29
Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Hongshun Wang
2024/12/29
Re: Memory leak in pekko's Netty 4 transport.
ConradJam
2024/12/29
Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Hongshun Wang
2024/12/29
[VOTE] FLIP-492: Support Query Modifications for Materialized Tables
Feng Jin
2024/12/29
Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Ahmed Hamdy
2024/12/29
[jira] [Created] (FLINK-36979) Revert netty bump for 1.20 and 1.19
Matthias Pohl (Jira)
2024/12/29
Re: Memory leak in pekko's Netty 4 transport.
Matthias Pohl
2024/12/29
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Hongshun Wang
2024/12/28
Re: Memory leak in pekko's Netty 4 transport.
PJ Fanning
2024/12/28
Memory leak in pekko's Netty 4 transport.
kerr
2024/12/28
[jira] [Created] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode.
hiliuxg (Jira)
2024/12/28
[jira] [Created] (FLINK-36977) paimon apply default value options when apply add column_schema change
hiliuxg (Jira)
2024/12/28
[jira] [Created] (FLINK-36976) Bump jackson to 2.18.2
Sergey Nuyanzin (Jira)
2024/12/27
[jira] [Created] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions
Mohsen Rezaei (Jira)
2024/12/27
[jira] [Created] (FLINK-36974) support overwrite flink config by command line
hiliuxg (Jira)
2024/12/27
[jira] [Created] (FLINK-36973) udf dateformat support LocalZonedTimestampData
hiliuxg (Jira)
2024/12/27
申请退订邮件
樊跃翔
2024/12/27
[jira] [Created] (FLINK-36972) Unify AWS sink implementation
Ahmed Hamdy (Jira)
2024/12/27
[jira] [Created] (FLINK-36971) Add Sqs Sink SQL connector
Ahmed Hamdy (Jira)
2024/12/27
[jira] [Created] (FLINK-36969) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING
Xiao Huang (Jira)
2024/12/27
[jira] [Created] (FLINK-36970) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING
Xiao Huang (Jira)
2024/12/26
[jira] [Created] (FLINK-36968) The "values" lookup table used for testing does not deduplicate data with the same key.
xuyang (Jira)
2024/12/26
[Discuss] Kafka Enumerator assigns splits based on the current assignment situation.
Hongshun Wang
2024/12/26
[jira] [Created] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0
Jeff Yang (Jira)
2024/12/26
Re: Resolving Flink Backpressure
Samrat Deb
2024/12/26
[jira] [Created] (FLINK-36966) Bump mockito to 5.x
Sergey Nuyanzin (Jira)
2024/12/25
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
2024/12/25
[jira] [Created] (FLINK-36965) Enable to allow re-create the pod watch with many retries on k8s cluster failure
Yun Tang (Jira)
2024/12/25
[jira] [Created] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink.
Yanquan Lv (Jira)
2024/12/25
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/25
[jira] [Created] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey`
Zakelly Lan (Jira)
2024/12/25
[jira] [Created] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake
Shuai Xu (Jira)
2024/12/25
[jira] [Created] (FLINK-36961) Wait ForSt state excutor shutdown when disposing
Yanfei Lei (Jira)
2024/12/24
[RESULT][VOTE] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/24
[Discuss] FLIP-485: Flink UDF metrics
Linda Li
2024/12/24
[jira] [Created] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2
xuhuang (Jira)
2024/12/24
[jira] [Created] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails.
Junrui Lee (Jira)
2024/12/24
[jira] [Created] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options
MOBIN (Jira)
2024/12/23
Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Feng Jin
2024/12/23
[jira] [Created] (FLINK-36957) Implement async StreamFlatMap
Yanfei Lei (Jira)
2024/12/23
Re: Resolving Flink Backpressure
Mohammad Aamir Iqubal
2024/12/23
[jira] [Created] (FLINK-36956) Pipeline transform should deduce PK column types to be NOT NULL
yux (Jira)
2024/12/23
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Venkatakrishnan Sowrirajan
2024/12/23
[jira] [Created] (FLINK-36955) Migrate RewriteIntersectAllRule
Jacky Lau (Jira)
2024/12/23
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Shengkai Fang
2024/12/23
Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Yuepeng Pan
2024/12/23
Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Ron Liu
2024/12/23
[jira] [Created] (FLINK-36954) Migrate CalcRankTransposeRule
Jacky Lau (Jira)
2024/12/23
[jira] [Created] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang (Jira)
2024/12/23
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/23
[jira] [Created] (FLINK-36952) fix mongodb chinese doc
Thorne (Jira)
2024/12/22
[jira] [Created] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule
Jacky Lau (Jira)
2024/12/22
[DISCUSS] Early Fire Support for Flink SQL Interval Join
Weiqing Yang
2024/12/22
[jira] [Created] (FLINK-36950) Migrate WindowPropertiesRules
Jacky Lau (Jira)
2024/12/22
[jira] [Created] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth
Zakelly Lan (Jira)
2024/12/22
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Shengkai Fang
2024/12/22
Re: [VOTE] FLIP-467: Introduce Generalized Watermarks
Yunfeng Zhou
2024/12/22
[jira] [Created] (FLINK-36948) Drop deprecated FlinkMatchers
Sergey Nuyanzin (Jira)
2024/12/21
Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status
gyula . fora
2024/12/21
Re: Slack Invite
Yun Tang
2024/12/20
Slack Invite
Fadojutimi, Bowofola (Toye)
2024/12/20
Flink technical debt. Chi meeting
David Radley
2024/12/20
RE: [VOTE] FLIP-493: Add K8S conditions to CRD's Status
David Radley
2024/12/20
Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status
gyula . fora
2024/12/20
[VOTE] FLIP-493: Add K8S conditions to CRD's Status
Lajith Koova
2024/12/20
[jira] [Created] (FLINK-36947) Rate limiting the GetRecord call frequency
Burak Ozakinci (Jira)
2024/12/20
[jira] [Created] (FLINK-36946) optimize sink operator name truncate
tartarus (Jira)
2024/12/20
[VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
2024/12/20
[jira] [Created] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job
Yohei Yoshimuta (Jira)
2024/12/20
[jira] [Created] (FLINK-36944) Introduce 'enableAsycState' in DataStream v1 interfaces
Zakelly Lan (Jira)
2024/12/20
Re: [VOTE] FLIP-467: Introduce Generalized Watermarks
weijie guo
2024/12/20
Re: [VOTE] FLIP-467: Introduce Generalized Watermarks
Junrui Lee
2024/12/20
Re: [VOTE] FLIP-467: Introduce Generalized Watermarks
Xintong Song
2024/12/20
[jira] [Created] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan (Jira)
2024/12/20
[RESULT][VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
2024/12/20
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
2024/12/20
[jira] [Created] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimestamportOperator
Wang Qilong (Jira)
2024/12/20
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
2024/12/19
[VOTE] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/19
[jira] [Created] (FLINK-36941) Fix Doc for DATE_FORMAT
Yiyu Tian (Jira)
2024/12/19
[jira] [Created] (FLINK-36940) Why does autoscaler Math.round the TargetProcessingCapacity
Rui Fan (Jira)
2024/12/19
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
2024/12/19
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
2024/12/19
Re: Blue/Green Deployments support for Flink
Alex Nitavsky
2024/12/19
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Mate Czagany
2024/12/19
[jira] [Created] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer
Keith Lee (Jira)
2024/12/19
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Lincoln Lee
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Yanquan Lv
2024/12/19
Re: Java truststores
Gabor Somogyi
2024/12/19
RE: Java truststores
Nic Townsend
2024/12/19
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Timo Walther
2024/12/19
Re: Java truststores
Gabor Somogyi
2024/12/19
Java truststores
Nic Townsend
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Zakelly Lan
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/19
[jira] [Created] (FLINK-36938) Provide hooks before and after the watermark processing
Zakelly Lan (Jira)
2024/12/19
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yuan Mei
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Zakelly Lan
2024/12/19
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/19
[jira] [Created] (FLINK-36937) Integrate PTF TypeInference into Table API
Timo Walther (Jira)
2024/12/19
[jira] [Created] (FLINK-36936) Introduce UpdatableTopNFunction in Rank with Async State API
Wang Qilong (Jira)
2024/12/19
[jira] [Created] (FLINK-36935) Implement fast link for ForStFileSystem
Yanfei Lei (Jira)
2024/12/18
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Lajith Koova
2024/12/18
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/18
[jira] [Created] (FLINK-36933) Error using QUALIFY in rank
Wang Qilong (Jira)
2024/12/18
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Yunfeng Zhou
2024/12/18
Re: Resolving Flink Backpressure
Samrat Deb
2024/12/18
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Hangxiang Yu
2024/12/18
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/18
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Zakelly Lan
2024/12/18
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xintong Song
2024/12/18
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Ron Liu
2024/12/18
[jira] [Created] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator
Philippe Gref-Viau (Jira)
2024/12/18
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Mate Czagany
2024/12/18
[jira] [Created] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode
Wenkai Qi (Jira)
2024/12/18
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/18
[jira] [Created] (FLINK-36930) Lookup join with JDBC connector fails when join condition does not include fields from the probe/left table
Lilo (Jira)
2024/12/18
Re: [DISCUSS] FLIP-496: SQL connector for keyed state data
Zakelly Lan
2024/12/18
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Yunfeng Zhou
2024/12/18
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Gabor Somogyi
2024/12/18
Resolving Flink Backpressure
Mohammad Aamir Iqubal
2024/12/18
[DISCUSS] FLIP-496: SQL connector for keyed state data
Gabor Somogyi
2024/12/18
[DISCUSS] Flink 1.18.2 release & grace period for EOL versions
Matthias Pohl
2024/12/18
[jira] [Created] (FLINK-36929) SQL connector for keyed state data
Gabor Somogyi (Jira)
2024/12/18
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yunfeng Zhou
2024/12/18
Re: CHI: Automatic Stale PR Cleanup
Matthias Pohl
2024/12/18
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
2024/12/18
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Matthias Pohl
2024/12/18
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
2024/12/17
[jira] [Created] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)
Zakelly Lan (Jira)
2024/12/17
[jira] [Created] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API
xuyang (Jira)
2024/12/17
[jira] [Created] (FLINK-36926) Introduce Window Join Operator with Async State API
xuyang (Jira)
2024/12/17
[jira] [Created] (FLINK-36925) Introduce SemiAntiJoinOperator in Join with Async State API
Wang Qilong (Jira)
2024/12/17
[jira] [Created] (FLINK-36924) cannot initialize module JavadocMethod - Property 'allowUndeclaredRTE' does not exist, please check the documentation
luoyuxia (Jira)
2024/12/17
[jira] [Created] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19
Yanquan Lv (Jira)
2024/12/17
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Ron Liu
2024/12/17
[DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Michas Szacillo (BLOOMBERG/ 919 3RD A)
2024/12/17
[jira] [Created] (FLINK-36922) Add warning when creating KryoSerializer for generic type
LEONID ILYEVSKY (Jira)
2024/12/17
[DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
2024/12/17
Re: CHI: Automatic Stale PR Cleanup
Gyula Fóra
2024/12/17
Re: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
2024/12/17
Re: CHI: Automatic Stale PR Cleanup
Jim Hughes
2024/12/17
CHI: Automatic Stale PR Cleanup
Tom Cooper
2024/12/17
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
2024/12/17
[DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
2024/12/17
[jira] [Created] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails
Robert Metzger (Jira)
2024/12/17
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Alexander Fedulov
2024/12/17
Re: Blue/Green Deployments support for Flink
Alexander Fedulov
2024/12/17
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Matthias Pohl
2024/12/17
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Alexander Fedulov
2024/12/17
Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
2024/12/17
Re: [DISCUSS] Flink 1.20.1 release
Ammu P
2024/12/17
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
2024/12/17
[RESULT][VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
2024/12/17
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Leonard Xu
2024/12/17
FW: FW: Re: Flink technical debt. Chi meeting
David Radley
2024/12/17
[jira] [Created] (FLINK-36920) Update org.quartz-schedule:quartz
Anupam Aggarwal (Jira)
2024/12/17
[jira] [Created] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin (Jira)
2024/12/16
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
2024/12/16
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
2024/12/16
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
2024/12/16
[jira] [Created] (FLINK-36918) Introduce ProcTimeSortOperator in TemporalSort with Async State API
Wang Qilong (Jira)
2024/12/16
[jira] [Created] (FLINK-36917) Add OceanBase DataSource to Flink CDC
ChaomingZhang (Jira)
2024/12/16
[jira] [Created] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW
Yiyu Tian (Jira)
2024/12/16
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yanfei Lei
2024/12/16
[jira] [Created] (FLINK-36915) flink-oracle-cdc supports user-defined conditions or time updates
twan1588 (Jira)
2024/12/16
[jira] [Created] (FLINK-36914) Sources with watermark alignment should wait for watermark generation
Xingcan Cui (Jira)
2024/12/16
[VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
2024/12/16
Full Checkpoint information in UI and API
Ryan van Huuksloot
2024/12/16
[jira] [Created] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name.
Yanquan Lv (Jira)
2024/12/16
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
2024/12/16
RE: Re: Plans for JDBC connector for 1.20?
Jérôme Gagnon
2024/12/16
RE: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
2024/12/16
[jira] [Created] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP
Weijie Guo (Jira)
2024/12/16
[jira] [Created] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade
Jacky Lau (Jira)
2024/12/16
[jira] [Created] (FLINK-36910) Support calling time-related dynamic functions with parenthesis
Gustavo de Morais (Jira)
2024/12/16
[jira] [Created] (FLINK-36909) Reduce Stream Creation in StreamPatternSubscriber
xiaochen.zhou (Jira)
2024/12/16
Log4j JSONTemplateLayout
Ryan van Huuksloot
2024/12/16
Re: Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
2024/12/16
Re: Operator IPv6 support
Gyula Fóra
2024/12/16
Re: Operator IPv6 support
Attila Kreiner
2024/12/16
Re: Operator IPv6 support
Gyula Fóra
2024/12/16
Operator IPv6 support
Attila Kreiner
2024/12/16
[RESULT][VOTE] FLIP-484: Add custom metric variables to operators
Piotr Nowojski
2024/12/16
Re: [VOTE] FLIP-484: Add custom metric variables to operators
Piotr Nowojski
2024/12/16
[RESULT][VOTE] FLIP-483: Add support for children Spans
Piotr Nowojski
2024/12/16
Re: [VOTE] FLIP-483: Add support for children Spans
Piotr Nowojski
2024/12/16
[RESULT][VOTE] FLIP-482: Add OpenTelemetryEventReporter
Piotr Nowojski
Earlier messages
Later messages