Messages by Thread
-
[jira] [Created] (FLINK-37732) FLIP-527: State Schema Evolution for RowData
Weiqing Yang (Jira)
-
[DISCUSS] State Schema Evolution for RowData
Weiqing Yang
-
[jira] [Created] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket
Yanquan Lv (Jira)
-
2025/04/24 CHI Eastern time zone workgroup meeting minutes
David Radley
-
[jira] [Created] (FLINK-37730) Collect job exceptions as kubernetes events
Robert Metzger (Jira)
-
[jira] [Created] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema
Pawel Leszczynski (Jira)
-
[jira] [Created] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize()
Shuyi Chen (Jira)
-
[jira] [Created] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java
Shuyi Chen (Jira)
-
[DISCUSS] FLIP-486: Introduce a new DeltaJoin
Xuyang
-
[jira] [Created] (FLINK-37726) Read incremental data for existing tables
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar
Alan Sheinberg (Jira)
-
[VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch
Allison
-
[jira] [Created] (FLINK-37724) Add AsyncTableFunction as new UDF type
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37721) Fix Janino Bug which resulted in
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-37720) Enable table.optimizer.reuse-sink by default
xiangyu feng (Jira)
-
[jira] [Created] (FLINK-37719) Support Java 25 (LTS)
Liam Miller-Cushon (Jira)
-
[DISCUSS] FLIP-516: Multi-Way Join Operator
Gustavo de Morais
-
[jira] [Created] (FLINK-37718) Refactor ApplicationSubmissionContextReflector
tianzhu.wen (Jira)
-
[jira] [Created] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data
vertern (Jira)
-
[ANNOUNCE] Apache flink-connector-kafka 4.0.0 released
Arvid Heise
-
[RESULT][VOTE] FLIP-522: Add generalized type information to SQL state connector
Gabor Somogyi
-
Re: [DISCUSS] FlinkSQL support enableObjectReuse to optimize CopyingChainingOutput
Zhanghao Chen
-
[jira] [Created] (FLINK-37716) Simplify YarnClusterDescriptor by removing parameter JobGraph
Jiaan Geng (Jira)
-
FW: Kryo v2 to v5 migration tool
David Radley
-
[jira] [Created] (FLINK-37715) Flink try use winutils.exe even without hadoop
Nick M (Jira)
-
[SUMMARY] Flink 2.1 Release Sync 04/23/2025
Ron Liu
-
[RESULT][VOTE] Release flink-connector-kafka v4.0.0, release candidate #3
Arvid Heise
-
[jira] [Created] (FLINK-37714) KafkaTableITCase generates artifacts in main path
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover
Yanquan Lv (Jira)
-
2025/04/17 CHI Western time zone workgroup meeting minute
David Radley
-
[ANNOUNCE] Apache flink-connector-jdbc 3.3.0 & 4.0.0 released
Hang Ruan
-
[KINDLY REMINDER] Flink 2.1 Release Sync 23/04/2025
Ron Liu
-
[RESULT][VOTE] flink-connector-jdbc 4.0.0, release candidate #3
Hang Ruan
-
[RESULT][VOTE] flink-connector-jdbc 3.3.0, release candidate #2
Hang Ruan
-
[jira] [Created] (FLINK-37712) Table
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils
Jiaan Geng (Jira)
-
[jira] [Created] (FLINK-37710) Schema operator relies on data sources re-emitting CreateTableEvents during startup
Sergei Morozov (Jira)
-
Order of OperatorCoordinator method calls
Sergei Morozov
-
[jira] [Created] (FLINK-37709) Add file descriptor usage in default JVM metrics
Zhenqiu Huang (Jira)
-
回复: [DISCUSS] Drop support for HBase v1
tanjialiang
-
[jira] [Created] (FLINK-37708) Print digest about SinkAbilitySpec in plan just like SourceAbilitySpec
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-37707) Deprecate DeserializationSchema#deserialize(byte[])
Hongjia Liang (Jira)
-
[VOTE] FLIP-522: Add generalized type information to SQL state connector
Gabor Somogyi
-
[jira] [Created] (FLINK-37706) [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space
Leonard Xu (Jira)
-
[jira] [Created] (FLINK-37705) JobPlanInfo properties adjustments in OpenAPI spec
Efrat Levitan (Jira)
-
[jira] [Created] (FLINK-37704) Add restoring from state E2e cases for CDC YAML
yux (Jira)
-
[jira] [Created] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline
dalongliu (Jira)
-
[jira] [Created] (FLINK-37702) The python cron hadoop pipeline failed of azure ci
dalongliu (Jira)
-
[jira] [Created] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline
dalongliu (Jira)
-
[jira] [Created] (FLINK-37700) SQL parse exception when creating a view with PTF
juntaozhang (Jira)
-
[jira] [Created] (FLINK-37699) Overwrite the parameters of the created Paimon table through table options
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37698) The behavior is inconsistent with the comments for fromSchedulerNg
Jiaan Geng (Jira)
-
[jira] [Created] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode
Yi Zhang (Jira)
-
[jira] [Created] (FLINK-37696) replace postgres image to official pg 14 and adjust test to use pgoutput plugin
Hongshun Wang (Jira)
-
[VOTE] Release flink-connector-jdbc v3.3.0, release candidate #2
Hang Ruan
-
[jira] [Created] (FLINK-37695) Parsing for a JSON() function call fail to its position
Gustavo de Morais (Jira)
-
[VOTE] Release flink-connector-jdbc v4.0.0, release candidate #3
Hang Ruan
-
Recording Feature FLIP to Flink 2.1 Release Wiki
Ron Liu
-
[ANNOUNCE] Apache flink-connector-elasticsearch 4.0.0 released
weijie guo
-
[jira] [Created] (FLINK-37694) Update version to 4.1-SNAPSHOT for es main branch
Weijie Guo (Jira)
-
[RESULT][VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #2
weijie guo
-
[jira] [Created] (FLINK-37693) ForSt fails to restore from reused checkpoint
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-37692) ForSt Avoid deleting directory when reuse restored directory
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector
Gunnar Morling (Jira)
-
[jira] [Created] (FLINK-37690) Fix flaky Kudu test table datagen
Ferenc Csaky (Jira)
-
[DISCUSS] FLIP-523 - Handle TLS Certificate Renewal
Nicolas Fraison
-
[jira] [Created] (FLINK-37689) Improve the comments and variable names for TaskMailbox
Jiaan Geng (Jira)
-
[VOTE] FLIP-524: CloudWatch Metric Sink Connector
Daren Wong
-
[jira] [Created] (FLINK-37688) FLIP-534: Amazon CloudWatch Metric Sink Connector
Daren Wong (Jira)
-
[ANNOUNCE] New Apache Flink Committer - Xiqian Yu
Leonard Xu
-
[ANNOUNCE] New Apache Flink Committer - Yanquan Lv
Leonard Xu
-
[jira] [Created] (FLINK-37687) Bump flink-connector-aws to 2.0
Keith Lee (Jira)
-
[jira] [Created] (FLINK-37686) ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-37685) process the callback immediately when the processing key equals to the key in record context
Renxiang Zhou (Jira)
-
[jira] [Created] (FLINK-37684) ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySelector
Youjun Yuan (Jira)
-
[jira] [Created] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing
Ryan Despain (Jira)
-
[jira] [Created] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116
Atul Sharma (Jira)
-
[jira] [Created] (FLINK-37677) [cdc-connector] Sink support skip create table event
JunboWang (Jira)
-
[jira] [Created] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37680) Add subclass cache for PojoSerializer
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37679) Improve the performance of Flink serialization
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37678) suggest improve doris connector version
tongyp (Jira)
-
[jira] [Created] (FLINK-37676) Add a cache for TableId in Selector to improve performance
Yanquan Lv (Jira)
-
[RESULT][VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
weijie guo
-
[ANNOUNCE] Apache flink-connector-elasticsearch 3.1.0 released
weijie guo
-
[VOTE] Release flink-connector-jdbc v4.0.0, release candidate #2
Hang Ruan
-
[jira] [Created] (FLINK-37675) Update elastic.yml for 3.1.0 release
Weijie Guo (Jira)
-
[DISCUSS] Add generalized type information to SQL state connector
Gabor Somogyi
-
[jira] [Created] (FLINK-37674) Add generalized type information to SQL state connector
Gabor Somogyi (Jira)
-
[ANNOUNCE] Apache flink-connector-kudu 2.0.0 released
Ferenc Csaky
-
[jira] [Created] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37672) Bump protobuf-maven-plugin from 0.5.1 to 0.6.1
Siddharth R (Jira)
-
[DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing
Xuannan Su
-
[jira] [Created] (FLINK-37671) ChangelogMode.toString returns invalid string for partial deletes
Timo Walther (Jira)
-
[VOTE] Release flink-connector-jdbc v4.0.0, release candidate #1
Hang Ruan
-
[jira] [Created] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned
Piotr Nowojski (Jira)
-
[jira] [Created] (FLINK-37669) [HELM] Add Helm chart unit tests to flink kubernetes operator
Yi Chen (Jira)
-
[jira] [Created] (FLINK-37668) Compaction filter related configs cannot work as expected
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-37667) Make PostTransformOperator always chain with before Operator
Yanquan Lv (Jira)
-
[DISCUSS] Release new version of Flink JDBC Connector for Flink 2.0
Hang Ruan
-
[jira] [Created] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation
Atul Sharma (Jira)
-
[jira] [Created] (FLINK-37665) Simplify DoubleMaximum.clone() Implementation
Atul Sharma (Jira)
-
[DISCUSS] Missing TreeMapState abstraction for maintaining ordered state
Charles COLELLA
-
[RESULT][VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Pradeepta Choudhury
-
[jira] [Created] (FLINK-37656) Introduce FromValues in Python Table API
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-37664) Intergra Kudu connector docs
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-37661) Remove Kryo serializer reference data from version 1.x
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching
Herbert Wang (Jira)
-
[jira] [Created] (FLINK-37660) Reenable Kryo serializer upgrade tests
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-37662) Allow configuration of side car containers
Thomas Weise (Jira)
-
[jira] [Created] (FLINK-37659) Flink 2.0: update reference data for Migration Tests
Zhanghao Chen (Jira)
-
Minutes of 2025/04/10 CHI Eastern time zone workgroup meeting
David Radley
-
[jira] [Created] (FLINK-37658) Improve the Datagen connector documentation
david radley (Jira)
-
[jira] [Created] (FLINK-37657) Helm chart references invalid image repository
Nick Caballero (Jira)
-
[VOTE] Release flink-connector-kafka v4.0.0, release candidate #3
Arvid Heise