issues  

Messages by Date

• 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
• 2025/06/11 [jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 [jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• 2025/06/11 [jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8 guoqinglong (Jira)
• 2025/06/11 [jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8 guoqinglong (Jira)
• 2025/06/11 Re: [PR] [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8 guoqinglong (Jira)
• 2025/06/11 [jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8 guoqinglong (Jira)
• 2025/06/11 [jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11 guoqinglong (Jira)
• 2025/06/11 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/11 [jira] [Updated] (FLINK-37877) Add the key ordered operator in table runtime ASF GitHub Bot (Jira)
• 2025/06/11 [PR] [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join [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 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/06/11 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline Arvid Heise (Jira)
• 2025/06/10 Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] via GitHub
• 2025/06/10 [jira] [Closed] (FLINK-37903) Support runtime config for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37903) Support runtime config for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] via GitHub
• 2025/06/10 Re: [PR] Aec pr for diff [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/10 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/10 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/10 [jira] [Closed] (FLINK-37876) Introduce key ordered component in runtime Xuyang Zhong (Jira)
• 2025/06/10 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/10 [jira] [Commented] (FLINK-37876) Introduce key ordered component in runtime Xuyang Zhong (Jira)
• 2025/06/10 Re: [PR] [FLINK-37876][table] Introduce async execution controller for key ordered in table runtime [flink] via GitHub
• 2025/06/10 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/10 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 Jira
• 2025/06/10 [jira] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 Jira
• 2025/06/10 [jira] [Updated] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 Jira
• 2025/06/10 [jira] [Commented] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version Jira
• 2025/06/10 [jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version Jira
• 2025/06/10 Re: [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] via GitHub
• 2025/06/10 [jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE Xuyang Zhong (Jira)
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE Xuyang Zhong (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE Xuyang Zhong (Jira)
• 2025/06/10 [jira] [Comment Edited] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 [jira] [Created] (FLINK-37940) Support retry for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/10 [jira] [Resolved] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 [jira] [Assigned] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle Jiangjie Qin (Jira)
• 2025/06/10 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/06/10 [jira] [Comment Edited] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API dalongliu (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API dalongliu (Jira)
• 2025/06/10 Re: [PR] [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] via GitHub
• 2025/06/10 [jira] [Closed] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci dalongliu (Jira)
• 2025/06/10 Re: [PR] [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/10 [jira] [Comment Edited] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci dalongliu (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci dalongliu (Jira)
• 2025/06/10 Re: [PR] [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly [flink-cdc] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] via GitHub
• 2025/06/10 [jira] [Created] (FLINK-37939) Metrics for ml predict function Hao Li (Jira)
• 2025/06/10 [jira] [Created] (FLINK-37938) ml evaluate implementation for different task types Hao Li (Jira)
• 2025/06/10 Re: [PR] [FLINK-37794] ml_evaluate function [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Matt Cuento (Jira)
• 2025/06/10 Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-37795) Physical rewrite for ml_evaluate ASF GitHub Bot (Jira)
• 2025/06/10 [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] via GitHub
• 2025/06/10 [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Use correct `FlinkVersion.v2_1` [flink] via GitHub
• 2025/06/10 Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka] via GitHub
• 2025/06/10 [PR] Bump org.apache.kafka:kafka-clients from 3.9.0 to 3.9.1 [flink-connector-kafka] via GitHub
• 2025/06/10 Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka] via GitHub
• 2025/06/10 Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
• 2025/06/10 [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-37916) Add StreamPhysicalMultiJoin physical node ASF GitHub Bot (Jira)
• 2025/06/10 [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/10 [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline ASF GitHub Bot (Jira)
• 2025/06/10 [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/10 [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Use correct `FlinkVersion.v2_1` [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] Use correct `FlinkVersion.v2_1` [flink] via GitHub
• 2025/06/10 [PR] [hotfix] Use correct `FlinkVersion.v2_1` [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-37814) Add RIGHT JOIN to LEFT JOIN rule Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37890) Extend FlinkLogicalMultiJoin to check for common join key Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37481) Multi way join operator Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule + FlinkLogicalMultiJoin Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37916) Add StreamPhysicalMultiJoin physical node Timo Walther (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37910) Add StreamExecMultiJoin exec node Timo Walther (Jira)
• 2025/06/10 [jira] [Closed] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node Timo Walther (Jira)
• 2025/06/10 Re: [PR] [FLIP-516][FLINK-37910][table] Add StreamExecMultiJoin [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] via GitHub
• 2025/06/10 [jira] [Resolved] (FLINK-37935) Allow to read WindowingStrategy by downstream projects Sergey Nuyanzin (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37935) Allow to read WindowingStrategy by downstream projects Sergey Nuyanzin (Jira)
• 2025/06/10 Re: [PR] [FLINK-37935][table] Allow to read WindowingStrategy by downstream projects [flink] via GitHub
• 2025/06/10 [jira] [Assigned] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Roman Khachatryan (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/10 [jira] [Comment Edited] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Roman Khachatryan (Jira)
• 2025/06/10 Re: [PR] [FLINK-37669][HELM] Add Helm chart unit tests to flink kubernetes operator [flink-kubernetes-operator] via GitHub
• 2025/06/10 Re: [PR] [FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail [flink] via GitHub
• 2025/06/10 Re: [PR] [hotfix] split number is not calculated correctly in CassandraSource [flink-connector-cassandra] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-35051) Weird priorities when processing unaligned checkpoints ASF GitHub Bot (Jira)
• 2025/06/10 [PR] [FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail [flink] via GitHub
• 2025/06/10 [jira] [Created] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. Etienne Chauchot (Jira)
• 2025/06/10 [PR] [improvement] adding runtime converter array [flink-cdc] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37911][Helm] Reorganize Helm chart templates [flink-kubernetes-operator] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Aleksandr Iushmanov (Jira)
• 2025/06/10 [jira] [Assigned] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Roman Khachatryan (Jira)
• 2025/06/10 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/10 [jira] [Closed] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict Shengkai Fang (Jira)
• 2025/06/10 [jira] [Commented] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict Shengkai Fang (Jira)
• 2025/06/10 Re: [PR] [FLINK-37920][table] Reuse same util for AsyncCalc, AsyncLookupJoin a… [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37920][table] Reuse same util for AsyncCalc, AsyncLookupJoin a… [flink] via GitHub
• 2025/06/10 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/10 Re: [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] via GitHub
• 2025/06/10 [jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling Timo Walther (Jira)
• 2025/06/10 Re: [PR] [FLIP-516][FLINK-37910][table] Add StreamExecMultiJoin [flink] via GitHub
• 2025/06/10 Re: [PR] [FLIP-516][FLINK-37910][table] Add StreamExecMultiJoin [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] via GitHub
• 2025/06/10 [jira] [Updated] (FLINK-37928) Forbid cdc-stream for ML_PREDICT ASF GitHub Bot (Jira)
• 2025/06/10 [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37595][table] Add Join Remove Rules [flink] via GitHub
• 2025/06/10 [jira] [Assigned] (FLINK-37928) Support only insert only stream for ml_predict Shengkai Fang (Jira)
• 2025/06/10 [jira] [Updated] (FLINK-37928) Forbid cdc-stream for ML_PREDICT Shengkai Fang (Jira)
• 2025/06/10 Re: [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] via GitHub
• 2025/06/10 Re: [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] via GitHub
• 2025/06/10 [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] via GitHub
• 2025/06/10 [jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator Gustavo de Morais (Jira)

• Earlier messages