dev  

Messages by Thread

• • Re: [VOTE]FLIP-480: Support to deploy script in application mode Ron Liu
  • Re:Re: [VOTE]FLIP-480: Support to deploy script in application mode Xuyang
  • Re:Re: [VOTE]FLIP-480: Support to deploy script in application mode Ferenc Csaky
  • Re: Re: [VOTE]FLIP-480: Support to deploy script in application mode Zhu Zhu
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode shuai xu
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Yuepeng Pan
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Shengkai Fang
• [jira] [Created] (FLINK-36674) Flink will not commit if checkpointing is not enabled slankka (Jira)
• [DISCUSS] Feature Freeze for Flink 2.0 - Jan 13 Xintong Song
• [jira] [Created] (FLINK-36673) Operator is not properly handling failed deployments without savepoints Yaroslav Tkachenko (Jira)
• [DISCUSS] FLIP-481: Introduce Event Reporting Piotr Nowojski
  • Re: [DISCUSS] FLIP-481: Introduce Event Reporting Roman Khachatryan
  • Re: [DISCUSS] FLIP-481: Introduce Event Reporting Piotr Nowojski
  • Re: [DISCUSS] FLIP-481: Introduce Event Reporting Roman Khachatryan
  • Re: [DISCUSS] FLIP-481: Introduce Event Reporting Piotr Nowojski
• [jira] [Created] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN Hong Liang Teoh (Jira)
• Flink V1 to V2 state migration David Radley
  • Re: Flink V1 to V2 state migration Galen Warren
  • Re: Flink V1 to V2 state migration Zakelly Lan
  • Re: Flink V1 to V2 state migration Alexis Sarda-Espinosa
  • Re: Flink V1 to V2 state migration Zakelly Lan
  • RE: Flink V1 to V2 state migration David Radley
  • Re: Flink V1 to V2 state migration Gabor Somogyi
  • RE: Flink V1 to V2 state migration David Radley
  • Re: Flink V1 to V2 state migration Xu Huang
  • RE: Flink V1 to V2 state migration David Radley
• [jira] [Created] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. Hong Liang Teoh (Jira)
• FLIP-484: Add custom metric variables to operators Piotr Nowojski
  • [DISCUSS] FLIP-484: Add custom metric variables to operators Piotr Nowojski
  • Re: FLIP-484: Add custom metric variables to operators Roman Khachatryan
  • Re: FLIP-484: Add custom metric variables to operators Hongshun Wang
  • Re: FLIP-484: Add custom metric variables to operators Piotr Nowojski
  • Re: FLIP-484: Add custom metric variables to operators Piotr Nowojski
• [DISCUSS] FLIP-482: Add OpenTelemetryEventReporter Piotr Nowojski
  • Re: [DISCUSS] FLIP-482: Add OpenTelemetryEventReporter Roman Khachatryan
  • Re: [DISCUSS] FLIP-482: Add OpenTelemetryEventReporter Piotr Nowojski
• [DISCUSS] FLIP-483: Add support for children Spans Piotr Nowojski
  • Re: [DISCUSS] FLIP-483: Add support for children Spans Roman Khachatryan
  • Re: [DISCUSS] FLIP-483: Add support for children Spans Piotr Nowojski
  • Re: [DISCUSS] FLIP-483: Add support for children Spans Roman Khachatryan
  • Re: [DISCUSS] FLIP-483: Add support for children Spans Piotr Nowojski
• [jira] [Created] (FLINK-36670) Optimize port range out-of-bounds exception log Gianzie (Jira)
• [jira] [Created] (FLINK-36669) The flink version of ES should use parent's pom Gianzie (Jira)
• [jira] [Created] (FLINK-36668) Release flink-connector-aws v5.0.0 Hong Liang Teoh (Jira)
• [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 Danny Cranmer
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 weijie guo
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 Xintong Song
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 Ahmed Hamdy
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 Hong Liang
• RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Ferenc Csaky
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
• [jira] [Created] (FLINK-36667) Remove `proto` schema definitions from source Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. kaitian (Jira)
• [jira] [Created] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. Hong Liang Teoh (Jira)
• [DISCUSS] Changing return type of window properties (WINDOW_START/END) Dawid Wysakowicz
  • Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END) Timo Walther
  • Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END) Leonard Xu
  • Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END) Dawid Wysakowicz
  • Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END) Leonard Xu
