Messages by Thread
-
[jira] [Created] (FLINK-37825) Standard YAML convert and dump failed
melin (Jira)
-
[jira] [Created] (FLINK-37824) Paimon connector lost column comment in CreateTableEvent
linqigeng (Jira)
-
[jira] [Created] (FLINK-37823) Add Python 3.12 support
Mika Naylor (Jira)
-
[SUMMARY] Flink 2.1 Release Sync 05/21/2025
Ron Liu
-
[jira] [Created] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci
dalongliu (Jira)
-
[DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project
Xintong Song
-
[jira] [Created] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci
dalongliu (Jira)
-
[jira] [Created] (FLINK-37820) AsyncScalarFunction UDFs cannot be loaded via CompiledPlan
Ferenc Csaky (Jira)
-
[VOTE] FLIP-530: Dynamic job configuration
Roman Khachatryan
-
[jira] [Created] (FLINK-37819) Add column expansion test for model TVF
Hao Li (Jira)
-
Flink Pulsar connector new releases in maven
Fabrizzio Chávez Tejada
-
[jira] [Created] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings.
Arvid Heise (Jira)
-
[VOTE] FLIP-486: Introduce a new DeltaJoin
Xuyang
-
[jira] [Created] (FLINK-37817) Add Bundled Aggregate API and operator for group by
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-37816) FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg (Jira)
-
storage partition join (bucket join) implementation in flink
Lu Niu
-
[jira] [Created] (FLINK-37815) JDBC lookup cache - dont query db even if missing
tooptoop4 (Jira)
-
[jira] [Created] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator
Gustavo de Morais (Jira)
-
CCommunity Health initiative canceled this week (22/05/25)
David Radley
-
[jira] [Created] (FLINK-37813) JobManager failover during allocation slots causes ResourceManager to release unwanted TaskManager failure
Baozhu Zhao (Jira)
-
Issue with Duplicate transactionalIdPrefix in Flink 2.0 Kafka Sinks
Teunissen, F.G.J. (Fred)
-
[RESULT][VOTE] FLIP-519: Introduce async lookup key ordered mode
shuai xu
-
Keyed Process Stream Operator Behavior for Asynchronous
Vamsi Aws
-
[jira] [Created] (FLINK-37812) Fix broken links to Apache Avro in doc and code
Mingliang Liu (Jira)
-
[jira] [Created] (FLINK-37811) Flink Job stuck in suspend state after losing leadership in Zookeeper HA
Arun Lakshman (Jira)
-
2025/05/15 CHI Western time zone workgroup meeting minutes
David Radley
-
[ANNOUNCE] Apache Flink CDC 3.4.0 released
Yanquan Lv
-
[jira] [Created] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities
david radley (Jira)
-
Is rabbitmq flink connector supported or abandoned?
Fabrizzio Chávez Tejada
-
[jira] [Created] (FLINK-37809) sqlserver limit statement support
sleepy0521 (Jira)
-
[RESULT][VOTE] FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL
Ramin Gharib
-
[jira] [Created] (FLINK-37808) Checkpoint completed after job failure
Keith Lee (Jira)
-
[jira] [Created] (FLINK-37807) Report s5cmd cancellation in a nicer way
Piotr Nowojski (Jira)
-
[jira] [Created] (FLINK-37806) Add some time cost metrics of some steps
Weijun Wang (Jira)
-
[jira] [Created] (FLINK-37805) Add some time cost logs of some steps
Weijun Wang (Jira)
-
[RESULT] [VOTE] Apache Flink CDC Release 3.4.0, release candidate #3
Yanquan Lv
-
[RESULT][VOTE] FLIP-516: Multi-Way Join Operator
Gustavo de Morais
-
[jira] [Created] (FLINK-37804) Python failed to build wheels on macos
dalongliu (Jira)
-
[jira] [Created] (FLINK-37802) files in directory job-result-store was incorrect
yanggang (Jira)
-
[jira] [Created] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-37801) HybridShuffle: RemoteTier should not finish empty segments
Jira
-
[jira] [Created] (FLINK-37800) When using jobmanager-pod-template to deploy a Native Kubernetes Application Job, an error message appears in the log: 'Invalid value: "/opt/flink/artifacts": must be unique,'
Yang Zhou (Jira)
-
[jira] [Created] (FLINK-37799) Flink native model predict runtime implementation
Hao Li (Jira)
-
[jira] [Created] (FLINK-37798) Persist DelayedScaleDown info in state store
Sai Sharath Dandi (Jira)
-
[jira] [Created] (FLINK-37796) Codegen for ml_evaluate
Hao Li (Jira)
-
[jira] [Created] (FLINK-37797) Documentation
Hao Li (Jira)
-
[jira] [Created] (FLINK-37793) Codegen for ml_predict
Hao Li (Jira)
-
[jira] [Created] (FLINK-37795) Physical rewrite for ml_evaluate
Hao Li (Jira)
-
[jira] [Created] (FLINK-37794) ml_evaluate sql function skeleton
Hao Li (Jira)
-
[jira] [Created] (FLINK-37792) Physical rewrite for ml_predict
Hao Li (Jira)
-
[jira] [Created] (FLINK-37791) Integrate with sql to rel converter
Hao Li (Jira)
-
[jira] [Created] (FLINK-37790) Add model factory related interfaces/classes
Hao Li (Jira)
-
[jira] [Created] (FLINK-37789) Integrate with sqlvalidator
Hao Li (Jira)
-
Upgrade Flink's log4j to to 2.24.3
David Radley
-
[jira] [Created] (FLINK-37787) Refractor Apache Flink project to use Java 21 features
Pranav Mahajan (Jira)
-
[jira] [Created] (FLINK-37788) Refractor equalsTo() method in classes to use Java 17 instanceof operator
Pranav Mahajan (Jira)
-
[jira] [Created] (FLINK-37786) Infer schema information from the state of Source and emit it to avoid maintaining state in PreTransform
Yanquan Lv (Jira)
-
Schema Evolution in Sql-Client
Ashish Khatkar
-
[jira] [Created] (FLINK-37785) Cannot set advanced RocksDB options in state processor job
Alexis Sarda-Espinosa (Jira)
-
[jira] [Created] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation
JunboWang (Jira)
-
[jira] [Created] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled
Jira
-
Long Initial Checkpoint Start Delay in PyFlink FlatMap Operator
张河川
-
[jira] [Created] (FLINK-37782) flink-rpc-core RemoteHandshakeMessage nullness annotation
alan.zhao (Jira)
-
[jira] [Created] (FLINK-37781) Add elasticsearch lookup join document
MOBIN (Jira)
-
[jira] [Created] (FLINK-37780) ml_predict sql function skeleton
Hao Li (Jira)
-
[jira] [Created] (FLINK-37779) Add getModel to Flink catalog reader etc
Hao Li (Jira)
-
[jira] [Created] (FLINK-37778) model keyword syntax change
Hao Li (Jira)
-
[jira] [Created] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Hao Li (Jira)
-
[jira] [Created] (FLINK-37776) Drop support for Python 3.8
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml
Mika Naylor (Jira)
-
[VOTE] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API
Hao Li
-
[RESULT][VOTE] FLIP-520: Simplify StructuredType handling
Timo Walther
-
[VOTE] FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL
Ramin Gharib
-
[RESULT][VOTE] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing
Xuannan Su
-
[RESULT][VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Hao Li
-
[jira] [Created] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names
Sergei Morozov (Jira)
-
[jira] [Created] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs
Nihar Rao (Jira)
-
2025/05/08 CHI Eastern time zone workgroup meeting minutes
David Radley
-
[DISCUSS] Projection pushdown support in Flink Kafka Table connector
Farooq Qaiser
-
[VOTE]FLIP-519: Introduce async lookup key ordered mode
shuai xu
-
[DISCUSS] FLIP-530: Dynamic job configuration
Roman Khachatryan
-
[DISCUSS] Flink 1.19.3 release
Ferenc Csaky
-
[VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Hao Li
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Yash Anand
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Mayank Juneja
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Shengkai Fang
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Ron Liu
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Yunfeng Zhou
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Martijn Visser
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Hao Li
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Piotr Nowojski
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Sergey Nuyanzin
-
Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Hao Li
-
[DISCUSS] Flink 1.20.2 release
Ferenc Csaky
-
flink-connector-aws v5.1.0 release planning
Daren Wong
-
[jira] [Created] (FLINK-37772) Release flink-connector-aws v5.1.0
Daren Wong (Jira)
-
[jira] [Created] (FLINK-37771) Simplify getPartitionedState of AbstractKeyedStateBackend
Jiaan Geng (Jira)
-
[jira] [Created] (FLINK-37770) FLIP-518: Introduce a community review process
david radley (Jira)
-
[RESULT][VOTE] FLIP-518: Introduce a community review process
David Radley
-
Flink Operator 1.12 release planning
Gabor Somogyi
-
[VOTE] FLIP-516: Multi-Way Join Operator
Gustavo de Morais
-
[jira] [Created] (FLINK-37769) Include cause in event when Restarting unhealthy job
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37768) ConstraintEnforcer not handling all constraints
Dawid Wysakowicz (Jira)
-
[VOTE] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing
Xuannan Su
-
[jira] [Created] (FLINK-37767) Update ref version for es connector
Weijie Guo (Jira)
-
[SUMMARY] Flink 2.1 Release Sync 05/07/2025
Ron Liu
-
[jira] [Created] (FLINK-37766) FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync
Kartikey Pant (Jira)