issues@flink.apache.org, 2025-07

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Commented] (FLINK-37959) supported All postgres sql 14 field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/01 01:08:00 UTC, 0 replies.
- Re: [PR] [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/01 01:42:37 UTC, 6 replies.
- Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/01 02:12:26 UTC, 0 replies.
- Re: [PR] [Fix][Docs] Quick Start mysql-to-starrocks Flink Version Incorrect [flink-cdc] - posted by "suntectec (via GitHub)" <gi...@apache.org> on 2025/07/01 02:22:46 UTC, 0 replies.
- Re: [PR] [Feature][runtime] Introducing the FlinkRunnerContext component to support Python workflow execution [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/07/01 02:30:54 UTC, 0 replies.
- Re: [I] [Feature] Adds the support of executing the given workflow [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/07/01 02:32:09 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/01 03:04:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36929) SQL connector for keyed savepoint data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/01 03:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/01 03:26:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/01 03:27:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/01 03:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "JeffHu88 (via GitHub)" <gi...@apache.org> on 2025/07/01 03:30:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/01 04:07:00 UTC, 1 replies.
- Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/01 04:08:04 UTC, 2 replies.
- Re: [PR] [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/01 06:09:43 UTC, 2 replies.
- [jira] [Created] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Salva (Jira)" <ji...@apache.org> on 2025/07/01 06:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] - posted by "liangyu-1 (via GitHub)" <gi...@apache.org> on 2025/07/01 06:20:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Salva (Jira)" <ji...@apache.org> on 2025/07/01 06:25:00 UTC, 4 replies.
- Re: [PR] [FLINK-26944][Table SQL/API] Add ADD_MONTHS supported in SQL and Table API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/01 06:25:48 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Salva (Jira)" <ji...@apache.org> on 2025/07/01 06:27:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Salva (Jira)" <ji...@apache.org> on 2025/07/01 06:28:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "fallenup (Jira)" <ji...@apache.org> on 2025/07/01 07:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-38018][state] Migrate state processor API from sink API v1 to sink API v2 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/07/01 07:42:40 UTC, 2 replies.
- Re: [PR] [hotfix] Rename executionVertexId to executionVertex [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/07/01 08:30:24 UTC, 0 replies.
- Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/01 09:04:19 UTC, 15 replies.
- [jira] [Commented] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/01 09:05:00 UTC, 1 replies.
- Re: [I] [Feature][api][python] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/01 09:26:01 UTC, 1 replies.
- [PR] [API][Python] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/01 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/01 10:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/01 10:01:00 UTC, 3 replies.
- Re: [PR] [FLINK-34468][Connector/Cassandra] Adding support for Flink 1.20 [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/07/01 10:01:19 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/01 10:02:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/01 10:04:00 UTC, 0 replies.
- [PR] [hotfix][test] Move SlotSharingSlotAllocatorTest#getSlots into TestingSlot [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/01 10:25:41 UTC, 3 replies.
- Re: [PR] [FLINK-37770][GithubAction] Community review Github Action. [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/01 10:32:09 UTC, 0 replies.
- [PR] [BP-2.1][FLINK-37770][GithubAction] Community review Github Action. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/01 10:44:19 UTC, 4 replies.
- [PR] [BP-2.0][FLINK-37770][GithubAction] Community review Github Action. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/01 10:47:41 UTC, 4 replies.
- [PR] [BP-120][FLINK-37770][GithubAction] Community review Github Action. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/01 10:54:39 UTC, 8 replies.
- [jira] [Updated] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/07/01 11:03:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/07/01 11:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/07/01 12:44:11 UTC, 7 replies.
- [jira] [Updated] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 12:49:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Niha (Jira)" <ji...@apache.org> on 2025/07/01 13:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Niha (Jira)" <ji...@apache.org> on 2025/07/01 13:03:00 UTC, 4 replies.
- Re: [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/01 13:22:49 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema - posted by "Keshav Kansal (Jira)" <ji...@apache.org> on 2025/07/01 14:53:00 UTC, 2 replies.
- [PR] [Fix][Docs] Fix Quick Start MySQL to Starrocks Flink Version Incorrect [flink-cdc] - posted by "suntectec (via GitHub)" <gi...@apache.org> on 2025/07/01 14:53:43 UTC, 1 replies.
- Re: [PR] [FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate [flink] - posted by "fhueske (via GitHub)" <gi...@apache.org> on 2025/07/01 15:20:48 UTC, 38 replies.
- Re: [PR] [FLINK-37125] [conf] fixed env.log.max java.lang.NumberFormatException [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/01 15:36:20 UTC, 7 replies.
- [jira] [Updated] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/01 15:38:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/01 16:26:00 UTC, 2 replies.
- Re: [PR] [hotfix] ELEMENT should throw TableRuntimeException [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/01 17:21:03 UTC, 13 replies.
- [jira] [Commented] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 17:28:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38036) Make PlannerBase#getExecNodeGraphProcessors pulbic - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 17:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38036) Make PlannerBase#getExecNodeGraphProcessors public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 17:33:00 UTC, 1 replies.
- [PR] [FLINK-38036][table] Make `PlannerBase#getExecNodeGraphProcessors` public [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/01 17:38:15 UTC, 3 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2025/07/01 18:38:27 UTC, 7 replies.
- [jira] [Created] (FLINK-38037) Configure hashDistribution with commonJoinKey - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/01 19:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/01 21:12:00 UTC, 5 replies.
- [jira] [Resolved] (FLINK-38036) Make PlannerBase#getExecNodeGraphProcessors public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 21:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38036) Make PlannerBase#getExecNodeGraphProcessors public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/01 21:14:00 UTC, 0 replies.
- [PR] [FLINK-38037][table] Configure hashDistribution with commonJoinKey [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/07/01 21:40:56 UTC, 12 replies.
- [jira] [Updated] (FLINK-38037) Configure hashDistribution with commonJoinKey - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/01 21:41:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36679) Add a metric to track checkpoint _metadata size - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/01 21:50:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38038) Fix some typos in code, tests and docs - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/01 23:01:00 UTC, 0 replies.
- [PR] [FLINK-38038][docs] Fix some typos in code, tests and docs [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/01 23:03:31 UTC, 6 replies.
- [jira] [Updated] (FLINK-38038) Fix some typos in code, tests and docs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/01 23:04:00 UTC, 1 replies.
- Re: [PR] [FLINK-36827] CDC quickstart tidyup [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/02 00:05:04 UTC, 1 replies.
- [jira] [Created] (FLINK-38039) Fix broken link and improve instructions for using connectors in Docker mode - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/02 01:17:00 UTC, 0 replies.
- [PR] [FLINK-38039][docs] Fix broken link and improve instructions for using connectors in Docker mode [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/02 01:18:52 UTC, 3 replies.
- [jira] [Updated] (FLINK-38039) Fix broken link and improve instructions for using connectors in Docker mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/02 01:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/02 01:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/02 01:28:00 UTC, 0 replies.
- [PR] [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/02 01:43:08 UTC, 5 replies.
- Re: [PR] [API][Python] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/02 02:09:00 UTC, 12 replies.
- [jira] [Created] (FLINK-38040) Documentation for VARIANT type and PARSE_JSON - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/07/02 07:08:00 UTC, 0 replies.
- [PR] [FLINK-38040][doc] Add documentation for VARIANT type and PARSE_JSON [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/07/02 07:12:01 UTC, 11 replies.
- [jira] [Updated] (FLINK-38040) Documentation for VARIANT type and PARSE_JSON - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/02 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/07/02 07:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/07/02 08:00:00 UTC, 2 replies.
- [I] [Feature][runtime] Support bounded source in flink operator [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/07/02 08:44:38 UTC, 0 replies.
- [jira] [Created] (FLINK-38041) Schema.Builder#fromResolvedSchema dropps comments - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/02 09:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38041) Schema.Builder#fromResolvedSchema drops comments - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/02 09:25:00 UTC, 1 replies.
- [PR] [FLINK-37958][cdc-sink-connectors] Flink CDC Sink connector support fluss [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/07/02 09:40:47 UTC, 18 replies.
- [PR] [FLINK-38041] Fix Schema.Builder#fromResolvedSchema dropping comments [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/07/02 09:51:35 UTC, 8 replies.
- Re: [PR] [Feature] Implements flink operators to execute workflow [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/07/02 10:00:16 UTC, 7 replies.
- Re: [PR] [FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19 [flink-connector-rabbitmq] - posted by "sunil-git1hub (via GitHub)" <gi...@apache.org> on 2025/07/02 10:27:44 UTC, 0 replies.
- Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/02 12:23:30 UTC, 2 replies.
- [PR] [FLINK-38033] Fix accidental upgrade snapshot dispose bug [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/07/02 12:33:49 UTC, 7 replies.
- [PR] [FLINK-37895][Job Manager] Fix failing collection of Flink Exceptions for Session Jobs [flink-kubernetes-operator] - posted by "vsantwana (via GitHub)" <gi...@apache.org> on 2025/07/02 12:57:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/02 12:58:00 UTC, 1 replies.
- [PR] Make flink download caching conditional on a cache miss [flink-connector-shared-utils] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/02 14:03:51 UTC, 0 replies.
- Re: [PR] [FLINK-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/07/02 14:18:19 UTC, 9 replies.
- [jira] [Closed] (FLINK-38037) Configure hashDistribution with commonJoinKey - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/07/02 14:22:00 UTC, 0 replies.
- [PR] Fix Java setup in Python CI workflow [flink-connector-shared-utils] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/02 15:24:12 UTC, 2 replies.
- Re: [PR] [FLINK-37983] Update to Kafka client 3.9.1 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/02 15:29:51 UTC, 3 replies.
- [jira] [Updated] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/02 15:30:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/02 15:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/02 15:45:00 UTC, 0 replies.
- [PR] Backport critical fixes for 1.12 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/07/02 15:49:02 UTC, 1 replies.
- [jira] [Closed] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/02 17:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-33926][kubernetes]: Allow using job jars in the system classpath in native mode [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/02 18:33:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/02 18:36:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/02 18:36:00 UTC, 0 replies.
- [PR] [FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/02 18:38:35 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/02 18:39:57 UTC, 3 replies.
- Re: [PR] [BP-2.1][FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/07/02 18:41:05 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38041) Schema.Builder#fromResolvedSchema drops comments - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/02 18:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/03 01:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/03 01:24:00 UTC, 0 replies.
- [PR] docs: updated StarRocks documentation link [flink-cdc] - posted by "zhuxt2015 (via GitHub)" <gi...@apache.org> on 2025/07/03 02:17:42 UTC, 3 replies.
- Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] - posted by "joyCurry30 (via GitHub)" <gi...@apache.org> on 2025/07/03 02:27:23 UTC, 3 replies.
- [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/03 04:22:04 UTC, 6 replies.
- [jira] [Closed] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/03 05:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/03 05:20:00 UTC, 0 replies.
- [PR] [hotfix] Community review script improvements [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/03 05:22:39 UTC, 6 replies.
- Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/03 06:29:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-37147) The where condition run time advance caused a program error - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/03 06:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/03 07:15:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/03 07:28:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38042) Warn the user on full table scans - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/03 07:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38042) Warn the user on full table scans - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/03 08:56:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38033) Job upgrades fail for operator v1.12 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/03 09:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-15571] Add Redis sink [flink-connector-redis-streams] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/03 10:53:08 UTC, 0 replies.
- [PR] [FLINK-36962] Avoid pushing down non-deterministic filter after stream join to source [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/07/03 11:21:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/03 11:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/03 11:26:00 UTC, 0 replies.
- [PR] Kubernetes Operator 1.12.1 [flink-web] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/07/03 13:03:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-17524) Remove "An illegal reflective access operation has occurred" warnings on JDK11 - posted by "Dan Lipofsky (Jira)" <ji...@apache.org> on 2025/07/03 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38043) Support joining without join keys - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/03 14:17:00 UTC, 0 replies.
- [PR] [FLINK-38043][table] Use empty row instead of null for no join keys [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/07/03 14:30:36 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-38037) Configure hashDistribution with commonJoinKey - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/07/03 14:38:00 UTC, 0 replies.
- Re: [PR] [plan][java] Support serializing / deserializing Java workflow plan to / from JSON [flink-agents] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2025/07/03 19:11:32 UTC, 12 replies.
- [jira] [Assigned] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/03 20:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/03 20:40:00 UTC, 0 replies.
- [PR] Use isEmpty() instead of length() > 0 in WordCount Tokenizer [flink] - posted by "Diogo-Sardagna (via GitHub)" <gi...@apache.org> on 2025/07/03 22:42:21 UTC, 1 replies.
- [PR] Add input validation to WordCount Tokenizer for robustness [flink] - posted by "Diogo-Sardagna (via GitHub)" <gi...@apache.org> on 2025/07/03 22:56:38 UTC, 1 replies.
- [PR] Enhance Javadoc documentation for WordCount Tokenizer class [flink] - posted by "Diogo-Sardagna (via GitHub)" <gi...@apache.org> on 2025/07/03 22:58:32 UTC, 3 replies.
- Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 00:04:59 UTC, 0 replies.
- Re: [PR] [FLINK-37254] Add OceanBaseDefaultValueConverter to fix table schema validation [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 00:05:03 UTC, 0 replies.
- Re: [PR] [FLINK-36024][source-connector][mysql] Throw the exception encountered when searching for the starting binlog [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 00:05:07 UTC, 0 replies.
- [jira] [Created] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version - posted by "Ao Yuchen (Jira)" <ji...@apache.org> on 2025/07/04 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version - posted by "Ao Yuchen (Jira)" <ji...@apache.org> on 2025/07/04 01:52:00 UTC, 1 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/07/04 03:13:43 UTC, 8 replies.
- [jira] [Updated] (FLINK-38039) Improve instructions for using SQL connectors in Docker mode - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/04 06:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-38039][docs] Improve instructions for using SQL connectors in Docker mode [flink] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2025/07/04 06:15:33 UTC, 3 replies.
- Re: [PR] Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 06:25:51 UTC, 2 replies.
- Re: [PR] [FLINK-37600] Add pre-commit git hook for common linting checks [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 06:25:56 UTC, 1 replies.
- Re: [PR] Bump @babel/runtime and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/04 06:25:57 UTC, 0 replies.
- [jira] [Created] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/07/04 06:33:00 UTC, 0 replies.
- [PR] [ci][python][build] Modernize Python dependency management with uv an… [flink-agents] - posted by "Sucran (via GitHub)" <gi...@apache.org> on 2025/07/04 07:36:28 UTC, 2 replies.
- [jira] [Created] (FLINK-38046) Solve the issue of missing one piece of data - posted by "jingzi (Jira)" <ji...@apache.org> on 2025/07/04 07:39:00 UTC, 0 replies.
- Re: [I] [Tech Debt] Use the modern pyproject.toml with uv setup [flink-agents] - posted by "Sucran (via GitHub)" <gi...@apache.org> on 2025/07/04 07:40:05 UTC, 1 replies.
- [PR] Solve the issue of missing one piece of data [flink-connector-jdbc] - posted by "wangxiaojing (via GitHub)" <gi...@apache.org> on 2025/07/04 07:41:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-38046) Solve the issue of missing one piece of data - posted by "jingzi (Jira)" <ji...@apache.org> on 2025/07/04 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/04 08:02:00 UTC, 0 replies.
- [PR] [FLINK-38022][table] Throw exception in main thread in tests when any exception is thrown in async thread during looking up [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/04 08:11:24 UTC, 18 replies.
- Re: [PR] [hotfix] Rename isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/07/04 08:20:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35263) FLIP-446: Kubernetes Operator State Snapshot CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35123) Flink Kubernetes Operator should not do deleteHAData - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35340) Flink Kubernetes Operator CRDs not applying correctly - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:49:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-36534) Upgrade Flink Kubernetes operator to flink-1.20 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33244) Not Able To Pass the Configuration On Flink Session - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34576) Flink deployment keep staying at RECONCILING/STABLE status - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33237) Optimize the data type of JobStatus#state from String to Enum - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33154) flink on k8s，An error occurred during consuming rocketmq - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33108) Error during error status handling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33222) Operator rollback app when it should not - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33232) Kubernetive Operator Not Able to Take Other Python paramters While Submitting Job Deployment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33519) standalone mode could not create keytab secret - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35901) Setting web.submit.enable to false prevents FlinkSessionJobs from working - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33930) Stateless stop job status exception - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34563) Autoscaling decision improvement - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34347) Kubernetes native resource manager request wrong spec. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33992) Add option to fetch the jar from private repository in FlinkSessionJob - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-37591][table] Add some PruneEmptyRules [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/04 08:58:40 UTC, 4 replies.
- [jira] [Closed] (FLINK-32561) Change the status field reconciliationTimestamp from long to Date - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-32829) Allow setting different values for CPU requests and limits - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-32886) Issue with volumeMounts when creating OLM for Flink Operator 1.6.0 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 08:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-32883) Support for standby task managers - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-32631) FlinkSessionJob stuck in Created/Reconciling state because of No Job found error in JobManager - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-28261) Consider Using Dependent Resources for Ingress - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-28648) Allow session deletion to block on any running job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:01:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-32813) Split autoscaler ConfigMap - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-28645) Clean up logging in FlinkService / Reconciler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31064) Error while retrieving the leader gateway - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-29108) Kubernetes operator: Support queryable state - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-30529) Use simple cancel for savepoint upgrades on failing jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-30530) Flink configuration from user-provided ConfigMap - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-30404) Do not redeploy taskmanagers on standalone application scaling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33785) TableJdbcUpsertOutputFormat could not deal with DELETE record correctly when primary keys were set - posted by "Dhwaneet Bhatt (Jira)" <ji...@apache.org> on 2025/07/04 09:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31493) helm upgrade does not work, because repo path does not follow helm standards - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-32093) Upon Delete deployment idle pods throw - java.lang.IllegalStateException: Cannot receive event after a delete event received - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31798) Add config to enable/disable Kubernetes Events - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31998) Flink Operator Deadlock on run job Failure - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-31867) Enforce a minimum number of observations within a metric window - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-32119) Revise source partition skew logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31920) Flaky Kubernetes operator tests - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/04 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/04 09:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/04 09:25:00 UTC, 4 replies.
- Re: [PR] [FLINK-37595][table] Add Join Remove Rules [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/04 09:44:46 UTC, 5 replies.
- Re: [PR] [FLINK-20625] Implement V2 Google Cloud PubSub Source in accordance with FLIP-27 [flink-connector-gcp-pubsub] - posted by "xxntti3n (via GitHub)" <gi...@apache.org> on 2025/07/04 09:55:59 UTC, 1 replies.
- Re: [PR] [FLINK-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/04 10:03:55 UTC, 20 replies.
- [jira] [Created] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/04 10:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-37478] Adding service labels to flink config [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/04 10:14:02 UTC, 7 replies.
- Re: [PR] [FLINK-37505][python] Add pyflink YAML based config support [flink] - posted by "zneel (via GitHub)" <gi...@apache.org> on 2025/07/04 10:20:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/04 11:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/04 11:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38018) Migrate state processor API from sink API v1 to sink API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/04 11:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/07/04 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/07/04 12:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/04 12:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/04 12:33:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/04 12:33:00 UTC, 2 replies.
- Re: [PR] [FLINK-37985][conf] Refactor public config options from StreamConfig to JobConfiguration [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/07/04 14:44:39 UTC, 4 replies.
- [jira] [Closed] (FLINK-38043) Support joining without join keys - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/04 15:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/04 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/04 15:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36679) Add a metric to track checkpoint _metadata size - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/04 16:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-38038][docs] Fix all typos in code, tests and docs [flink] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2025/07/05 04:45:55 UTC, 4 replies.
- [PR] [Docs]Update postgres-cdc.md with table-name and schema-name support regular expressions to monitor [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2025/07/05 07:34:25 UTC, 0 replies.
- [jira] [Created] (FLINK-38051) Fix flaky test JobAutoScalerImplTest - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/07/06 04:22:00 UTC, 0 replies.
- [PR] [FLINK-38051] Fix flaky test JobAutoScalerImplTest [flink-kubernetes-operator] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/07/06 04:29:59 UTC, 1 replies.
- Re: [PR] [FLINK-34989][ci] Reduces number of concurrent jobs for nightly runs [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/06 06:25:30 UTC, 0 replies.
- [PR] Update nightly-trigger.yml [flink] - posted by "aripitek (via GitHub)" <gi...@apache.org> on 2025/07/06 07:32:59 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38039) Improve instructions for using SQL connectors in Docker mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/06 07:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38039) Improve instructions for using SQL connectors in Docker mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/06 07:36:00 UTC, 0 replies.
- [I] [Feature] Rename Workflow to Agent [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/07 03:50:13 UTC, 2 replies.
- [jira] [Updated] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 05:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 05:55:00 UTC, 1 replies.
- [PR] [all] Rename Workflow to Agent [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/07 06:03:10 UTC, 1 replies.
- [PR] [FLINK-37941][table] Exclude partitions in original table when merge strategy is EXCLUDING [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/07/07 06:12:36 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 06:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-30400][docs] Add some notes about changes for flink-connector-base dependency in externalized connectors [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/07 06:25:55 UTC, 2 replies.
- [jira] [Created] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 06:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/07 07:15:00 UTC, 4 replies.
- Re: [D] MVP Design Doc - (WIP, incrementally updating) [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/07 07:15:47 UTC, 2 replies.
- Re: [D] Resource & Resource Provider Design [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/07 07:18:24 UTC, 3 replies.
- Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2025/07/07 07:19:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:48:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:48:00 UTC, 0 replies.
- [jira] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/07 07:49:00 UTC, 0 replies.
- [PR] [hotfix] [docs] Edit Docs [flink] - posted by "ha2hi (via GitHub)" <gi...@apache.org> on 2025/07/07 08:14:55 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/07 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38054) Kryo Deserialization Error in ElasticSearch 8 Sink 3.1.0 With Flink 1.20.0 - posted by "Andrey Starostin (Jira)" <ji...@apache.org> on 2025/07/07 09:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38054) Kryo Deserialization Error in ElasticSearch 8 Sink 3.1.0 With Flink 1.20.0 - posted by "Andrey Starostin (Jira)" <ji...@apache.org> on 2025/07/07 09:10:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38054) Kryo deserialization error in ElasticSearch 8 sink 3.1.0 with Flink 1.20.0 - posted by "Andrey Starostin (Jira)" <ji...@apache.org> on 2025/07/07 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38055) The internalTimerService must initialize watermark before processing data - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 10:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 11:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 11:26:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37591) Add Some PruneEmptyRules - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 11:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37591) Add Some PruneEmptyRules - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/07 11:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/07 11:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/07 11:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/07 11:59:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/07 11:59:00 UTC, 2 replies.
- Re: [PR] FLINK-37949: Avoid netty deadlock with graceful shutdown [flink-connector-aws] - posted by "jayteej (via GitHub)" <gi...@apache.org> on 2025/07/07 12:03:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-37807) Report s5cmd cancellation in a nicer way - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/07 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/07 13:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-38056][s3] Improve interruption handling for s5cmd [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/07/07 13:49:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/07 13:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/07 13:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/07 13:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/07/07 13:56:09 UTC, 7 replies.
- [PR] [FLINK-38048] Update java version and move parent pom to v1.2.0 [flink-connector-shared-utils] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/07 15:58:29 UTC, 5 replies.
- [jira] [Commented] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/07/07 16:02:00 UTC, 0 replies.
- [PR] Update Dockerfiles for 1.19.3, and 1.20.2 releases [flink-docker] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/07 16:19:48 UTC, 2 replies.
- Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/07/07 16:55:47 UTC, 9 replies.
- [PR] [hotfix] Do not use syntax requiring java higher than java 11 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/07 18:15:22 UTC, 3 replies.
- [jira] [Commented] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "Yash Anand (Jira)" <ji...@apache.org> on 2025/07/07 21:24:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "Yash Anand (Jira)" <ji...@apache.org> on 2025/07/07 21:31:00 UTC, 0 replies.
- Re: [PR] [Docs] Update mysql-to-doris.md, add scan.startup.mode config to make demo run more smoothly [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 00:05:02 UTC, 1 replies.
- [PR] [chore] Fix builds [flink-connector-opensearch] - posted by "reta (via GitHub)" <gi...@apache.org> on 2025/07/08 00:13:35 UTC, 0 replies.
- Re: [PR] [hotfix] Fix weekly builds [flink-connector-opensearch] - posted by "reta (via GitHub)" <gi...@apache.org> on 2025/07/08 00:37:41 UTC, 5 replies.
- [jira] [Updated] (FLINK-38038) Fix typos in code, tests and docs - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/08 00:45:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38038) Fix typos in code, tests and docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/08 01:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38038) Fix typos in code, tests and docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/08 01:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37266) Python CLI arguments doesn't work in session mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/08 01:39:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/08 02:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/08 02:40:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/07/08 02:42:33 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-37944][test] Add utils for initializing process function test harnesses with async state [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/07/08 02:44:02 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38057) Connector emit time lag may be a wrong value - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/07/08 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38057) Connector emit time lag may be a wrong value - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/07/08 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/08 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/08 03:19:00 UTC, 0 replies.
- [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/07/08 03:40:33 UTC, 2 replies.
- [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/07/08 03:58:28 UTC, 3 replies.
- Re: [PR] [FLINK-36767] Bumped `cyclonedx-maven-plugin` to `2.9.1` to resolve CVE-2024-38374 [flink] - posted by "sa-kononov (via GitHub)" <gi...@apache.org> on 2025/07/08 04:11:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/08 04:15:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2025/07/08 04:22:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37991) Upgrade pemja to 0.5.3 - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/07/08 04:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-37775][python] Manage python development/test dependencies in pyproject.yaml [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/07/08 05:51:12 UTC, 2 replies.
- [PR] [FLINK-38045] Build createTableEventCache using TableSchemas from split and Make transform operator stateless [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/07/08 06:25:11 UTC, 0 replies.
- Re: [PR] [FLINK-31070][Table SQL/Client] Update jline from 3.21.0 to 3.22.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 06:26:00 UTC, 1 replies.
- Re: [PR] [table] Add support for temporal join on rolling aggregates [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 06:26:02 UTC, 0 replies.
- Re: [PR] [hotfix] [docs] Fix typo in docker.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 06:26:04 UTC, 0 replies.
- Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/08 06:26:08 UTC, 1 replies.
- Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/08 06:38:18 UTC, 6 replies.
- [PR] [BP-2.0][FLINK-37422][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/07/08 06:47:11 UTC, 3 replies.
- [jira] [Created] (FLINK-38060) Github action build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/08 06:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38060) Github action build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/08 06:49:00 UTC, 1 replies.
- [PR] [FLINK-38060][ci] Fix github action failed to build python wheel on linux [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/08 06:52:21 UTC, 5 replies.
- [jira] [Commented] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/08 07:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/08 07:09:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/08 07:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/07/08 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint - posted by "potterhe (Jira)" <ji...@apache.org> on 2025/07/08 07:55:00 UTC, 0 replies.
- Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/08 09:18:24 UTC, 8 replies.
- [jira] [Created] (FLINK-38062) ENCODE behaves wrong - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/08 10:58:00 UTC, 0 replies.
- [PR] [FLINK-38062][table] `ENCODE` function behaves wrong [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/08 11:00:24 UTC, 8 replies.
- [jira] [Updated] (FLINK-38062) ENCODE behaves wrong - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 11:01:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37887) Watched namespaces not picked up automatically by the operator - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/08 11:10:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37991) Upgrade pemja to 0.5.4 - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/07/08 11:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37391) Change watchNamespace config in operator is not respected while running - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/08 11:22:00 UTC, 1 replies.
- [PR] [ci][fluss] Add MySQL to Fluss E2e IT case [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/07/08 11:27:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/07/08 11:31:00 UTC, 2 replies.
- [PR] [FLINK-38042] Warn the user on full table scans [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/07/08 11:45:43 UTC, 7 replies.
- [jira] [Commented] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2025/07/08 12:12:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-38057) Connector emit time lag may be a wrong value - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 12:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/08 12:56:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/08 13:50:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/07/08 14:16:00 UTC, 0 replies.
- [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/07/08 14:22:47 UTC, 9 replies.
- [PR] [FLINK-38063] Update dependencies [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/08 15:16:23 UTC, 3 replies.
- [jira] [Updated] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 15:17:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 15:30:00 UTC, 0 replies.
- Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc] - posted by "eskabetxe (via GitHub)" <gi...@apache.org> on 2025/07/08 16:45:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-38046) Solve the issue of missing one piece of data - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2025/07/08 19:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2025/07/08 19:08:00 UTC, 0 replies.
- [PR] [FLINK-38064] bump cyclonedx-maven-plugin to 2.9.1 [flink] - posted by "r-sidd (via GitHub)" <gi...@apache.org> on 2025/07/08 19:11:14 UTC, 2 replies.
- [jira] [Updated] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 19:12:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38062) ENCODE behaves wrong - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/08 20:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38062) ENCODE behaves wrong - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/08 20:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38065) Mismatching bracket in PostgresOffset#toString - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/07/08 20:12:00 UTC, 0 replies.
- [PR] [FLINK-38065] Use curly braces in PostgresOffset#toString() [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/07/08 20:13:56 UTC, 1 replies.
- [jira] [Updated] (FLINK-38065) Mismatching bracket in PostgresOffset#toString - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/08 20:14:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/08 20:25:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/08 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/08 23:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/08 23:02:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/09 00:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/07/09 01:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38060) Github action build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 01:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38060) Github action build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 01:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38060) Github action build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 01:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 01:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38065) Mismatching bracket in PostgresOffset#toString - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 01:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38040) Documentation for VARIANT type and PARSE_JSON - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/07/09 02:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/07/09 02:24:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 02:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/09 02:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/09 02:39:00 UTC, 17 replies.
- [jira] [Created] (FLINK-38068) Fix distribution - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/09 02:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/09 02:48:00 UTC, 1 replies.
- [PR] [FLINK-38068] fix model provider pom [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/07/09 03:03:51 UTC, 18 replies.
- [jira] [Updated] (FLINK-38068) Fix distribution - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/09 03:04:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Dylan He (Jira)" <ji...@apache.org> on 2025/07/09 03:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Dylan He (Jira)" <ji...@apache.org> on 2025/07/09 03:30:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Dylan He (Jira)" <ji...@apache.org> on 2025/07/09 03:33:00 UTC, 0 replies.
- [PR] [FLINK-38069] Fix return type nullability diffs of function ENCODE & DECODE in SQL and Table API [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/07/09 03:57:43 UTC, 4 replies.
- [jira] [Created] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "Yash Anand (Jira)" <ji...@apache.org> on 2025/07/09 03:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "Yash Anand (Jira)" <ji...@apache.org> on 2025/07/09 03:59:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "Yash Anand (Jira)" <ji...@apache.org> on 2025/07/09 04:00:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38071) FLIP-485: Add UDF Metrics - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/07/09 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38071) FLIP-485: Add UDF Metrics - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/07/09 05:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35231) Tests rely on listJobsFunction in TestingClusterClient are broken - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-26972) Support spot instance in Flink Kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36212) Failing non-leader JM pod causes the deployment to be stuck in failing state - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:24:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:25:00 UTC, 0 replies.
- Re: [PR] [hotfix] Avoid duplicate loop for configuration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/09 06:25:50 UTC, 1 replies.
- [jira] [Updated] (FLINK-38051) Fix flaky test JobAutoScalerImplTest - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/09 06:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38051) Fix flaky test JobAutoScalerImplTest - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/09 06:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37911) [Helm] Reorganize Helm chart templates - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 06:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-36932][metrics] Added resource-level metrics for different states/statuses [flink-kubernetes-operator] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2025/07/09 07:12:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:20:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36169) Support namespace level resource check before scaling up - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36137) Missing JarURI leads to null pointer in reconciler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36137) Missing JarURI leads to null pointer in reconciler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36137) Missing JarURI leads to null pointer in reconciler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/09 07:25:00 UTC, 0 replies.
- [PR] [hotfix] Adds Override annotation [flink] - posted by "luyizhizaio (via GitHub)" <gi...@apache.org> on 2025/07/09 07:37:26 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/09 08:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37561) Report system events - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37560) Document events reporting - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37560) Document events reporting - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37561) Report system events - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37426) FLIP-481: Introduce Event Reporting - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37426) FLIP-481: Introduce Event Reporting - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/09 08:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 08:56:00 UTC, 0 replies.
- [I] [Tech Debt][plan] Implement checkSignature for PythonFunction in Java [flink-agents] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2025/07/09 08:58:43 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38011) [Release-2.1] Prepare RC0 release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 09:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38011) [Release-2.1] Prepare RC0 release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 09:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38011) [Release-2.1] Prepare RC0 release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 09:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 09:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38065) Mismatching bracket in PostgresOffset#toString - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 10:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38065) Mismatching bracket in PostgresOffset#toString - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/09 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38072) EventTimeWindowCheckpointingITCase#testSlidingTimeWindow test failed in cron ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/09 11:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37595) Add Join Remove rules. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/09 11:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37595) Add Join Remove rules. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/09 11:43:00 UTC, 0 replies.
- [PR] Datetype [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/07/09 11:56:02 UTC, 1 replies.
- Re: [I] [Feature] Implements agent execution operator [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/09 12:02:23 UTC, 0 replies.
- Re: [I] [Feature][runtime] Deploy workflow as a Flink job into a Flink cluster [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/09 12:03:32 UTC, 1 replies.
- Re: [I] [Feature][runtime] Implement a Flink operator that executes the given workflow plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/09 12:04:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-28648) Allow session deletion to block on any running job - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/09 13:42:00 UTC, 2 replies.
- [PR] [hotfix][docs] Update build documentation to require Java 17 [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/07/09 13:50:29 UTC, 5 replies.
- [PR] [hotfix][docs] Make timeout param of async i/o more clearer [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/09 14:21:48 UTC, 4 replies.
- [jira] [Created] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/09 14:26:00 UTC, 0 replies.
- [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/07/09 14:47:32 UTC, 14 replies.
- [jira] [Updated] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/09 14:48:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/07/09 15:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/07/09 15:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/07/09 15:48:00 UTC, 1 replies.
- [PR] [FLINK-36577] Add compatibility check for FlinkStateSnapshot [flink-kubernetes-operator] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/07/09 15:50:50 UTC, 1 replies.
- [jira] [Updated] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/07/09 15:53:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/07/09 15:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/07/09 15:54:00 UTC, 0 replies.
- [PR] [FLINK-38047] Bump cert-manager from v1.8.2 to v1.18.2 [flink-kubernetes-operator] - posted by "kumar-mallikarjuna (via GitHub)" <gi...@apache.org> on 2025/07/09 15:57:10 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/09 16:21:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2025/07/09 19:02:00 UTC, 10 replies.
- Re: [PR] [hotfix] Remove mention of SplittableTimers in favor of InterruptibleTimers [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2025/07/09 22:00:34 UTC, 2 replies.
- [jira] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/09 23:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/10 01:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/10 01:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/10 01:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 02:03:00 UTC, 0 replies.
- [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/07/10 02:16:23 UTC, 3 replies.
- Re: [D] Short-Term Memory Design [flink-agents] - posted by "coderplay (via GitHub)" <gi...@apache.org> on 2025/07/10 02:19:29 UTC, 9 replies.
- [jira] [Assigned] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/10 02:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/10 02:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 03:19:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 03:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/07/10 03:58:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/10 05:06:00 UTC, 1 replies.
- [PR] [Doc] Fix typo in Operations [flink-kubernetes-operator] - posted by "Guosmilesmile (via GitHub)" <gi...@apache.org> on 2025/07/10 06:23:14 UTC, 3 replies.
- Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 06:25:51 UTC, 0 replies.
- Re: [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 06:25:54 UTC, 1 replies.
- Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/10 06:26:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/10 06:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38047) Bump cert-manager in the Kubernetes Operator - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/10 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38075) [Window]Data loss when using ltz time. - posted by "kaitian (Jira)" <ji...@apache.org> on 2025/07/10 06:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38075) [Window]Data loss when using ltz time. - posted by "kaitian (Jira)" <ji...@apache.org> on 2025/07/10 06:59:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 - posted by "fallenup (Jira)" <ji...@apache.org> on 2025/07/10 07:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/10 07:40:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/10 07:40:00 UTC, 0 replies.
- Re: [PR] [Docs]Update postgres-cdc.md with table-name and schema-name configs support regular expressions to monitor [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/07/10 09:07:49 UTC, 0 replies.
- [I] [Feature][plan][runtime] Introduce Resource and Resource Provider [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:27:04 UTC, 0 replies.
- [I] [Feature][api][runtime] Support Short-Term Memory [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:28:01 UTC, 1 replies.
- [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:29:48 UTC, 5 replies.
- [I] [Feature][api] Support ReAct Agent [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:30:22 UTC, 2 replies.
- [I] [Feature][runtime] Support async execution for actions [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:33:00 UTC, 0 replies.
- [I] [Feature][api][runtime] Introduce metric mechanism [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/10 09:34:58 UTC, 1 replies.
- Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/07/10 10:07:27 UTC, 9 replies.
- [jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 10:08:00 UTC, 2 replies.
- [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/10 10:09:00 UTC, 13 replies.
- Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] - posted by "Tyhoning (via GitHub)" <gi...@apache.org> on 2025/07/10 10:09:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 10:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/10 10:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/10 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/10 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/07/10 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/07/10 11:23:00 UTC, 0 replies.
- [PR] [FLINK-38079] Add Pipeline support for DateType and TimeType [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/07/10 11:27:44 UTC, 1 replies.
- [jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 11:28:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 11:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 11:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/10 12:35:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/10 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38082) User's async function timeout call may result in unexpected retries - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/07/10 13:29:00 UTC, 0 replies.
- [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/10 13:36:26 UTC, 8 replies.
- [jira] [Updated] (FLINK-38082) User's async function timeout call may result in unexpected retries - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 13:37:00 UTC, 2 replies.
- [jira] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2025/07/10 14:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/10 14:42:00 UTC, 0 replies.
- Re: [PR] Add Flink 1.19.3 release [flink-web] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/07/10 14:51:51 UTC, 0 replies.
- Re: [PR] Add Flink 1.20.2 release [flink-web] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/07/10 14:51:52 UTC, 0 replies.
- [jira] [Created] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/10 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38084) Update model provider download doc - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/10 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38085) Use buildx for Docker image creation - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/10 17:27:00 UTC, 0 replies.
- [PR] [FLINK-28648][operator] Fix Cleanup Process for Session Cluster [flink-kubernetes-operator] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/07/10 18:43:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-28648) Allow session deletion to block on any running job - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38086) Make ChangelogNormalize reusable if possible - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/10 22:31:00 UTC, 0 replies.
- [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/10 22:59:05 UTC, 15 replies.
- [jira] [Updated] (FLINK-38086) Make ChangelogNormalize reusable if possible - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 23:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/07/10 23:23:00 UTC, 0 replies.
- [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/10 23:27:28 UTC, 10 replies.
- [jira] [Updated] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/10 23:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38068) Fix distribution - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/07/11 01:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38068) Fix distribution - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/07/11 01:52:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/07/11 01:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/11 01:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/07/11 02:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/07/11 02:00:00 UTC, 0 replies.
- [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/07/11 02:19:35 UTC, 4 replies.
- Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] - posted by "ChaomingZhangCN (via GitHub)" <gi...@apache.org> on 2025/07/11 02:35:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/11 02:38:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/11 02:38:00 UTC, 0 replies.
- [PR] [plan][python][java] Add test cases for checking agent plan compatibi… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/11 02:57:31 UTC, 3 replies.
- [jira] [Created] (FLINK-38088) If source config "scan.startup.mode:snapshot",not create replicatedconnect. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/11 03:16:00 UTC, 0 replies.
- [PR] Add Flink 2.1.0 release [flink-web] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/11 04:07:48 UTC, 20 replies.
- Re: [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 06:25:56 UTC, 0 replies.
- Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/07/11 08:59:16 UTC, 3 replies.
- [jira] [Created] (FLINK-38089) Avoid pushing down non-deterministic filter in agg, join and union - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/11 09:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-36962] Avoid pushing down non-deterministic filter in FILTER_RULES [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/07/11 09:36:06 UTC, 0 replies.
- [PR] [FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/07/11 09:37:22 UTC, 2 replies.
- [jira] [Updated] (FLINK-38089) Avoid pushing down non-deterministic filter in agg, join and union - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/11 09:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38043) Support joining without join keys - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37584) Bump assertj-core version from 3.23.1 to 3.27.3 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37521) Implement async state version of KeyedCoProcessOperator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37623) Async state support for `process()` in Datastream API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36336) Remove deprecated dataset API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37438) Improve the createLocalEnvironment by reduce duplicate operation on Configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37620) ForSt Sync mode support remote storage and provide configurable options - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37875) Introduce the option and the support of planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37720) Enable sink reuse table optimizer by default and apply plan changes to existing test cases - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37930) Generalize the async record processing with key-ordered framework - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37377) Sync guava with guava in flink-shaded - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37385) Add support for smile format in flink main repo - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37789) Integrate with sqlvalidator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37792) Reuse LookupJoin Operator to run ML_PREDICT - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37790) Add model factory related interfaces/classes - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37780) ml_predict sql function type inference and argument validation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:00:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-37779) Add getModel to Flink catalog reader etc - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37481) Multi way join operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37778) model keyword syntax change - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37910) Add StreamExecMultiJoin exec node - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37916) Add StreamPhysicalMultiJoin physical node - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:02:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37862) Implement data type improvements for StructuredType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/11 10:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/11 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/11 10:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37258) Order Flink Job list in Flink UI with start time - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37408) Update all docker-compose references to docker compose in documentation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/11 10:56:00 UTC, 0 replies.
- [PR] [FLINK-38090][table] Align data type of inline structured types for TableResult.collect() [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/07/11 11:14:11 UTC, 5 replies.
- [jira] [Updated] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/11 11:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37588) Flink Kubernetes Operator Parameter `jm-deployment.shutdown-ttl` does not take effect - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/11 11:21:00 UTC, 0 replies.
- [PR] [FLINK-38031][table] Support EXPLAIN before EXECUTE statement [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/07/11 12:45:42 UTC, 2 replies.
- [jira] [Updated] (FLINK-38031) Support and Release Connectors for Flink 2.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/11 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38092) Update japicmp configuration post 1.19.3 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/11 13:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38091) Update japicmp configuration post 1.20.2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/11 13:37:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38091) Update japicmp configuration post 1.20.2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/11 13:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38091) Update japicmp configuration post 1.20.2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/11 13:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38092) Update japicmp configuration post 1.19.3 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/11 13:37:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/11 13:49:00 UTC, 1 replies.
- [PR] [FLINK-38092] Bump japicmp configuration post 1.19.3 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/11 13:59:40 UTC, 2 replies.
- [jira] [Assigned] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/11 14:18:00 UTC, 0 replies.
- [PR] [FLINK-38091] Bump japicmp configuration post 1.20.2 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/07/11 14:58:32 UTC, 6 replies.
- [PR] docs: update overview.md [flink-kubernetes-operator] - posted by "haoxins (via GitHub)" <gi...@apache.org> on 2025/07/11 15:43:59 UTC, 2 replies.
- [PR] Alpha/5 0/fix fork group [flink-connector-pulsar] - posted by "dialalpha (via GitHub)" <gi...@apache.org> on 2025/07/11 16:09:14 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2025/07/11 16:39:00 UTC, 6 replies.
- [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 10.0.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/11 16:46:02 UTC, 1 replies.
- [PR] Add Kafka-to-Kafka SQL Example to Documentation [flink] - posted by "Ashfaqbs (via GitHub)" <gi...@apache.org> on 2025/07/11 18:28:02 UTC, 12 replies.
- [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle status in case of MISSING/ERROR JM status [flink-kubernetes-operator] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/07/11 21:42:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/11 21:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/11 21:53:00 UTC, 1 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 [flink-connector-aws] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:11:30 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 [flink-connector-kudu] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:22:33 UTC, 5 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 [flink-connector-prometheus] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:25:57 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:29:50 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-gcp-pubsub] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:29:57 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-jdbc] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:31:47 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-mongodb] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:33:29 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-rabbitmq] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:37:44 UTC, 0 replies.
- [PR] Bump org.apache.commons:commons-lang3 from 3.3.2 to 3.18.0 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/12 01:39:32 UTC, 3 replies.
- [jira] [Closed] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/12 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/07/12 15:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern. - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/12 17:13:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/13 02:18:27 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790 [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/13 02:20:09 UTC, 2 replies.
- [PR] [BP-2.1][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790 #26791 [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/13 02:25:26 UTC, 2 replies.
- [PR] [Java] Check JSON Serializability Before Sending Event to Context [flink-agents] - posted by "Kavishankarks (via GitHub)" <gi...@apache.org> on 2025/07/13 05:22:38 UTC, 2 replies.
- Re: [PR] [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws] - posted by "digitalpoetry (via GitHub)" <gi...@apache.org> on 2025/07/13 05:49:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/07/13 07:43:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-35746) Add logic to override observed config based on settings observed through REST API - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/13 08:38:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-35746) Add logic to override observed config based on settings observed through REST API - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/13 08:39:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37991) Upgrade pemja to 0.5.4 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/13 08:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35746) Add logic to override observed config based on settings observed through REST API - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/13 08:50:00 UTC, 0 replies.
- Re: [PR] [hotfix] Update version to 21.0 [flink-shaded] - posted by "reneleonhardt (via GitHub)" <gi...@apache.org> on 2025/07/13 13:57:47 UTC, 1 replies.
- [jira] [Created] (FLINK-38094) Introduce pyflink.__version__ - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/07/13 14:01:00 UTC, 0 replies.
- [PR] [FLINK-38094][python] Introduce pyflink.__version__ [flink] - posted by "Myasuka (via GitHub)" <gi...@apache.org> on 2025/07/13 14:06:31 UTC, 3 replies.
- [jira] [Updated] (FLINK-38094) Introduce pyflink.__version__ - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/13 14:07:00 UTC, 0 replies.
- [PR] [API][Java] agent java api [flink-agents] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/07/13 18:21:38 UTC, 1 replies.
- Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/07/13 20:19:37 UTC, 11 replies.
- [PR] FLINK-38035: Redact sensitive env vars in PythonEnvUtils logging [flink] - posted by "vssakuru (via GitHub)" <gi...@apache.org> on 2025/07/14 00:53:32 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/14 02:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/14 02:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/14 02:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/14 02:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/07/14 02:30:00 UTC, 0 replies.
- Re: [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink] - posted by "jiefei30 (via GitHub)" <gi...@apache.org> on 2025/07/14 03:00:08 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38068) Fix distribution - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/14 03:35:00 UTC, 0 replies.
- Re: [I] [Feature][api][java] Introduce Java API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/14 04:56:58 UTC, 0 replies.
- Re: [I] [Feature][api] Introduce API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/14 05:51:22 UTC, 0 replies.
- Re: [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/14 06:26:02 UTC, 2 replies.
- [PR] [FLINK-37968] Update Netty version to v4.1.122.Final [flink-connector-aws] - posted by "somaniraghav (via GitHub)" <gi...@apache.org> on 2025/07/14 06:34:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/14 06:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle Status of FlinkDeployment Resource in case of MISSING/ERROR JM status [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/07/14 07:22:03 UTC, 7 replies.
- [jira] [Assigned] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/14 07:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/14 07:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-38081][table] Support EXPLAIN before EXECUTE statement [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/07/14 07:40:37 UTC, 0 replies.
- [jira] [Updated] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/14 07:41:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/07/14 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38095) Error in Session Job autoscaler when realizing parallelism overrides - posted by "Jean-Benoit Hamard (Jira)" <ji...@apache.org> on 2025/07/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy - posted by "Michał Misiewicz (Jira)" <ji...@apache.org> on 2025/07/14 10:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy - posted by "Michał Misiewicz (Jira)" <ji...@apache.org> on 2025/07/14 10:42:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/14 10:47:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/14 10:47:00 UTC, 0 replies.
- [PR] [FLINK-38097][docs] Add deployments/finalizers to RBAC permissions in documentation [flink-kubernetes-operator] - posted by "kumar-mallikarjuna (via GitHub)" <gi...@apache.org> on 2025/07/14 11:01:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2025/07/14 11:32:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed - posted by "shilei (Jira)" <ji...@apache.org> on 2025/07/14 11:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed - posted by "shilei (Jira)" <ji...@apache.org> on 2025/07/14 11:33:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed - posted by "shilei (Jira)" <ji...@apache.org> on 2025/07/14 11:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38099) Greenplum: Distribution column updates in Greenplum upsert - posted by "zm999999 (Jira)" <ji...@apache.org> on 2025/07/14 12:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/14 13:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/14 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector - posted by "Luca Occhipinti (Jira)" <ji...@apache.org> on 2025/07/14 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38101) Support SI Format for CPU resources - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2025/07/14 13:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector - posted by "Luca Occhipinti (Jira)" <ji...@apache.org> on 2025/07/14 13:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38101) Support SI Format for CPU resources - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2025/07/14 13:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/07/14 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38102) RestApiMetricsCollectorTest is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/14 14:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/14 14:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38102) RestApiMetricsCollectorTest is unstable - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2025/07/14 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38103) DataTypeFactory cannot restore inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/14 14:49:00 UTC, 0 replies.
- [PR] [FLINK-37701][flink-runtime] Backporting of the fix to 2.0 for AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/07/14 15:24:25 UTC, 3 replies.
- [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/14 15:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2025/07/14 15:30:09 UTC, 2 replies.
- [PR] [FLINK-38103][table] Fix error for inline structured types in DataTypeFactory [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/07/14 15:30:10 UTC, 10 replies.
- [jira] [Updated] (FLINK-38103) DataTypeFactory cannot restore inline structured types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/14 15:31:00 UTC, 0 replies.
- [jira] (FLINK-38102) RestApiMetricsCollectorTest is unstable - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2025/07/14 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38104) FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/14 21:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/15 02:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38094) Introduce pyflink.__version__ - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 02:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38094) Introduce pyflink.__version__ - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 02:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/15 02:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/15 02:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/15 02:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/15 02:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 03:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 03:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/15 03:47:00 UTC, 2 replies.
- [PR] [FLINK-38105][python] Change NamespaceAggsHandleFunctionBase.get_accumulators to cpdef [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/07/15 03:52:18 UTC, 7 replies.
- Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 06:25:59 UTC, 0 replies.
- Re: [PR] [FLINK-37672] Bump protobuf-maven-plugin [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/15 06:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/15 07:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/15 07:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36870) Start scale down timer after initial scale up - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/07/15 08:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-37245] Prevent masking null values in BinaryRowData [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/07/15 08:39:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-34539) Tune JobManager memory - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/07/15 08:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/07/15 08:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-33773) Add fairness to scaling decisions - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/07/15 08:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-34151) Integrate Karpenter resource limits into cluster capacity check - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/07/15 08:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38101) Support SI Format for CPU resources - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/15 09:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2025/07/15 10:33:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-38092) Update japicmp configuration post 1.19.3 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/15 11:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38091) Update japicmp configuration post 1.20.2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/07/15 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38106) Job gets indefinitely stuck with "Job Not Found" events - posted by "Rasmus Bilgram (Jira)" <ji...@apache.org> on 2025/07/15 12:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/15 12:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/15 12:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38103) DataTypeFactory cannot restore inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/15 14:06:00 UTC, 0 replies.
- [PR] [Python] Support Event contains Row field be json serializable [flink-agents] - posted by "Kavishankarks (via GitHub)" <gi...@apache.org> on 2025/07/15 16:06:28 UTC, 0 replies.
- [PR] [Flink-26823] Adding Cassandra Table Source [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/15 16:56:45 UTC, 0 replies.
- Re: [I] [Feature] Optimize PythonFunction instantiation in `call_python_function` [flink-agents] - posted by "Kavishankarks (via GitHub)" <gi...@apache.org> on 2025/07/15 17:29:06 UTC, 0 replies.
- Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/15 18:13:29 UTC, 6 replies.
- [jira] [Updated] (FLINK-26823) Make Cassandra Source available for Flink SQL users - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/15 18:14:00 UTC, 0 replies.
- Re: [I] [Feature][api][java] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2025/07/15 19:50:11 UTC, 0 replies.
- Re: [I] [Feature][plan] Support converting between Java & Python Workflow Plans [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/16 01:28:43 UTC, 0 replies.
- Re: [I] [Feature][plan] Introduce Workflow, Event, Action & Callable in the Workflow Plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/16 01:28:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/16 01:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/16 01:56:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38107) JobMasterTest#testJobFailureWhenGracefulTaskExecutorTermination azure ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/16 01:57:00 UTC, 0 replies.
- [PR] [FLINK-38098][Runtime] Fix JobClientHeartbeatRequestBody deserialization error [flink] - posted by "shilei-ly (via GitHub)" <gi...@apache.org> on 2025/07/16 02:01:22 UTC, 3 replies.
- [jira] [Reopened] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/16 02:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/16 02:48:00 UTC, 0 replies.
- [I] [Tech Debt] [api][python] Support Event containing Row field can be json serializable [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/16 03:33:10 UTC, 0 replies.
- Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/16 03:43:43 UTC, 6 replies.
- [PR] [infra] add Min Zhou, Weiqing Yang and Alan Zhang as collaborators on Github [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/07/16 04:17:55 UTC, 1 replies.
- [PR] [FLINK-38044][runtime-web] update angular to v19 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/07/16 05:10:27 UTC, 3 replies.
- [D] Community Sync [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/07/16 05:37:45 UTC, 7 replies.
- [jira] [Closed] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/16 05:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-35704] Use ForkJoinPool in NonSplittingRecursiveEnumerator [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 06:30:52 UTC, 0 replies.
- Re: [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/16 06:30:56 UTC, 2 replies.
- [PR] [Feature][api][runtime] Support Short-Term Memory [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/07/16 07:58:47 UTC, 5 replies.
- [jira] [Created] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/16 08:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/16 08:44:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/16 08:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/16 09:04:00 UTC, 1 replies.
- [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/07/16 10:13:53 UTC, 13 replies.
- [jira] [Updated] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/16 10:14:00 UTC, 0 replies.
- [I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/16 11:15:26 UTC, 1 replies.
- [I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/16 11:15:54 UTC, 1 replies.
- [PR] [plan][runtime][python] Introduce Resource and Resource Provider in p… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/16 11:34:56 UTC, 2 replies.
- [PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents] - posted by "kitalkuyo-gita (via GitHub)" <gi...@apache.org> on 2025/07/16 14:00:25 UTC, 2 replies.
- [PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink] - posted by "vssakuru (via GitHub)" <gi...@apache.org> on 2025/07/16 14:54:44 UTC, 14 replies.
- [jira] [Created] (FLINK-38109) BlobServer isn't associated with the correct bind-host - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/07/16 22:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/07/16 22:27:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 02:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 02:03:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 02:03:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 02:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/07/17 03:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/07/17 03:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/07/17 03:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/07/17 06:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters - posted by "haiqingchen (Jira)" <ji...@apache.org> on 2025/07/17 06:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters - posted by "haiqingchen (Jira)" <ji...@apache.org> on 2025/07/17 06:18:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 06:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37990) [Umbrella] Test Flink Release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/17 06:21:00 UTC, 0 replies.
- Re: [PR] [FLINK-36465] Bump okhttp3 to 4.12.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 06:26:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/17 06:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/17 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service - posted by "yuan (Jira)" <ji...@apache.org> on 2025/07/17 08:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service - posted by "yuan (Jira)" <ji...@apache.org> on 2025/07/17 08:23:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1 - posted by "yude (Jira)" <ji...@apache.org> on 2025/07/17 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/17 08:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/17 08:41:00 UTC, 1 replies.
- [PR] [FLINK-38113][runtime] Rethrow fatal (including OOM) errors in Execution.deploy [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/07/17 08:56:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/17 08:57:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38114) Allow offloading of task restore - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/17 09:05:00 UTC, 0 replies.
- [PR] Chore/angular v20 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/07/17 09:10:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/17 09:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-38044][runtime-web] update angular to v20 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/07/17 09:14:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1 - posted by "yude (Jira)" <ji...@apache.org> on 2025/07/17 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38115) Synchronous the Python JDBC connector with the Java implementation - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/17 10:35:00 UTC, 0 replies.
- Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/17 11:01:08 UTC, 0 replies.
- Re: [PR] [hotfix][core] Replace the concating on strings with the placeholder in log lines [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/17 11:01:17 UTC, 0 replies.
- [PR] [FLINK-37914][table] Add built-in OBJECT_UPDATE function [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/07/17 11:50:25 UTC, 13 replies.
- [jira] [Updated] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/17 11:51:00 UTC, 2 replies.
- [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/07/17 11:55:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/07/17 14:41:00 UTC, 0 replies.
- [PR] [Python][Optimisation] Introduced caching mechanism to reuse existing PythonFunction instances for identical (module, qualname) pairs. [flink-agents] - posted by "Kavishankarks (via GitHub)" <gi...@apache.org> on 2025/07/17 17:21:03 UTC, 4 replies.
- [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2025/07/17 18:57:42 UTC, 11 replies.
- [PR] Bump on-headers and compression in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/07/17 21:19:26 UTC, 1 replies.
- [jira] [Created] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error - posted by "David Ballano (Jira)" <ji...@apache.org> on 2025/07/17 22:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38117) Add anonymous ContextResolvedModel - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/17 23:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38117) Add anonymous ContextResolvedModel - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/07/17 23:27:00 UTC, 0 replies.
- Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/18 00:04:55 UTC, 0 replies.
- [jira] [Created] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode - posted by "shilei-ly (Jira)" <ji...@apache.org> on 2025/07/18 01:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode - posted by "shilei-ly (Jira)" <ji...@apache.org> on 2025/07/18 01:33:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode - posted by "shilei-ly (Jira)" <ji...@apache.org> on 2025/07/18 01:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-37889] [table-planner] Add JoinToMultiJoinRule [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/07/18 05:54:34 UTC, 0 replies.
- [jira] [Created] (FLINK-38119) [Unstable test]IcebergWriterTest.testWriteWithAllSupportedTypes:344 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/18 05:55:00 UTC, 0 replies.
- [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink] - posted by "liyude-tw (via GitHub)" <gi...@apache.org> on 2025/07/18 06:22:44 UTC, 6 replies.
- [jira] [Updated] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/18 06:23:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2025/07/18 14:16:00 UTC, 0 replies.
- [PR] [FLINK-37973][table-planner] Add support for right joins to multijoin operator [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/07/18 18:10:05 UTC, 3 replies.
- [jira] [Updated] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/18 18:11:00 UTC, 0 replies.
- [PR] [FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set [flink] - posted by "rosakng (via GitHub)" <gi...@apache.org> on 2025/07/18 20:16:17 UTC, 9 replies.
- [PR] [hotfix]Fix kafka doc properties table error [flink] - posted by "zm999999 (via GitHub)" <gi...@apache.org> on 2025/07/19 02:24:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38013) [Release-2.1] Cross team testing - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38013) [Release-2.1] Cross team testing - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/19 02:32:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrate ProcessingTimeServiceSource from Source Function to Source V2 API in StreamSourceOperatorLatencyMetricsTest [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/19 09:36:36 UTC, 2 replies.
- [jira] [Updated] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/19 09:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 06:25:38 UTC, 1 replies.
- Re: [PR] [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/20 06:25:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37724) Add AsyncTableFunction as new UDF type - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/07/20 22:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38086) Make ChangelogNormalize reusable if possible - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/20 23:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38086) Make ChangelogNormalize reusable if possible - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/20 23:11:00 UTC, 0 replies.
- Re: [PR] [hotfix][docs]Fix kafka doc properties table error [flink] - posted by "zm999999 (via GitHub)" <gi...@apache.org> on 2025/07/21 05:10:15 UTC, 1 replies.
- Re: [PR] [hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/21 06:26:01 UTC, 1 replies.
- [jira] [Created] (FLINK-38121) Build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/21 06:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38121) Build python wheel on linux failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/21 06:35:00 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-38121) Build python wheel on linux failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/21 07:47:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38122) Creating structured types with no fully defining constructor results in wrong results - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/21 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38122) Creating structured types with no fully defining constructor results in wrong results - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/21 07:48:00 UTC, 0 replies.
- [PR] [FLINK-38121][python] Limit the version of pyarrow to <21.0.0 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/07/21 07:48:27 UTC, 5 replies.
- [jira] [Updated] (FLINK-38121) Build python wheel on linux failed - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/21 07:49:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38121) Build python wheel on linux failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/21 08:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-33548) Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/21 08:24:00 UTC, 0 replies.
- [PR] [FLINK-38111] [oceanbase]：Migrate OceanBase CDC Connector from LogProxy to Binlog Service. [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2025/07/21 08:26:43 UTC, 8 replies.
- [jira] [Commented] (FLINK-36787) In Flink SQL stream mode, joining a Kafka source with a JDBC dimension table caused a Yarn node to run out of memory (OOM). - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/07/21 08:41:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-36787) In Flink SQL stream mode, joining a Kafka source with a JDBC dimension table caused a Yarn node to run out of memory (OOM). - posted by "zhengyuan (Jira)" <ji...@apache.org> on 2025/07/21 09:22:00 UTC, 0 replies.
- [PR] [FLINK-38034] Added WriteAheadSinkTestBase to Cassandra Connector Repository [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/21 09:45:23 UTC, 4 replies.
- [jira] [Updated] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/21 09:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38034) raise back the visibility of WriteAheadSinkTestBase to public - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/21 09:52:00 UTC, 0 replies.
- [PR] [FLINK-38121] Ensure latest pip version before building Python wheels [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/07/21 09:56:53 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38042) Warn the user on full table scans - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/21 10:00:00 UTC, 0 replies.
- [D] Flink Agents Metrics Design [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/07/21 11:25:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-28648) Allow session deletion to block on any running job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/21 12:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37724) Add AsyncTableFunction as new UDF type - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/07/21 16:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35854) Upgrade Calcite version to 1.35.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/21 20:24:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35855) Upgrade Calcite version to 1.36.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/21 20:25:00 UTC, 0 replies.
- [PR] [hotfix][javadocs] Fix typo in the Javadoc for the load value in LoadSimulationPipeline [flink-kubernetes-operator] - posted by "kaygorodov (via GitHub)" <gi...@apache.org> on 2025/07/21 20:25:09 UTC, 2 replies.
- [jira] [Created] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:09:00 UTC, 0 replies.
- [PR] [FLINK-37988] Allows AsyncTableFunction to have empty results for left join [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/07/21 21:14:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-37988) Add left join support for AsyncTableFunction - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/21 21:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:16:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37988) Add left join support for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/07/21 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/21 21:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38121) Build python wheel on linux failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/07/22 00:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38082) User's async function timeout call may result in unexpected retries - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/07/22 01:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38082) User's async function timeout call may result in unexpected retries - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/07/22 01:40:00 UTC, 0 replies.
- Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink] - posted by "hejufang (via GitHub)" <gi...@apache.org> on 2025/07/22 03:10:27 UTC, 3 replies.
- [PR] [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/22 05:05:34 UTC, 2 replies.
- [PR] [FLINK-38010][release] Update dev-master point to 2.2 [flink-docker] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/22 05:53:58 UTC, 4 replies.
- [jira] [Updated] (FLINK-38010) [Release-2.1] Create a release branch - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/22 05:54:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38128) CLONE - Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38125) Finalize release 2.1.0 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38127) CLONE - Deploy artifacts to Maven Central Repository - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38126) CLONE - Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38126) CLONE - Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38129) CLONE - Publish the Dockerfiles for the new release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38128) CLONE - Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38126) CLONE - Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38127) CLONE - Deploy artifacts to Maven Central Repository - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38125) Finalize release 2.1.0 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38128) CLONE - Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38127) CLONE - Deploy artifacts to Maven Central Repository - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38128) Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38125) Finalize release 2.1.0 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:43:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38127) Deploy artifacts to Maven Central Repository - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:44:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38129) CLONE - Publish the Dockerfiles for the new release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38129) Publish the Dockerfiles for the new release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:44:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38126) Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38129) CLONE - Publish the Dockerfiles for the new release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38130) The python linux wheel package name is duplicated - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 07:51:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrate CoGroupJoinITCase new Source/Sink V2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/22 08:05:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-38130) The python linux wheel package name is duplicated - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/22 08:24:00 UTC, 4 replies.
- Re: [PR] [FLINK-23475][runtime][checkpoint] Supports repartition partly finished broacast states [flink] - posted by "xiangforever2014 (via GitHub)" <gi...@apache.org> on 2025/07/22 09:16:11 UTC, 0 replies.
- Re: [PR] [FLINK-37968] Bump Netty version to v4.1.122.Final [flink-connector-aws] - posted by "Neo2308 (via GitHub)" <gi...@apache.org> on 2025/07/22 09:25:19 UTC, 0 replies.
- [jira] [Created] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Renxiang Zhou (Jira)" <ji...@apache.org> on 2025/07/22 09:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Renxiang Zhou (Jira)" <ji...@apache.org> on 2025/07/22 09:46:00 UTC, 0 replies.
- [PR] [hotfix][runtime] Fix typo in methods/parameters naming for ResourceProfileInfo.java [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/07/22 10:31:47 UTC, 4 replies.
- Re: [PR] SQL Server CDC support - fixing the issues in the outstanding pull request by another author [flink-cdc] - posted by "arielmoraes (via GitHub)" <gi...@apache.org> on 2025/07/22 11:53:07 UTC, 0 replies.
- Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc] - posted by "arielmoraes (via GitHub)" <gi...@apache.org> on 2025/07/22 11:55:22 UTC, 0 replies.
- [jira] [Created] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/07/22 12:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/07/22 12:24:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38133) Unable to find checkpoint status analysis during Flink restart on k8s，jobmanager created by deployment， - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38133) Unable to find checkpoint status analysis during Flink restart on k8s，jobmanager created by deployment - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:42:00 UTC, 7 replies.
- [jira] [Updated] (FLINK-38133) Unable to find checkpoint status analysis during Flink jm pod restart on k8s，jobmanager created by deployment - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38133) Unable to find checkpoint status analysis during Flink jm pod restart on k8s，running mode is nativekubenetes,jobmanager created by deployment - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38133) Unable to find checkpoint info during Flink jm pod restart on k8s,running mode is nativekubenetes,jobmanager created by deployment - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38133) Unable to find checkpoint status analysis during Flink jm pod restart on k8s,running mode is nativekubenetes,jobmanager created by deployment - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:56:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED - posted by "jeremyMu (Jira)" <ji...@apache.org> on 2025/07/22 13:59:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/07/22 15:28:00 UTC, 0 replies.
- [PR] Change base image from jre-jammy to jre-noble for security improvements [flink-docker] - posted by "soapjam (via GitHub)" <gi...@apache.org> on 2025/07/22 15:50:20 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/07/22 16:14:00 UTC, 1 replies.
- [PR] [FLINK-38114][runtime] Allow asynchronous offloading of TaskRestore [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/07/22 16:51:52 UTC, 2 replies.
- [jira] [Updated] (FLINK-38114) Allow offloading of task restore - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/22 16:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38114) Allow offloading of task restore - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/22 16:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38114) Allow offloading of task restore to avoid pekko.framesize exceeded errors on task deploy - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/07/22 16:55:00 UTC, 2 replies.
- Re: [PR] [FLINK-37209][transform] Add built-in Qwen model for transform. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 00:05:22 UTC, 1 replies.
- [PR] Feature: [api][runtime] Introduce metric mechanism [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/07/23 00:06:04 UTC, 7 replies.
- [jira] [Closed] (FLINK-38130) The python linux wheel package name is duplicated - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/23 04:06:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Removed SourceFunction Dependency from YarnTestCacheJob. [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/23 04:06:29 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38130) The python linux wheel package name is duplicated - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/23 04:08:00 UTC, 0 replies.
- Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/23 06:26:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-38133) Unable to find checkpoint info during Flink jm pod restart on k8s,running mode is nativekubenetes,jobmanager created by deployment - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/07/23 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. - posted by "yangyu (Jira)" <ji...@apache.org> on 2025/07/23 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. - posted by "yangyu (Jira)" <ji...@apache.org> on 2025/07/23 07:24:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. - posted by "yangyu (Jira)" <ji...@apache.org> on 2025/07/23 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38135) Non-existent method for RAW type hashing - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/23 07:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38135) Non-existent method for RAW type hashing - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/07/23 07:34:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/23 08:11:00 UTC, 1 replies.
- [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/07/23 08:27:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-38135) Non-existent method for RAW type hashing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/23 08:28:00 UTC, 0 replies.
- [D] Prompt & Tool & ChatModel Design [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/23 08:48:26 UTC, 0 replies.
- [I] [Feature] [api] Introduce Prompt, Tool and ChatModel in Python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/23 08:59:43 UTC, 0 replies.
- [I] [Feature] [api] Introduce Prompt, Tool and ChatModel in java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/23 09:00:14 UTC, 0 replies.
- [PR] [FLINK-35855][table] Upgrade Calcite version to 1.36.0 [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/07/23 09:27:07 UTC, 4 replies.
- [jira] [Updated] (FLINK-35855) Upgrade Calcite version to 1.36.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/23 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38136) Add restore tests for PTFs - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/23 11:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38114) Allow offloading of task restore to avoid pekko.framesize exceeded errors on task deploy - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/07/23 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/23 12:23:00 UTC, 0 replies.
- [PR] Create Accepted [flink-cdc] - posted by "LESSSOUL3 (via GitHub)" <gi...@apache.org> on 2025/07/23 12:45:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/23 13:00:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/07/23 13:01:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/23 13:15:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38135) Non-existent method for RAW type hashing - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/07/23 15:38:00 UTC, 0 replies.
- [PR] [FLINK-38136][table] Add restore tests for PTFs [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/07/23 15:49:53 UTC, 3 replies.
- [jira] [Updated] (FLINK-38136) Add restore tests for PTFs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/23 15:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/23 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Voon Hou (Jira)" <ji...@apache.org> on 2025/07/23 19:02:00 UTC, 0 replies.
- [PR] [FLINK-38138] Fix OOB error in ColumnarArrayData [flink] - posted by "voonhous (via GitHub)" <gi...@apache.org> on 2025/07/23 19:13:06 UTC, 3 replies.
- [jira] [Updated] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/23 19:14:00 UTC, 0 replies.
- [PR] [FLINK-35855][table] Upgrade Calcite to 1.36.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/23 22:01:07 UTC, 18 replies.
- [jira] [Created] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/24 01:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/24 02:00:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/24 02:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/24 02:02:00 UTC, 0 replies.
- [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/07/24 02:37:25 UTC, 1 replies.
- [PR] [FLINK-32695] Migrated SimpleStringGenerator to DataGeneratorSource [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/24 03:30:15 UTC, 1 replies.
- Re: [PR] [FLINK-37783] Auto-disable buffer debloating for tiered shuffle. [flink] - posted by "SteNicholas (via GitHub)" <gi...@apache.org> on 2025/07/24 03:34:26 UTC, 1 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to DataGeneratorSource [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/07/24 03:35:45 UTC, 0 replies.
- [D] Asynchronous Execution for Flink Agents [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/07/24 03:39:16 UTC, 2 replies.
- [PR] [hotfix] Format code using tools/lint.sh [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/07/24 07:21:31 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/24 07:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38034) raise back the visibility of WriteAheadSinkTestBase to public - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/24 09:19:00 UTC, 0 replies.
- [PR] [WIP][API][Runtime] Support agent and action asynchronous execution [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/07/24 11:49:25 UTC, 0 replies.
- [PR] [api][python] Introduce Prompt, Tool and ChatModel in python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/24 12:17:27 UTC, 1 replies.
- [PR] Feature migrate to flink 2.0.0 [flink-training] - posted by "XenoAmess (via GitHub)" <gi...@apache.org> on 2025/07/24 13:22:16 UTC, 0 replies.
- [PR] [FLINK-38093][k8s] Bump Fabric8 version to 7.3.1 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/07/24 14:30:58 UTC, 4 replies.
- [jira] [Updated] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/24 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/07/24 21:42:00 UTC, 0 replies.
- [PR] [FLINK-38140] Changes AsyncScalarFunction config from buffer-capacity to max-concurrent-operations [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/07/24 22:00:15 UTC, 4 replies.
- [jira] [Updated] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/24 22:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-35546] Elasticsearch 8 connector fails fast for non-retryable bulk request items [flink-connector-elasticsearch] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/07/24 22:06:50 UTC, 0 replies.
- Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/07/24 23:22:35 UTC, 6 replies.
- Re: [PR] [FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 00:05:08 UTC, 1 replies.
- Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/07/25 00:28:51 UTC, 2 replies.
- [PR] [FLINK-38134][cdc-common] Cannot recognize DropColumnEvent in method … [flink-cdc] - posted by "tbpure (via GitHub)" <gi...@apache.org> on 2025/07/25 04:23:30 UTC, 4 replies.
- Re: [PR] [FLINK-34015][checkpoint] fix that passing ignore-unclaimed-state through dynamic props does not take effect [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 06:25:55 UTC, 0 replies.
- Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 06:25:59 UTC, 0 replies.
- Re: [PR] Added Confluent to Vendor Solutions section [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/25 06:26:01 UTC, 1 replies.
- [jira] [Created] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/25 07:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/25 07:03:00 UTC, 1 replies.
- [PR] [FLINK-38137][state] RocksDB and ForSt state backend are compatible with the case where the user value of the map state is null [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/07/25 07:47:05 UTC, 19 replies.
- [PR] FLINK-32695-ReactiveModeITCase-NewSource-Migration [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/25 08:15:48 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] ReactiveModeITCase-NewSource-Migration [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/25 08:17:21 UTC, 1 replies.
- [jira] [Created] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/07/25 11:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/07/25 11:18:00 UTC, 1 replies.
- [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/07/25 13:35:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/07/25 13:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/25 13:42:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/25 13:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/25 13:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/25 13:45:00 UTC, 2 replies.
- [PR] [FLINK-38143][python] Fix pyflink flat YAML based config support [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/07/25 14:28:51 UTC, 12 replies.
- [jira] [Commented] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/07/25 16:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-36958][pipeline-connector][kafka] Support csv/json/debezium-json/canal-json format options [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/26 00:05:06 UTC, 0 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/26 00:05:11 UTC, 0 replies.
- Re: [PR] [API][Runtime] Support agent and action asynchronous execution [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/07/26 02:21:09 UTC, 6 replies.
- Re: [PR] [FLINK-36443][table][test][bp-2.0] Improve flaky tests related to partition specs [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/26 06:25:42 UTC, 1 replies.
- Re: [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/26 06:25:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Renxiang Zhou (Jira)" <ji...@apache.org> on 2025/07/26 07:54:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/26 08:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38143) Pyflink flat YAML based config support is broken - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/07/26 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38144) Change log state backend is not compatible with the case where the user value of the map state is null - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/27 09:50:00 UTC, 0 replies.
- [PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink] - posted by "huleidada (via GitHub)" <gi...@apache.org> on 2025/07/27 10:15:25 UTC, 1 replies.
- [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/07/27 10:44:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-35746) Add logic to override observed config based on settings observed through REST API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/27 10:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/07/28 03:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/07/28 03:15:00 UTC, 0 replies.
- [PR] [api][java] react agent api [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/07/28 05:20:20 UTC, 1 replies.
- Re: [PR] [FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/28 06:26:07 UTC, 0 replies.
- Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/07/28 07:27:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/28 08:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37700) SQL parse exception when creating a view with PTF - posted by "juntaozhang (Jira)" <ji...@apache.org> on 2025/07/28 09:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/28 09:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35855) Upgrade Calcite version to 1.36.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/28 10:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35855) Upgrade Calcite version to 1.36.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/28 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38145) Fix ReflectiveDiffBuilder config comparison to properly handle deleted configuration entries - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/07/28 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38146) support config for create filesystem - posted by "jonasjc (Jira)" <ji...@apache.org> on 2025/07/28 10:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38145) Fix ReflectiveDiffBuilder config comparison to properly handle deleted configuration entries - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/07/28 10:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38145) Fix ReflectiveDiffBuilder config comparison to properly handle deleted configuration entries - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/07/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38146) support config for create filesystem - posted by "jonasjc (Jira)" <ji...@apache.org> on 2025/07/28 10:51:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38147) Add Flink 2.1 support to operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/28 11:31:00 UTC, 0 replies.
- [PR] [FLINK-38147] Add Flink 2.1 support [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/07/28 11:33:50 UTC, 0 replies.
- [jira] [Updated] (FLINK-38147) Add Flink 2.1 support to operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/28 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Michał Fijołek (Jira)" <ji...@apache.org> on 2025/07/28 11:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Michał Fijołek (Jira)" <ji...@apache.org> on 2025/07/28 11:54:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/28 11:56:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/28 12:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/28 12:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/28 12:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35856) Upgrade Calcite version to 1.37.0 - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/07/28 12:28:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/28 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38149) Convert COLUMN_LIST to DescriptorType - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/28 14:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38149) Convert COLUMN_LIST to DescriptorType - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/07/28 14:24:00 UTC, 3 replies.
- [PR] [FLINK-38149] Convert COLUMN_LIST to DescriptorType [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/07/28 14:29:04 UTC, 2 replies.
- [jira] [Created] (FLINK-38150) Fail in planning if window boundary is not numeric/interval_day_time - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/28 14:33:00 UTC, 0 replies.
- [PR] [FLINK-38150][table] Fail in planning if window boundary is not numeric/interval_day_time [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/28 15:07:41 UTC, 12 replies.
- [jira] [Updated] (FLINK-38150) Fail in planning if window boundary is not numeric/interval_day_time - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/28 15:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38149) Convert COLUMN_LIST to DescriptorType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/28 15:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38136) Add restore tests for PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/28 15:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38136) Add restore tests for PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/28 15:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/28 15:44:00 UTC, 0 replies.
- Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar] - posted by "vbabenkoru (via GitHub)" <gi...@apache.org> on 2025/07/28 20:06:27 UTC, 0 replies.
- [jira] [Created] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error - posted by "felixzh (Jira)" <ji...@apache.org> on 2025/07/29 02:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/07/29 02:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error - posted by "felixzh (Jira)" <ji...@apache.org> on 2025/07/29 02:58:00 UTC, 2 replies.
- [PR] [FLINK-38151] Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error [flink] - posted by "felixzh2020 (via GitHub)" <gi...@apache.org> on 2025/07/29 03:09:35 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38126) Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 04:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38126) Deploy Python artifacts to PyPI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 04:03:00 UTC, 0 replies.
- Re: [PR] Bump http-proxy-middleware and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/29 06:26:08 UTC, 0 replies.
- [PR] [FLINK-38129] Add GPG key for 2.1.0 release [flink-docker] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/29 06:41:22 UTC, 3 replies.
- [jira] [Commented] (FLINK-38128) Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 07:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38128) Create Git tag and mark version as released in Jira - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 07:16:00 UTC, 0 replies.
- [PR] [FLINK-38129][flink-docker] Update Dockerfiles for 2.1.0 release [flink-docker] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/29 07:28:57 UTC, 2 replies.
- [I] [Tech Debt] Pemja Bug Tracking [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/07/29 08:43:53 UTC, 0 replies.
- [PR] Update DefaultRestClientFactory.java [flink-connector-opensearch] - posted by "zzusp (via GitHub)" <gi...@apache.org> on 2025/07/29 08:58:10 UTC, 1 replies.
- [PR] [FLINK-32695] [Tests] CoordinatorEventsToStreamOperatorRecipientExact… [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/29 09:48:18 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase Migrated to Source V2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/29 09:51:48 UTC, 1 replies.
- [jira] [Created] (FLINK-38152) MySQL CDC docs some params are invalid - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/07/29 11:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38152) MySQL CDC scan.snapshot.fetch.size params is invalid - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/07/29 11:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38152) MySQL CDC docs some params are invalid - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/07/29 11:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38152) MySQL CDC scan.snapshot.fetch.size param is invalid - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/07/29 11:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38007) Prepare Flink 2.1 Release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 11:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 11:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38009) [Release-2.1] Select executing Release Manager - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 11:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38015) [Release-2.1] Review and update documentation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 11:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/29 11:28:00 UTC, 0 replies.
- [PR] [docs] Update mysql-cdc some param description [flink-cdc] - posted by "gong (via GitHub)" <gi...@apache.org> on 2025/07/29 11:37:58 UTC, 2 replies.
- [jira] [Created] (FLINK-38153) Documentation has an error - posted by "Bao Liu (Jira)" <ji...@apache.org> on 2025/07/29 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/29 13:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/07/29 14:00:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-34094) Document new AsyncScalarFunction - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/07/29 14:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/29 14:16:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/29 14:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/07/29 14:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/29 19:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/29 19:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38150) Fail in planning if window boundary is not numeric/interval_day_time - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/29 19:30:00 UTC, 0 replies.
- [PR] publish wheel for apache-flink-libraries [flink] - posted by "dimbleby (via GitHub)" <gi...@apache.org> on 2025/07/29 19:54:51 UTC, 1 replies.
- [jira] [Created] (FLINK-38155) Ability to read webhook keystore password from disk - posted by "Youssuf (Jira)" <ji...@apache.org> on 2025/07/29 21:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38156) Pipeline E2E tests are currently bound to fail. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/30 01:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38152) MySQL CDC scan.snapshot.fetch.size param is invalid - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/30 01:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2025/07/30 03:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38156) Pipeline E2E tests are currently bound to fail. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/30 03:47:00 UTC, 1 replies.
- [PR] [FLINK-38156][hotfix] Fix pipeline E2E tests. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/07/30 03:59:57 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38129) Publish the Dockerfiles for the new release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38127) Deploy artifacts to Maven Central Repository - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38125) Finalize release 2.1.0 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38015) [Release-2.1] Review and update documentation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/30 06:07:00 UTC, 0 replies.
- [PR] Update japicmp configuration for 2.1.0 [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/30 06:10:29 UTC, 4 replies.
- Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 06:26:06 UTC, 0 replies.
- Re: [PR] [hotfix] [docs] Fix flink-connector-kafka version in "How to use Maven.." doc of Flink master [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 06:26:09 UTC, 1 replies.
- Re: [PR] [FLINK-37579] Avoid duplicate generate ResourceProfile [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 06:26:13 UTC, 1 replies.
- Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/30 06:26:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35670) Support Postgres CDC Pipeline Source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/30 08:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37765) Idea import duplicate modules error. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/30 08:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/30 08:51:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job - posted by "Adrian Vasiliu (Jira)" <ji...@apache.org> on 2025/07/30 08:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/07/30 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/30 09:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/30 09:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/30 09:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/07/30 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38158) FLIP-484: Add custom metric variables to operators - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/07/30 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924 - posted by "David Kornel (Jira)" <ji...@apache.org> on 2025/07/30 09:26:00 UTC, 0 replies.
- [PR] [FLINK-38159] Update commons-lang3 dependency to 3.18.0 [flink-kubernetes-operator] - posted by "kornys (via GitHub)" <gi...@apache.org> on 2025/07/30 09:49:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/30 09:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924 - posted by "David Kornel (Jira)" <ji...@apache.org> on 2025/07/30 09:51:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/30 10:03:16 UTC, 1 replies.
- [PR] [Test][Do NOT MERGE] Test PR to check if the build fails [flink] - posted by "vssakuru (via GitHub)" <gi...@apache.org> on 2025/07/30 10:09:26 UTC, 1 replies.
- [PR] [runtime-web] chore: bump angular to v19 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/07/30 10:09:33 UTC, 2 replies.
- [jira] [Assigned] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/07/30 10:37:00 UTC, 0 replies.
- [PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/07/30 12:43:25 UTC, 6 replies.
- [jira] [Updated] (FLINK-38158) FLIP-484: Add custom metric variables to operators - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/30 12:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/30 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/30 12:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/07/30 13:05:00 UTC, 0 replies.
- [PR] [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters [flink] - posted by "kumar-mallikarjuna (via GitHub)" <gi...@apache.org> on 2025/07/30 13:17:36 UTC, 6 replies.
- [jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/07/30 13:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/30 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer - posted by "Jaydeep Karia (Jira)" <ji...@apache.org> on 2025/07/30 16:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer - posted by "Jaydeep Karia (Jira)" <ji...@apache.org> on 2025/07/30 16:17:00 UTC, 0 replies.
- [D] Flink Agents - Use Cases and Gap Analysis [flink-agents] - posted by "thefalc (via GitHub)" <gi...@apache.org> on 2025/07/30 16:19:12 UTC, 0 replies.
- [jira] [Created] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2025/07/30 16:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2025/07/30 16:47:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2025/07/30 16:48:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37714) KafkaTableITCase generates artifacts in main path - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/30 17:07:00 UTC, 0 replies.
- [PR] [hotfix] Set version to 5.0-SNAPSHOT [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/07/30 17:24:56 UTC, 3 replies.
- [jira] [Commented] (FLINK-30656) Provide more logs for schema compatibility check - posted by "Nick M (Jira)" <ji...@apache.org> on 2025/07/30 17:28:00 UTC, 0 replies.
- [PR] [hotfix] Set version to 4.0-SNAPSHOT [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/07/30 17:28:51 UTC, 1 replies.
- [PR] [hotfix] Set version to 3.4-SNAPSHOT [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/07/30 17:36:54 UTC, 0 replies.
- [PR] [hotfix] Backport Improvement to 4.0 preparing 4.0.1 release [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/07/30 17:50:05 UTC, 2 replies.
- [jira] [Closed] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/30 20:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38093) Update version of Fabric8 to 7.3.1 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/07/30 20:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/07/31 00:05:07 UTC, 0 replies.
- [PR] [hotfix] Fix security issues. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/07/31 01:40:59 UTC, 0 replies.
- [PR] Rebuild website [flink-web] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/07/31 02:54:24 UTC, 2 replies.
- [PR] [FLINK-38141][pipeline-connector/iceberg] Fix iceberg connector incorrect type mapping [flink-cdc] - posted by "doovvv (via GitHub)" <gi...@apache.org> on 2025/07/31 03:26:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/31 03:27:00 UTC, 0 replies.
- [PR] Hotfix Fix 2.1 announcement page via align markdown header [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/07/31 05:55:47 UTC, 1 replies.
- [jira] [Closed] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 06:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 06:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38164) MySQL connector supportLONG and LONG VARCHAR type - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/31 06:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38164) MySQL connector supportLONG and LONG VARCHAR type - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/07/31 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38165) Promote release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38167) CLONE - Apache mailing lists announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38170) CLONE - Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38174) CLONE - Remove outdated versions - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38168) CLONE - Other announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38172) CLONE - Update japicmp configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38173) CLONE - Update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38175) CLONE - Start End of Life discussion thread for now outdated Flink minor version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38169) CLONE - Updates the docs stable version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38166) CLONE - Merge website pull request - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38171) CLONE - Add 2.0 to PreviousDocs list - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38165) Promote release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38165) Promote release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:13:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38166) CLONE - Merge website pull request - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38167) Apache mailing lists announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:15:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38166) Merge website pull request - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38166) Merge website pull request - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38166) Merge website pull request - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38167) Apache mailing lists announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38167) Apache mailing lists announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38168) Other announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:17:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38168) Other announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38168) Other announcements - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38009) [Release-2.1] Select executing Release Manager - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38169) Updates the docs stable version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:19:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38169) CLONE - Updates the docs stable version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38170) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:20:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38169) Updates the docs stable version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:20:00 UTC, 0 replies.
- [PR] [FLINK-38170][release] Build 2.1 docs in GitHub Action and mark 2.1 as stable in docs [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/31 07:21:04 UTC, 4 replies.
- [jira] [Updated] (FLINK-38171) Add 2.1 to PreviousDocs list - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 07:28:00 UTC, 1 replies.
- [PR] Upgrade os-maven-plugin for RISC-V riscv64 support [flink] - posted by "gong-flying (via GitHub)" <gi...@apache.org> on 2025/07/31 07:40:32 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 07:41:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/07/31 07:41:00 UTC, 0 replies.
- [PR] [FLINK-38171][Docs] Add 2.1 to PreviousDocs list [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/31 07:47:37 UTC, 2 replies.
- [PR] [FLINK-32695] Moved TestSource to SourceV2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/07/31 08:08:15 UTC, 0 replies.
- [jira] [Created] (FLINK-38176) Release kafka connector 4.0.1 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/31 08:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38176) Release kafka connector 4.0.1 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/31 08:18:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38176) Release kafka connector 4.0.1 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/07/31 08:18:00 UTC, 0 replies.
- [PR] [FLINK-38176] Add Flink kafka connector 4.0.1 [flink-web] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/07/31 08:20:14 UTC, 0 replies.
- Re: [PR] [FLINK-32695] Moved TestSource in TypeFillTest to SourceV2 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/07/31 08:21:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-38172) Update japicmp configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38173) Update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38173) Update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38172) Update japicmp configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38174) Remove outdated versions - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38174) Remove outdated versions - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38175) CLONE - Start End of Life discussion thread for now outdated Flink minor version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38175) CLONE - Start End of Life discussion thread for now outdated Flink minor version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38175) Start End of Life discussion thread for now outdated Flink minor version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 09:10:00 UTC, 0 replies.
- [PR] [FLINK-38173][release] Generate reference data for state migration tests based on release-2.1.0 [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/07/31 09:19:12 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37844) Push down projections for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/31 10:42:00 UTC, 0 replies.
- [PR] [FLINK-37844][table] Add new ProjectMultiJoinTransposeRule [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/07/31 10:58:55 UTC, 11 replies.
- [jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/31 10:59:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/31 11:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/31 11:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38171) Add 2.1 to PreviousDocs list - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 11:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38171) Add 2.1 to PreviousDocs list - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 11:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38170) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 11:55:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38170) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/07/31 11:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35670) Support Postgres CDC Pipeline Source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/07/31 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/31 12:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/31 12:32:00 UTC, 1 replies.
- [PR] [FLINK-38177][table] ALTER TABLE .. MODIFY WATERMARK might reset current distribution [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/07/31 12:36:21 UTC, 4 replies.
- [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/07/31 17:24:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/07/31 17:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/31 17:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/07/31 17:46:00 UTC, 0 replies.