Messages by Thread
-
-
[jira] [Created] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory
Roman Khachatryan (Jira)
-
[jira] [Created] (FLINK-37954) Full the exception message when the regular could not be optimized into delta join while delta join strategy is FORCE
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-37953) Add OBF password obfuscation support for SSL configurations
Basapuram Kumar (Jira)
-
[VOTE] Release 1.19.3, release candidate #2
Ferenc Csaky
-
[jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37950) MongoDB connector should support ordered option
Jacob Jona Fahlenkamp (Jira)
-
[jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline
dalongliu (Jira)
-
[jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint
Keith Lee (Jira)
-
[jira] [Created] (FLINK-37947) Add sql hint to enable this optimization
Shuai Xu (Jira)
-
[VOTE] FLIP-533: Cassandra Sink V2
Poorvank Bhatia
-
[jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN
slankka (Jira)
-
[jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data
sunshuxian (Jira)
-
[jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11
guoqinglong (Jira)
-
[SUMMARY] Flink 2.1 Release Sync 06/11/2025
Ron Liu
-
[jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-37940) Support retry for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37938) ml evaluate implementation for different task types
Hao Li (Jira)
-
[jira] [Created] (FLINK-37939) Metrics for ml predict function
Hao Li (Jira)
-
[jira] [Created] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split.
Etienne Chauchot (Jira)
-
[jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37935) Allow to read WindowingStrategy by downstream projects
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-37934) Get the case-sensitive variable names and method names of mysql are not standardized, and need to be adjusted
Jira
-
[jira] [Created] (FLINK-37933) Move TransformationScan/SinkProvider out of planner
Arvid Heise (Jira)
-
[jira] [Created] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability
Shruti Singhania (Jira)
-
[jira] [Created] (FLINK-37931) LookupJoinUtil failed to compile
Zakelly Lan (Jira)
-
[KINDLY REMINDER] Flink 2.1 Release Sync 06/11/2025
Ron Liu
-
[DISCUSS] FLIP Suggestion: Externalize and Modernize Apache Pinot Connector
Poorvank Bhatia
-
[jira] [Created] (FLINK-37930) Generalize the AsyncExecutionController
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37929) Support cdc stream for ml_predict
Hao Li (Jira)
-
[jira] [Created] (FLINK-37928) Support only insert only stream for ml_predict
Hao Li (Jira)
-
[jira] [Created] (FLINK-37927) Add batch mode support for AsyncTableFunction
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-37926) Support type casting between variant and constructed type
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37924) Support variant field accessing
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37925) Support type casting between variant and primitive type
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37922) Integrating Variant Type into Flink
Xuannan Su (Jira)
-
[jira] [Created] (FLINK-37921) Refactor current implementation with implementation in FLIP-425
Shuai Xu (Jira)
-
Invitation to Slack
Алексей Поздняков
-
[jira] [Created] (FLINK-37920) Reuse same utils for AsyncScalar, AsyncLookupJoin and AsyncMLPredict
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37919) Logback | Not applied
Dheeraj Panangat (Jira)
-
[jira] [Created] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards.
hajimeni (Jira)
-
[jira] [Created] (FLINK-37917) Add support for MultiJoinedRowData
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37916) FLIP-516: Add StreamPhysicalMultiJoin physical node
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37915) Migrate Firehose and Kinesis Stream IT Test to E2E test package
Daren Wong (Jira)
-
[jira] [Created] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-37912) Typing the DataStream interfaces
Joey Pereira (Jira)
-
[RESULT][VOTE] FLIP 505: Flink History Server Scalability Improvements, Remote Data Store Fetch and Per Job Fetch
Allison
-
[jira] [Created] (FLINK-37911) [Helm] Reorganize Helm chart templates
Yi Chen (Jira)
-
[VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink
David Radley
-
[RESULT][VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project
Xintong Song
-
[jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error
Sachin Mittal (Jira)
-
[jira] [Created] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts
Jonathan Du (Jira)
-
[jira] [Created] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters
Ruan Hang (Jira)
-
2025/06/05 CHI Eastern time zone workgroup meeting minutes
David Radley
-
[jira] [Created] (FLINK-37904) Support state ttl for async ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37903) Support runtime config for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37901) Support to serde ExecNode for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37902) Support batch execution for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader
Zhenqiu Huang (Jira)
-
Flink CDC for mongoDB, need to understand MongoDBStreamFetchTask better
Sachin Mittal
-
[jira] [Created] (FLINK-37899) Unstable JoinRestoreTest
Shengkai Fang (Jira)
-
Waiting on approval to Jira account
Jonathan Du
-
[jira] [Created] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-37898) Implement delta join operator
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join.
Xuyang Zhong (Jira)
-
[DISCUSS] FLIP-533: Cassandra Sink V2
Poorvank Bhatia
-
[jira] [Created] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs
Jira
-
[ANNOUNCE] Apache Flink Kubernetes Operator 1.12.0 released
Gabor Somogyi
-
[jira] [Created] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed
dalongliu (Jira)
-
[jira] [Created] (FLINK-37893) Rest Port Name should be made configurable
Mayur Dhingra (Jira)
-
[jira] [Created] (FLINK-37894) Introduce new Join Operator with Async State API
Wang Qilong (Jira)
-
[SUMMARY] Flink 2.1 Release Sync 06/04/2025
Ron Liu
-
Call for Presentations: Current New Orleans, October 29-30, 2025
Robert Metzger
-
[jira] [Created] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported
Sergei Morozov (Jira)
-
[jira] [Created] (FLINK-37889) FLIP-516: Add new FlinkLogicalMultiJoin rule
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37890) FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key
Gustavo de Morais (Jira)
-
Missing required TM metrics when truing to use the autoscaler
David Radley
-
Request a permission
Zhe Wang
-
[jira] [Created] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg
r0y4d3v (Jira)
-
[jira] [Created] (FLINK-37887) Watched namespaces not picked up automatically by the operator
Igor Milavec (Jira)
-
[HELP] Failing ArchitectureTest on master (CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API)
Gabor Somogyi
-
[jira] [Created] (FLINK-37886) Introduce the ITCase to check whether unaligned checkpoint works well for jobs with sink writer and committer
Rui Fan (Jira)
-
[KINDLY REMINDER] Flink 2.1 Release Sync 06/04/2025
Ron Liu
-
[jira] [Created] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1
Jira
-
[jira] [Created] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master
Gabor Somogyi (Jira)
-
[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1
Gabor Somogyi
-
[DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support
Poorvank Bhatia
-
[jira] [Created] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May
Sergey Nuyanzin (Jira)
-
[VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project
Xintong Song
-
[jira] [Created] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-37881) Drop gosu in favour of Dockerfile's USER
Avi Sanwal (Jira)
-
[RESULT][VOTE] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API
Hao Li
-
[jira] [Created] (FLINK-37880) build_wheels_on_macos fails every time
Sergey Nuyanzin (Jira)
-
[VOTE] Release 1.20.2, release candidate #1
Ferenc Csaky
-
[jira] [Created] (FLINK-37876) Introduce key ordered component in runtime
Shuai Xu (Jira)
-
[DISCUSS] FLIP-532: Donate GetInData HTTP Connector to Flink
David Radley
-
2025/05/29 CHI Western time zone workgroup meeting minutes
David Radley
-
[jira] [Created] (FLINK-37879) transform concat function don't support utf-8 and cast don't support STRING
Xin Gong (Jira)
-
[jira] [Created] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public
Sergey Nuyanzin (Jira)
-
[VOTE] Release 1.19.3, release candidate #1
Ferenc Csaky