Messages by Thread
-
-
Re: [PR] [FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction [flink]
via GitHub
-
Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink]
via GitHub
-
Re: [PR] [FLINK-30284][flink-metrics] Adding datacenter url property to datadog [flink]
via GitHub
-
[PR] [FLINK-37958][cdc-sink-connectors] Flink CDC Sink connector support fluss [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-36609) Protobuf Format not support proto3
Hongshun Wang (Jira)
-
[PR] Init workflow api [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-37972) Support jar and UserClassLoader sharing between jobs.
Weijun Wang (Jira)
-
[jira] [Updated] (FLINK-37759) Support upload user jars by external process instead of via blobs.
Weijun Wang (Jira)
-
[jira] [Resolved] (FLINK-37969) Allow Transformation subgraphs to be merged during translation
Arvid Heise (Jira)
-
[PR] Pulsar 3.0.12 [flink-connector-pulsar]
via GitHub
-
[jira] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source
Maximilian Michels (Jira)
-
[jira] [Updated] (FLINK-37971) SQL hints are dropped by planner
Maximilian Michels (Jira)
-
[jira] [Created] (FLINK-37971) SQL hints are dropped by planner when
Maximilian Michels (Jira)
-
[PR] [FLINK-37969] Allow Transformation subgraphs to be merged during translation [flink]
via GitHub
-
[jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37969) Allow Transformation subgraphs to be merged during translation
Arvid Heise (Jira)
-
[PR] [FLINK-37921][table] Replace TableKeyedAsyncWaitOperator with new operator under new async framework [flink]
via GitHub
-
[PR] [FLINK-37944][test] Add utils for initializing process function test harnesses with async state. [flink]
via GitHub
-
Re: [PR] [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs [flink]
via GitHub
-
[jira] [Resolved] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API
Sergey Nuyanzin (Jira)
-
[PR] [hotfix] Fix the ut.sh for java tests [flink-agents]
via GitHub
-
[jira] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis
Xenos (Jira)
-
[PR] [Feature][runtime] Adds the basic components from flink-statefun to implement feedback ability [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis
Radha Krishna Peteti (Jira)
-
[PR] [FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying. [flink]
via GitHub
-
[I] [Tech Debt] Use the modern pyproject.toml with uv setup [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util
Junrui Lee (Jira)
-
[jira] [Created] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis
Radha Krishna Peteti (Jira)
-
[PR] [hotfix] Reuse the final field barrierId [flink]
via GitHub
-
Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 [flink-connector-pulsar]
via GitHub
-
[jira] [Commented] (FLINK-37930) Generalize the async record processing with key-ordered framework
Zakelly Lan (Jira)
-
[jira] [Resolved] (FLINK-37930) Generalize the async record processing with key-ordered framework
Zakelly Lan (Jira)
-
[PR] [FLINK-37797] Model DDL documentation [flink]
via GitHub
-
[jira] [Commented] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability
Chris Nauroth (Jira)
-
Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar]
via GitHub
-
[jira] [Comment Edited] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-37957) Do not write empty lists to compiled plan
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-37957) Do not write empty lists to compiled plan
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink]
via GitHub
-
[PR] [FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL E… [flink]
via GitHub
-
[jira] [Assigned] (FLINK-37967) Add Confluent product and link to vendor solutions documentation
Martijn Visser (Jira)
-
[PR] [FLINK-37967] Add Confluent Cloud for Apache Flink as vendor solution in docs [flink]
via GitHub
-
[jira] [Created] (FLINK-37967) Add Confluent product and link to vendor solutions documentation
Martijn Visser (Jira)
-
[PR] [FLINK-37889] [table-planner] Add JoinToMultiJoinRule [flink]
via GitHub
-
[jira] [Updated] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key
Gustavo de Morais (Jira)
-
[jira] [Comment Edited] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule
Gustavo de Morais (Jira)
-
[PR] [docs] Adding Confluent to vendors list [flink]
via GitHub
-
[PR] [hotfix][ci] Add missing Iceberg unit tests & split pipelien connector UT into stages [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-37660) Reenable Kryo serializer upgrade tests
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-37660) Reenable Kryo serializer upgrade tests
Zakelly Lan (Jira)
-
[jira] [Resolved] (FLINK-37660) Reenable Kryo serializer upgrade tests
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0
Roman Khachatryan (Jira)
-
[jira] [Closed] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner
Xuyang Zhong (Jira)
-
[PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule, Semantic tests and Restore tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule, Semantic tests and Restore tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965][FLINK-37889][FLINK-37966] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
Re: [PR] [FLINK-37965][FLINK-37889][FLINK-37966] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink]
via GitHub
-
[PR] fix: CVE-2025-4565 [flink-statefun]
via GitHub
-
Re: [PR] [mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin
Gustavo de Morais (Jira)
-
[PR] [hotfix][python] Avoids temporary LICENSE file generated during build [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-37799) Flink native model predict runtime implementation
Shengkai Fang (Jira)
-
[jira] [Commented] (FLINK-37799) Flink native model predict runtime implementation
Shengkai Fang (Jira)
-
Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws]
via GitHub