issues  

Messages by Date

• 2025/06/12 [jira] [Updated] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow Ferenc Csaky (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow ASF GitHub Bot (Jira)
• 2025/06/12 [PR] [FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API [flink-connector-rabbitmq] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison Chang (Jira)
• 2025/06/12 [jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow Ferenc Csaky (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule Gustavo de Morais (Jira)
• 2025/06/12 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend xiangyu feng (Jira)
• 2025/06/12 Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink] via GitHub
• 2025/06/12 [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink] via GitHub
• 2025/06/12 Re: [PR] Fix documentation issue regarding to createTemporalTableFunction params [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] via GitHub
• 2025/06/12 Re: [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] via GitHub
• 2025/06/12 Re: [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program [flink] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process david radley (Jira)
• 2025/06/12 Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] via GitHub
• 2025/06/12 [jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 Xuannan Su (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option Jacob Jona Fahlenkamp (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule Stepan Stepanishchev (Jira)
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule Gustavo de Morais (Jira)
• 2025/06/12 [I] [Feature] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option Jacob Jona Fahlenkamp (Jira)
• 2025/06/12 [I] [Feature] Introduce Workflow, Event, Action & Callable in the Python Workflow Plan [flink-agents] via GitHub
• 2025/06/12 [I] [Feature] Support converting between Java & Python Workflow Plans [flink-agents] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option Jacob Jona Fahlenkamp (Jira)
• 2025/06/12 [I] [Feature][runtime] Deploy workflow as a Flink job into a Flink cluster [flink-agents] via GitHub
• 2025/06/12 [jira] [Created] (FLINK-37950) MongoDB connector should support ordered option Jacob Jona Fahlenkamp (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37894) Introduce Index in CatalogTable Xuyang Zhong (Jira)
• 2025/06/12 [I] [Feature] Introduce Python API for Workflow, Event and Action [flink-agents] via GitHub
• 2025/06/12 [I] [Feature] Introduce Workflow, Event, Action & Callable in the Java Workflow Plan [flink-agents] via GitHub
• 2025/06/12 [I] [Tech Debt] Document how-to-contribute in README [flink-agents] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline Zakelly Lan (Jira)
• 2025/06/12 Re: [PR] [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program [flink] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Ferenc Csaky (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule Gustavo de Morais (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule Gustavo de Morais (Jira)
• 2025/06/12 [jira] [Closed] (FLINK-37894) Introduce Index in CatalogTable Xuyang Zhong (Jira)
• 2025/06/12 Re: [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink] via GitHub
• 2025/06/12 [I] [Feature] Introduce API for Workflow, Event and Action [flink-agents] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37894][table] Introduce Index in CatalogTable [flink] via GitHub
• 2025/06/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37245] Prevent masking null values in BinaryRowData [flink] via GitHub
• 2025/06/12 [I] [Feature] Support DataStream / Table as input / output of Flink Agents [flink-agents] via GitHub
• 2025/06/12 [jira] [Assigned] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline Zakelly Lan (Jira)
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 [jira] [Closed] (FLINK-37536) Improve SQL gateway documentation Shengkai Fang (Jira)
• 2025/06/12 Re: [PR] [FLINK-37894][table] Introduce Index in CatalogTable [flink] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline Xuyang Zhong (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline Zakelly Lan (Jira)
• 2025/06/12 [jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline dalongliu (Jira)
• 2025/06/12 [I] [Feature][runtime] Implement a Flink operator that executes the given workflow plan [flink-agents] via GitHub
• 2025/06/12 [I] [Feature] Introduce Java API for Workflow, Event and Action [flink-agents] via GitHub
• 2025/06/12 [I] [Feature] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents] via GitHub
• 2025/06/12 [jira] [Resolved] (FLINK-37933) Move TransformationScan/SinkProvider out of planner Arvid Heise (Jira)
• 2025/06/12 [I] [Feature] Introduce the fundamental concepts: Workflow, Event, Action & Callable [flink-agents] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly Ferenc Csaky (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Ferenc Csaky (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37536) Improve SQL gateway documentation Shengkai Fang (Jira)
• 2025/06/12 Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink] via GitHub
• 2025/06/12 [jira] [Commented] (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)
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink] via GitHub
• 2025/06/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/06/12 [jira] [Comment Edited] (FLINK-36303) PostgreSQL timestamp precision 0 not supported Rui Fan (Jira)
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 [jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint Keith Lee (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process david radley (Jira)
• 2025/06/12 [jira] [Created] (FLINK-37947) Add sql hint to enable this optimization Shuai Xu (Jira)
• 2025/06/12 [PR] [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37896][table-planner] Introduce a new trait derived from sink to source to check whether the downstream operators can accept duplicate data [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37799][model][docs] Add document for OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37738][cdc-connector][postgres] Support read changelog as append only mode [flink-cdc] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram ASF GitHub Bot (Jira)
• 2025/06/12 Re: [PR] [FLINK-35458][test][type] Add serializer upgrade test for set serializer [flink] via GitHub
• 2025/06/12 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline dalongliu (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline dalongliu (Jira)
• 2025/06/12 [jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process david radley (Jira)
• 2025/06/12 [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 [PR] [FLINK-37799][model][docs] Add document for OpenAI Model Function [flink] via GitHub
• 2025/06/12 [jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process david radley (Jira)
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] via GitHub
• 2025/06/12 Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] via GitHub
• 2025/06/12 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/12 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/12 [jira] [Assigned] (FLINK-37916) Add StreamPhysicalMultiJoin physical node Timo Walther (Jira)
• 2025/06/12 [jira] [Closed] (FLINK-37916) Add StreamPhysicalMultiJoin physical node Timo Walther (Jira)
• 2025/06/12 [jira] [Commented] (FLINK-37933) Move TransformationScan/SinkProvider out of planner Arvid Heise (Jira)
• 2025/06/12 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/12 [jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend Zakelly Lan (Jira)
• 2025/06/12 Re: [PR] [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect … [flink] via GitHub
• 2025/06/12 [jira] [Closed] (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)
• 2025/06/12 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] via GitHub
• 2025/06/12 Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] via GitHub
• 2025/06/12 [jira] [Assigned] (FLINK-37898) Implement delta join operator Xuyang Zhong (Jira)
• 2025/06/11 Re: [PR] [FLINK-37660] Reenable Kryo serializer upgrade tests [flink] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner Xuyang Zhong (Jira)
• 2025/06/11 Re: [PR] [FLINK-35458][test][type] Add serializer upgrade test for set serializer [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/11 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/11 [jira] [Assigned] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend Zakelly Lan (Jira)
• 2025/06/11 Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner CaoZhen (Jira)
• 2025/06/11 [jira] [Updated] (FLINK-37737) Add support for GaussDB database type ASF GitHub Bot (Jira)
• 2025/06/11 Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37772] Bump connector version to 5.1.0 [flink-connector-aws] via GitHub
• 2025/06/11 [jira] [Closed] (FLINK-35018) ML_EVALUATE function Hao Li (Jira)
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-33536) Flink Table API CSV streaming sink fails with "IOException: Stream closed" sigalit (Jira)
• 2025/06/11 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 [jira] [Closed] (FLINK-35017) ML_PREDICT function Hao Li (Jira)
• 2025/06/11 [jira] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL Hao Li (Jira)
• 2025/06/11 [jira] [Closed] (FLINK-35020) Model Catalog implementation in Hive etc Hao Li (Jira)
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop. [flink-connector-aws] via GitHub
• 2025/06/11 Re: [PR] [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop. [flink-connector-aws] via GitHub
• 2025/06/11 [PR] [FLINK-37946][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN slankka (Jira)
• 2025/06/11 Re: [PR] [FLINK-37946][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN ASF GitHub Bot (Jira)
• 2025/06/11 [jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN slankka (Jira)
• 2025/06/11 [jira] [Commented] (FLINK-37928) Forbid cdc-stream for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/11 [jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend Jufang He (Jira)
• 2025/06/11 Re: [PR] [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect … [flink] via GitHub
• 2025/06/11 [PR] [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect … [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/11 [jira] [Closed] (FLINK-37928) Forbid cdc-stream for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/11 [jira] [Commented] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May Sergey Nuyanzin (Jira)
• 2025/06/11 Re: [PR] Add templates for Github Issues and PRs [flink-agents] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37894][table] Introduce Index in CatalogTable [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 [PR] Add templates for Github Issues and PRs [flink-agents] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] via GitHub
• 2025/06/11 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/11 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/11 [jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram Gustavo de Morais (Jira)
• 2025/06/11 Re: [PR] [FLINK-37894][table] Introduce Index in CatalogTable [flink] via GitHub
• 2025/06/11 [jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 Zakelly Lan (Jira)
• 2025/06/11 Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop. [flink-connector-aws] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May Jing Ge (Jira)
• 2025/06/11 [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator Gustavo de Morais (Jira)
• 2025/06/11 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/11 [jira] [Commented] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub

• Earlier messages
• Later messages