• [jira] [Created] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36664) [Window]The window with window_offset will lose data. kaitian (Jira)
• [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? Gyula Fóra
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? yuanfeng hu
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Rui Fan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Matthias Pohl
  • 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? 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? Rui Fan
  • 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? 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? Yuepeng Pan
  • 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
• Planned release dates for 1.19.2 and 1.20.1 Prasanna kumar
  • Re: Planned release dates for 1.19.2 and 1.20.1 Prasanna kumar
  • Re: Planned release dates for 1.19.2 and 1.20.1 Robert Metzger
• Flink Kubernetes operator santhosh venkat
  • Re: Flink Kubernetes operator Gyula Fóra
• [jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL lincoln lee (Jira)
• [ANNOUNCE] New Apache Flink Committer - Junrui Li Zhu Zhu
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Lijie Wang
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Biao Geng
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Zhanghao Chen
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Lincoln Lee
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Shengkai Fang
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Guowei Ma
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Rui Fan
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Feng Jin
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Zakelly Lan
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Xia Sun
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Yuepeng Pan
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Xuyang
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Yu Chen
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Jing Ge
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Luke Chen
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Ahmed Hamdy
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Hong Liang
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li weijie guo
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Maximilian Michels
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li wenjin
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Ron Liu
  • Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li Junrui Lee
• [jira] [Created] (FLINK-36661) the managed memory setting is relatively small, resulting in duplicate processing results for batch tasks Jira
• [jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0 LvYanquan (Jira)
• [jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0 LvYanquan (Jira)
• [jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0 LvYanquan (Jira)
• [DISCUSS] AdaptiveScheduler slots assignment strategy optimization Yuepeng Pan
  • Re: [DISCUSS] AdaptiveScheduler slots assignment strategy optimization Yuepeng Pan
• Re: Kafka connector releases Yanquan Lv
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Leonard Xu
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Yanquan Lv
  • Re: Kafka connector releases Arvid Heise
• [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 weijie guo
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Xintong Song
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Lorenzo Nicora
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Danny Cranmer
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Yanquan Lv
• [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 weijie guo
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Xintong Song
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Danny Cranmer
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Danny Cranmer
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
• [jira] [Created] (FLINK-36657) Release Flink 1.20 Matyas Orhidi (Jira)
• Flink technical debt. David Radley
  • Re: Flink technical debt. Robert Metzger
  • RE: Flink technical debt. David Radley
  • RE: Flink technical debt. Nic Townsend
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Jim Hughes
  • FW: Re: Flink technical debt. David Radley
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Robert Metzger
  • RE: Flink technical debt. David Radley
  • FW: RE: Flink technical debt. David Radley
  • Re: FW: RE: Flink technical debt. Jim Hughes
  • RE: FW: RE: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. David Radley
  • Re: FW: Re: Flink technical debt. Sergey Nuyanzin
  • RE: FW: Re: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. Chi meeting David Radley
  • FW: FW: Re: Flink technical debt. Chi meeting David Radley
  • Flink technical debt. Chi meeting David Radley
  • Re: Flink technical debt. Tom Cooper
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Jim Hughes
  • Re: Flink technical debt. Ferenc Csaky
  • Re: Flink technical debt. Shalini
  • Re: Flink technical debt. Lajith Koova
  • Re: Flink technical debt. Lyrics Cool
  • Re: Flink technical debt. Hong Liang
  • RE: Flink technical debt. Sebastien Pereira
  • RE: Re: Flink technical debt. Ammu P
• [jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error Leonard Xu (Jira)
• [jira] [Created] (FLINK-36655) using flink state processor api to process big state in rocksdb is very slow guanghua pi (Jira)
• [jira] [Created] (FLINK-36654) Decimal divide Integer reports Null pointer exception Shuai Xu (Jira)
• [jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-36652) Upgrade Apache ORC to 1.9.4 Yuchi Duan (Jira)
• [jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists Jerome Gagnon (Jira)
• [jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed Di Wu (Jira)
• [jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector LvYanquan (Jira)
• [jira] [Created] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform Wenkai Qi (Jira)
• [jira] [Created] (FLINK-36646) Support Java 17+ job images more conveniently in the operator Rob Young (Jira)
• [jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability Thomas Cooper (Jira)
• [jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36642) Table API expressions with several built-in functions are not correctly serialized to SQL Fabian Hueske (Jira)
• JSON-Path CVEs Tom Cooper
  • Re: JSON-Path CVEs Sergey Nuyanzin
• [jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20 LvYanquan (Jira)
• [jira] [Created] (FLINK-36640) Provide an easy way to reset autoscaling Matyas Orhidi (Jira)
• [jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36638) Remove legacy bounded blocking shuffle Weijie Guo (Jira)
• [jira] [Created] (FLINK-36637) Fix ListShards for Kinesis streams with large number of shards Elphas Toringepi (Jira)
• [jira] [Created] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform Wenkai Qi (Jira)
• *TemporarySystemFunction API without ignoreIfExists option Venkatakrishnan Sowrirajan
• [jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed Yi Zhang (Jira)
• [jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime xingbe (Jira)

• Earlier messages
• Later messages