dev  

Messages by Date

• 2024/10/29 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ron Liu
• 2024/10/29 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ron Liu
• 2024/10/29 [DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats Yubin Li
• 2024/10/29 [jira] [Created] (FLINK-36627) Failure to process a CSV file in Flink due to a character encoding mismatch: the file is in ISO-8859 and the application expects UTF-8. Hector Miuler Malpica Gallegos (Jira)
• 2024/10/29 kafka-connector random WakeupException after enabling watermark alignment Alberto Lago
• 2024/10/29 Micro batching with flink Anil Dasari
• 2024/10/29 [jira] [Created] (FLINK-36626) Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+ Eduardo Breijo (Jira)
• 2024/10/29 [jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors Zhenqiu Huang (Jira)
• 2024/10/29 [ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released Őrhidi Mátyás
• 2024/10/29 [jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator Piotr Nowojski (Jira)
• 2024/10/29 Re: [DISCUSS] Release HBase connector with partial JDK support Márton Balassi
• 2024/10/29 Re: [DISCUSS] Elasticsearch v3.1 release Ahmed Hamdy
• 2024/10/29 [jira] [Created] (FLINK-36623) Improve logging in DefaultStateTransitionManager Roman Khachatryan (Jira)
• 2024/10/29 [jira] [Created] (FLINK-36622) Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs. Han Yin (Jira)
• 2024/10/29 [jira] [Created] (FLINK-36621) Build failure: StatefulSink not found Piotr Nowojski (Jira)
• 2024/10/29 [jira] [Created] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats zjjiang (Jira)
• 2024/10/29 [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set 李阳
• 2024/10/28 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
• 2024/10/28 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
• 2024/10/28 [jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added linqigeng (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC Hongshun Wang (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36617) Migrate kryo package Siddharth R (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig Jira
• 2024/10/28 Re: [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
• 2024/10/28 [jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API Dawid Wysakowicz (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase Youle (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP Sergey Nuyanzin (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok Hong Liang Teoh (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink LvYanquan (Jira)
• 2024/10/28 [jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes yux (Jira)
• 2024/10/28 Re: [DISCUSS] FlinkCDC bump version to Flink 1.19 Hang Ruan
• 2024/10/28 Re: [DISCUSS] FlinkCDC bump version to Flink 1.19 Leonard Xu
• 2024/10/27 [jira] [Created] (FLINK-36609) Protobuf Format not support proto3 Hongshun Wang (Jira)
• 2024/10/27 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Hongshun Wang
• 2024/10/27 [jira] [Created] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator xingbe (Jira)
• 2024/10/27 [jira] [Created] (FLINK-36607) Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join xingbe (Jira)
• 2024/10/27 [jira] [Created] (FLINK-36606) TimestampITCase generates test artifacts outside of tmp folder Sergey Nuyanzin (Jira)
• 2024/10/26 Re: Slack access Shengbo
• 2024/10/26 [jira] [Created] (FLINK-36605) Upgrade Debezium version to 2.7.x Anil Dasari (Jira)
• 2024/10/25 [jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Mingliang Liu (Jira)
• 2024/10/25 [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Őrhidi Mátyás
• 2024/10/25 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Maximilian Michels
• 2024/10/25 [jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API Lorenzo Nicora (Jira)
• 2024/10/25 [jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0 Thomas Cooper (Jira)
• 2024/10/25 Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Feng Jin
• 2024/10/25 Re: [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules Shiwei Wang
• 2024/10/25 Re: Consequences of removing per-job mode in Flink 2.0 Ferenc Csaky
• 2024/10/25 Re: Consequences of removing per-job mode in Flink 2.0 weijie guo
• 2024/10/25 Re: Consequences of removing per-job mode in Flink 2.0 Shengkai Fang
• 2024/10/24 [jira] [Created] (FLINK-36601) Add JobID property to FlinkResultSet Yi Cai (Jira)
• 2024/10/24 [jira] [Created] (FLINK-36600) Implement java.sql.Wrapper interface. Yi Cai (Jira)
• 2024/10/24 [jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group Alan Zhang (Jira)
• 2024/10/24 [jira] [Created] (FLINK-36598) [state/forst] Refactor initialization of ForSt db core Zakelly Lan (Jira)
• 2024/10/24 [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
• 2024/10/24 [jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output MOBIN (Jira)
• 2024/10/24 [jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified yux (Jira)
• 2024/10/24 Re: [ANNOUNCE] Apache Flink 2.0 Preview released weijie guo
• 2024/10/23 Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
• 2024/10/23 RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng
• 2024/10/23 [jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20 Aleksandr Pilipenko (Jira)
• 2024/10/23 https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng
• 2024/10/23 Re: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
• 2024/10/23 Re: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
• 2024/10/23 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Márton Balassi
• 2024/10/23 Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
• 2024/10/23 [jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back slankka (Jira)
• 2024/10/23 Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Konstantin Knauf
• 2024/10/23 Re: [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
• 2024/10/23 [jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE Thomas Cooper (Jira)
• 2024/10/23 [ANNOUNCE] Apache Flink 2.0 Preview released Xintong Song
• 2024/10/23 [jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend Yanfei Lei (Jira)
• 2024/10/23 [jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases Martijn Visser (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x yux (Jira)
• 2024/10/22 Re: [DISCUSS] Flink external connector bump version Yanquan Lv
• 2024/10/22 [jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend Zakelly Lan (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml ouyangwulin (Jira)
• 2024/10/22 Re: [DISCUSS] Release HBase connector with partial JDK support Yanquan Lv
• 2024/10/22 Re: [DISCUSS] Release HBase connector with partial JDK support Yanquan Lv
• 2024/10/22 [jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class Anil Dasari (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+ ZhengYu Chen (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. Jiangjie Qin (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots Anil Dasari (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics Matyas Orhidi (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36582) sql client hang when querying a parquet table Lu Niu (Jira)
• 2024/10/22 Re: [DISCUSS] Release HBase connector with partial JDK support Márton Balassi
• 2024/10/22 [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
• 2024/10/22 [jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters LvYanquan (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure MOBIN (Jira)
• 2024/10/22 [jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare. LIU (Jira)
• 2024/10/21 [RESULT][VOTE] FLIP-478: Introduce Config Option Scope Junrui Lee
• 2024/10/21 [jira] [Created] (FLINK-36578) Fixed bug when converting json to string Lee SeungMin (Jira)
• 2024/10/21 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Mate Czagany
• 2024/10/21 Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Dawid Wysakowicz
• 2024/10/21 [jira] [Created] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD Mate Czagany (Jira)
• 2024/10/21 Re: Request to work on FLINK-33926 Gantigmaa Selenge
• 2024/10/21 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Yuepeng Pan
• 2024/10/21 [jira] [Created] (FLINK-36576) Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider Lei Yang (Jira)
• 2024/10/21 [jira] [Created] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups Lei Yang (Jira)
• 2024/10/20 Re: Fwd: Custom Windowing Strategies in SQL Timo Walther
• 2024/10/20 Re: [DISCUSS] Flink external connector bump version Hang Ruan
• 2024/10/20 [RESULT][VOTE] Release 2.0-preview1, release candidate #1 Xintong Song
• 2024/10/20 Re: [VOTE] Release 2.0-preview1, release candidate #1 Xintong Song
• 2024/10/20 [jira] [Created] (FLINK-36574) The file STDOUT is not available on the TaskExecutor fangmin.yang (Jira)
• 2024/10/20 [jira] [Created] (FLINK-36573) Add table information of binlog offsets when checkpointing Runkang He (Jira)
• 2024/10/19 [jira] [Created] (FLINK-36572) The local time zone is wrongly set in StarRocks pipeline sink Runkang He (Jira)
• 2024/10/18 [jira] [Created] (FLINK-36571) Flink dashboard does not show Busy / Backpressure Hong Liang Teoh (Jira)
• 2024/10/18 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Tom Cooper
• 2024/10/18 Re: Major performance degradation in case of list operator state restore from S3 Gabor Somogyi
• 2024/10/18 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Rui Fan
• 2024/10/18 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Gabor Somogyi
• 2024/10/18 [jira] [Created] (FLINK-36570) Fatal error occurred in the cluster entrypoint zyh (Jira)
• 2024/10/18 [jira] [Created] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success Jake.zhang (Jira)
• 2024/10/18 [jira] [Created] (FLINK-36568) IllegalStateException Causes Collect Sink to Fail to Collect Result Junrui Li (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36567) Planner module didn't use the setting from flink-conf.yaml liting liu (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator LvYanquan (Jira)
• 2024/10/17 Re: [VOTE] Release 2.0-preview1, release candidate #1 Xingbo Huang
• 2024/10/17 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Sam Barker
• 2024/10/17 [jira] [Created] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions yux (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36564) Running CI in random timezone to expose more time related bugs LvYanquan (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36563) Running CI in random timezone to expose more time related bugs LvYanquan (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36562) Running CI in random timezone to expose more time related bugs LvYanquan (Jira)
• 2024/10/17 [jira] [Created] (FLINK-36561) ResultSet.wasNull() does not reflect null values in Flink JDBC Driver Ilya Soin (Jira)
• 2024/10/17 [ANNOUNCE] Apache flink-connector-kafka 3.3.0 released Arvid Heise
• 2024/10/17 [jira] [Created] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon LvYanquan (Jira)
• 2024/10/17 [RESULT][VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Zakelly Lan
• 2024/10/17 Re: [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Zakelly Lan
• 2024/10/17 Re: [VOTE] Release 2.0-preview1, release candidate #1 Zakelly Lan
• 2024/10/17 [jira] [Created] (FLINK-36559) [docs]Add elasticsearch sink to docs JunboWang (Jira)
• 2024/10/17 Re: [VOTE] Release 2.0-preview1, release candidate #1 Jark Wu
• 2024/10/16 Re: [DISCUSS] FlinkCDC bump version to Flink 1.19 ConradJam
• 2024/10/16 Re: [VOTE] FLIP-478: Introduce Config Option Scope Zhu Zhu
• 2024/10/16 Re: [VOTE] Release 2.0-preview1, release candidate #1 Jingsong Li
• 2024/10/16 Re: [VOTE] Release 2.0-preview1, release candidate #1 Yanquan Lv
• 2024/10/16 Re: [VOTE] Release 2.0-preview1, release candidate #1 Yunfeng Zhou
• 2024/10/16 Re: [VOTE] FLIP-478: Introduce Config Option Scope Shengkai Fang
• 2024/10/16 Re: [VOTE] FLIP-478: Introduce Config Option Scope Rui Fan
• 2024/10/16 [VOTE] FLIP-478: Introduce Config Option Scope Junrui Lee
• 2024/10/16 [DISCUSS] FlinkCDC bump version to Flink 1.19 Yanquan Lv
• 2024/10/16 Re: [VOTE] Release 2.0-preview1, release candidate #1 Rui Fan
• 2024/10/16 [DISCUSS] FlinkCDC bump version to Flink 1.19 Yanquan Lv
• 2024/10/16 [jira] [Created] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 yux (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator Sai Sharath Dandi (Jira)
• 2024/10/16 Re: [VOTE] Release 2.0-preview1, release candidate #1 Yuan Mei
• 2024/10/16 [jira] [Created] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating Piotr Nowojski (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha Piotr Nowojski (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36554) Support MapState in Operator State Jacob Jona Fahlenkamp (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36553) Local Global aggregation in Datasream API Jacob Jona Fahlenkamp (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36552) Fix Table API OVER window support in batch mode Dawid Wysakowicz (Jira)
• 2024/10/16 [jira] [Created] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore" Keith Wall (Jira)
• 2024/10/16 [RESULT][VOTE] flink-connector-kafka 3.3.0, release candidate #1 Arvid Heise
• 2024/10/16 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
• 2024/10/16 Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Junrui Lee
• 2024/10/16 [jira] [Created] (FLINK-36550) Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader Jira
• 2024/10/15 Re: [VOTE] Release 2.0-preview1, release candidate #1 Zhu Zhu
• 2024/10/15 [jira] [Created] (FLINK-36548) ChangelogDelegateEmbeddedRocksDBStateBackendTest crashed due to exit code: 134 Weijie Guo (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. jiangyu (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36547) Add option to retain `RowKind` sematics after serialization/deserialization Yubin Li (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36546) Handle batch sources in DataSinkTranslator Sergei Morozov (Jira)
• 2024/10/15 Re: [VOTE] Release 2.0-preview1, release candidate #1 Lincoln Lee
• 2024/10/15 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Leonard Xu
• 2024/10/15 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Rui Fan
• 2024/10/15 Re: [VOTE] Release 2.0-preview1, release candidate #1 weijie guo
• 2024/10/15 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Matthias Pohl
• 2024/10/15 [jira] [Created] (FLINK-36545) generate-olm-bundle.sh switches uid/gid when runner OLM tool image Keith Wall (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36544) Failing to generate OLM bundle (open manifests/flink-kubernetes-operator.clusterserviceversion.yaml: permission denied) Keith Wall (Jira)
• 2024/10/15 [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Őrhidi Mátyás
• 2024/10/15 [jira] [Created] (FLINK-36543) Table API over windows cannot be string serialized Dawid Wysakowicz (Jira)
• 2024/10/15 Major performance degradation in case of list operator state restore from S3 Gabor Somogyi
• 2024/10/15 [jira] [Created] (FLINK-36542) Speed up the spotless apply Wenjun Ruan (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36541) Occasional met commit conflict problem in PaimonSink. LvYanquan (Jira)
• 2024/10/15 Re: [VOTE] Release 2.0-preview1, release candidate #1 Junrui Lee
• 2024/10/15 [jira] [Created] (FLINK-36540) Add Support for Hadoop Caller Context when using Flink on yarn liang yu (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36539) Add Support for Hadoop Caller Context when using Flink on yarn liang yu (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36538) Bump commons-codec from 1.15 to 1.17.1 Siddharth R (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36537) Bump snappy-java from 1.1.10.4 to 1.1.10.7 Siddharth R (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36536) Bump commons-text from 1.10.0 to 1.12.0 Siddharth R (Jira)
• 2024/10/15 [jira] [Created] (FLINK-36535) Optimize the scale down logic based on historical parallelism Rui Fan (Jira)
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Leonard Xu
• 2024/10/14 [DISCUSS] Flink external connector bump version Yanquan Lv
• 2024/10/14 [jira] [Created] (FLINK-36534) Upgrade Flink Kubernetes operator to flink-1.20 Shailesh Gupta (Jira)
• 2024/10/14 [jira] [Created] (FLINK-36533) An exception occurs when using the taskmanager.data.bind-port five (Jira)
• 2024/10/14 [DISCUSS] FLINK-36510/PR 25494 Upgrade Pekko from 1.0.1 to 1.1.2 Grace Grimwood
• 2024/10/14 [jira] [Created] (FLINK-36532) Kafka group offsets are not committed on stop with savepoint LEONID ILYEVSKY (Jira)
• 2024/10/14 [jira] [Created] (FLINK-36531) AutoScaler needs to consider the lag from last checkpoint Sai Sharath Dandi (Jira)
• 2024/10/14 Re: [DISCUSS] Elasticsearch v3.1 release Danny Cranmer
• 2024/10/14 Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
• 2024/10/14 [jira] [Created] (FLINK-36530) Not able to restore list state from S3 Gabor Somogyi (Jira)
• 2024/10/14 [jira] [Created] (FLINK-36529) Support greater or equals logic for operator flink version default configs Gyula Fora (Jira)
• 2024/10/14 [jira] [Created] (FLINK-36528) Update org.apache.avro : avro dependency Kartik Goyal (Jira)
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Ahmed Hamdy
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Danny Cranmer
• 2024/10/14 Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
• 2024/10/14 [DISCUSS] Elasticsearch v3.1 release Ahmed Hamdy
• 2024/10/14 [jira] [Created] (FLINK-36527) Introduce a parameter to support the autoscaler to adopt a more aggressive strategy when Source or upstream shuffle is keyBy yuanfenghu (Jira)
• 2024/10/14 [jira] [Created] (FLINK-36526) Optimize the overhead of writing with direct buffer in ForSt Zakelly Lan (Jira)
• 2024/10/14 Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
• 2024/10/13 [jira] [Created] (FLINK-36525) Support for AI Model Integration for Data Processing wuzexian (Jira)
• 2024/10/13 [jira] [Created] (FLINK-36524) upgrade paimon 0.9.0 melin (Jira)

• Earlier messages
• Later messages