issues@flink.apache.org, 2025-10

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

- [PR] [DRAFT] [FLINK-24493] [flink-connector-base] Introduce DemultiplexingSink [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2025/10/01 00:05:28 UTC, 3 replies.
- [jira] [Updated] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/01 00:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/10/01 00:16:00 UTC, 0 replies.
- Re: [PR] [example][java] Add single agent example [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/01 00:51:44 UTC, 0 replies.
- Re: [PR] [example][java] Add multiple agent integration example [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/10/01 01:22:32 UTC, 2 replies.
- [jira] [Created] (FLINK-38467) Caused by: java.lang.ClassCastException - posted by "terrence (Jira)" <ji...@apache.org> on 2025/10/01 04:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/01 04:35:00 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. [flink-kubernetes-operator] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/10/01 05:16:40 UTC, 0 replies.
- Re: [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/01 06:12:28 UTC, 3 replies.
- Re: [PR] Update Dockerfiles for 1.20.3 release [flink-docker] - posted by "eric-nascimento-nubank (via GitHub)" <gi...@apache.org> on 2025/10/01 08:14:00 UTC, 1 replies.
- Re: [PR] [FLINK-38462] Introduce state backend type identifier [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/01 08:35:08 UTC, 9 replies.
- [jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:32:00 UTC, 10 replies.
- [jira] [Commented] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:36:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:37:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:38:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:44:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:47:00 UTC, 15 replies.
- [jira] [Commented] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 11:51:00 UTC, 3 replies.
- Re: [PR] [FLINK-38382][kafka] Support avro primitive types in Confluent Schema Registry binding [flink] - posted by "raphaelauv (via GitHub)" <gi...@apache.org> on 2025/10/01 11:51:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 12:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/01 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38468) Performance drops when the coalesce parameter includes functions - posted by "Jie Cheng (Jira)" <ji...@apache.org> on 2025/10/01 13:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions - posted by "Jie Cheng (Jira)" <ji...@apache.org> on 2025/10/01 13:11:00 UTC, 24 replies.
- Re: [PR] [FLINK-38211][table-planner] Refactor explain for MultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/10/01 13:14:55 UTC, 2 replies.
- Re: [PR] [FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19 [flink-connector-rabbitmq] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2025/10/01 13:17:58 UTC, 1 replies.
- Re: [PR] [FLINK-38454][core] Fix inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/10/01 13:50:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/10/01 13:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-36659] Bump flink version to 2.0.0 [flink-connector-jdbc] - posted by "raphaelauv (via GitHub)" <gi...@apache.org> on 2025/10/01 13:56:50 UTC, 1 replies.
- Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink] - posted by "ChengJie1053 (via GitHub)" <gi...@apache.org> on 2025/10/01 14:50:53 UTC, 1 replies.
- [PR] [example][java] Add ReAct agent example [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/10/01 22:55:19 UTC, 8 replies.
- [jira] [Updated] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow - posted by "Wren (Jira)" <ji...@apache.org> on 2025/10/02 00:12:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow - posted by "Wren (Jira)" <ji...@apache.org> on 2025/10/02 00:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/10/02 02:18:03 UTC, 3 replies.
- Re: [PR] [FLINK-16686][State] Set classloader for compaction filters [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/02 03:09:47 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-16686][State] Set classloader for compaction filters [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/02 03:35:40 UTC, 4 replies.
- [PR] [BP-2.0][FLINK-16686][State] Set classloader for compaction filters [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/02 03:40:58 UTC, 3 replies.
- Re: [PR] [FLINK-38272][runtime] Fix unstable BatchJobRecoveryTest [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/10/02 05:58:04 UTC, 1 replies.
- Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/02 06:46:14 UTC, 1 replies.
- [jira] [Created] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/10/02 06:54:00 UTC, 0 replies.
- [PR] [FLINK-38470] Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/10/02 07:14:37 UTC, 4 replies.
- [jira] [Updated] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/02 07:15:00 UTC, 0 replies.
- Re: [PR] Support skip verify ssl certificate and hostname [flink-connector-elasticsearch] - posted by "tosone (via GitHub)" <gi...@apache.org> on 2025/10/02 07:18:51 UTC, 0 replies.
- Re: [PR] [FLINK-38453] Add full splits to KafkaSourceEnumState [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/10/02 07:35:15 UTC, 10 replies.
- [jira] [Resolved] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/02 07:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38394) Upgrade Flink CDC to Flink 2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 07:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 07:57:00 UTC, 1 replies.
- Re: [PR] [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/02 07:59:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 08:00:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 08:02:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 08:58:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/02 09:27:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/02 09:32:15 UTC, 2 replies.
- [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3: FileNotFoundException - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/02 09:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/10/02 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/10/02 09:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31500) Move SqlAlterTableSchema conversion logic to AlterTableSchemaConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/02 10:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-38216][checkpoint][refactor] Split EndOfChannelStateEvent into EndOfInputChannelStateEvent and EndOfOutputChannelStateEvent [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/10/02 11:02:37 UTC, 3 replies.
- [PR] Announce Flink Agents 0.1.0 [flink-web] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/02 11:54:49 UTC, 12 replies.
- Re: [PR] [FLINK-38415][checkpoint] Disable auto compaction to prevent Index OutOfBounds Exception [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/02 11:55:50 UTC, 2 replies.
- [PR] [FLINK-38471] Add kafka sql connector as explicit dependency to kafka… [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/10/02 11:58:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/02 12:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/02 12:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/02 12:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/02 12:09:00 UTC, 0 replies.
- Re: [PR] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/10/02 14:42:45 UTC, 6 replies.
- [jira] [Reopened] (FLINK-38461) Introduce SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/02 15:01:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38462) Introduce state backend type identifier - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/02 15:01:00 UTC, 0 replies.
- [jira] (FLINK-38461) Introduce SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/02 15:01:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38461) Introduce SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/02 15:01:00 UTC, 2 replies.
- Re: [PR] [FLINK-38460][tests] Improve test coverage for SinkUpsertMaterializer [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/02 15:01:51 UTC, 12 replies.
- Re: [PR] [FLINK-38464] Introduce OrderedMultiSetState [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/02 16:06:08 UTC, 29 replies.
- [jira] [Closed] (FLINK-36467) Bump google-java-format and spotless - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/03 03:48:00 UTC, 0 replies.
- Re: [PR] [BP-2.1][FLINK-16686][State] Set classloader for compaction filters [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/03 05:01:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/03 05:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/03 05:05:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 - posted by "Hemanth Savasere (Jira)" <ji...@apache.org> on 2025/10/03 06:29:00 UTC, 1 replies.
- Re: [PR] [docs] Update the deployment introduction for Flink agents [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/03 08:18:06 UTC, 6 replies.
- [jira] [Closed] (FLINK-38211) Refactor explain for MultiJoin operator - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/10/03 08:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/03 11:41:23 UTC, 20 replies.
- Re: [PR] [docs] Update the configuration introduction for Flink agents [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/03 12:02:57 UTC, 5 replies.
- Re: [PR] [FLINK-38423][table-api] Add VECTOR_SEARCH connector API [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/03 12:59:15 UTC, 20 replies.
- [PR] [docs] Update flink agents overview doc. [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/03 13:57:38 UTC, 8 replies.
- [PR] [docs] Update workflow agent quickstart with overview and code walkthrough [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/03 14:19:01 UTC, 2 replies.
- Re: [D] Flink Agent Project Docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/03 14:19:51 UTC, 17 replies.
- [jira] [Created] (FLINK-38472) can not install apache-flink with python3.13 pemja==0.5.3 cannot be built - posted by "nicolas debeissat (Jira)" <ji...@apache.org> on 2025/10/03 15:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/03 17:06:00 UTC, 0 replies.
- [PR] [docs] Add docs for chat models and prompts [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/03 17:06:14 UTC, 1 replies.
- [I] [Bug] Add missing `close` function in MCPServer [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/03 17:27:05 UTC, 1 replies.
- [PR] [Bug] Add missing close function in MCPServer [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/03 17:38:26 UTC, 1 replies.
- Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/10/04 05:55:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-37984) Move Cassandra Sink to Sink V2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/04 05:56:00 UTC, 0 replies.
- [PR] [docs] Update the tool use docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/04 08:13:25 UTC, 6 replies.
- [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/10/04 09:23:48 UTC, 2 replies.
- [jira] [Updated] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/04 09:24:00 UTC, 0 replies.
- Re: [I] [Feature][docs] How to build an agent - Chat with LLM docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/04 12:15:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-38387) Disable spotless for java 25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/04 14:23:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38473) Upgrade Archunit to 1.4.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/04 14:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38473) Upgrade Archunit to 1.4.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/04 14:34:00 UTC, 1 replies.
- [PR] [FLINK-38473][build] Upgrade ArchUnit to 1.4.1 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/04 14:37:00 UTC, 2 replies.
- [PR] [FLINK-38387][build] Disable spotless for java 25 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/04 14:41:28 UTC, 5 replies.
- [jira] [Created] (FLINK-38474) Add java25-target profile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/04 14:44:00 UTC, 0 replies.
- [PR] [FLINK-38474][build] Add java25-target profile [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/04 14:47:26 UTC, 4 replies.
- [jira] [Updated] (FLINK-38474) Add java25-target profile - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/04 14:48:00 UTC, 0 replies.
- Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc] - posted by "durlabhjain (via GitHub)" <gi...@apache.org> on 2025/10/05 02:21:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38475) Fix community review CI script - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/05 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38475) Fix community review CI script - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/05 05:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38475) Fix community review CI script - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/05 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38476) Add FINISHED watermark status to support proper watermark aggregation - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/10/05 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38477) Add FINISHED watermark status to support proper watermark aggregation - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/10/05 07:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38477) Add FINISHED watermark status to support proper watermark aggregation - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/10/05 07:09:00 UTC, 4 replies.
- Re: [I] [Feature][docs] Get Started - Quickstart - Workflow Agent docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/05 09:29:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34836) [3.1][pipeline-connectors] Add Implementation of DataSink in Paimon. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/05 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/05 11:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/05 11:14:00 UTC, 0 replies.
- [PR] 38415/2.0 [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/05 11:34:59 UTC, 2 replies.
- [PR] 38415/2.1 [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/05 11:35:18 UTC, 2 replies.
- Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/10/05 11:41:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/05 11:42:00 UTC, 0 replies.
- Re: [I] [Feature][docs] Get Started - Overview docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/05 12:13:32 UTC, 0 replies.
- Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/10/05 12:24:09 UTC, 1 replies.
- [jira] [Closed] (FLINK-38476) Add FINISHED watermark status to support proper watermark aggregation - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/10/05 18:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/10/05 18:29:10 UTC, 23 replies.
- [jira] [Created] (FLINK-38479) Problems after upgrading the operator from 1.12.1 to 1.13.0 - posted by "fallenup (Jira)" <ji...@apache.org> on 2025/10/05 20:14:00 UTC, 0 replies.
- [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2025/10/05 20:40:43 UTC, 14 replies.
- [PR] [FLINK-38478][pipeline-connector][paimon] Generate a random commit user and store it in state. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/10/06 01:47:41 UTC, 3 replies.
- [jira] [Updated] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/06 01:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-38320] Upgrade Netty version to 4.2.4.Final [flink-shaded] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2025/10/06 07:29:58 UTC, 9 replies.
- [jira] [Created] (FLINK-38480) Continue on error and metadata column support for the HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/06 09:17:00 UTC, 0 replies.
- [PR] [docs] Update the monitoring introduction for Flink agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/06 10:53:49 UTC, 4 replies.
- [jira] [Commented] (FLINK-38479) Problems after upgrading the operator from 1.12.1 to 1.13.0 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/10/06 11:18:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/10/06 11:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38479) Problems after upgrading the operator from 1.12.1 to 1.13.0 - posted by "fallenup (Jira)" <ji...@apache.org> on 2025/10/06 12:02:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38481) Remove http header and responses from logging in HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/06 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38482) Knit in http connector into Flink docs - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/06 15:17:00 UTC, 0 replies.
- Re: [PR] [DOCS] List 3rd Party connector for NATS [flink] - posted by "scottf (via GitHub)" <gi...@apache.org> on 2025/10/06 15:27:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/06 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/06 17:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/06 17:34:00 UTC, 0 replies.
- [PR] [FLINK-38483][checkpoint] Fix the bug that Job cannot be recovered from unaligned checkpoint due to `Cannot get old subtasks from a descriptor that represents no state.` exception [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/06 17:39:23 UTC, 29 replies.
- [jira] [Updated] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/06 17:40:00 UTC, 1 replies.
- [PR] Support for Ollama Embedding models in Java. (ollama4j) [flink-agents] - posted by "mcolomerc (via GitHub)" <gi...@apache.org> on 2025/10/06 17:56:04 UTC, 32 replies.
- Re: [PR] [DRAFT][IN_PROGRESS][FLINK-37504] [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2025/10/06 18:04:37 UTC, 1 replies.
- [PR] [hotfix] Change the priority of various configuration setup methods [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/07 08:11:20 UTC, 1 replies.
- Re: [I] [Feature][docs] How to build an agent - Use a Tool docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/07 08:17:59 UTC, 0 replies.
- Re: [I] [Feature][docs] How to run an agent - Configuration docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/07 09:43:51 UTC, 0 replies.
- [jira] [Created] (FLINK-38484) community review github action stopped working - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/07 10:04:00 UTC, 0 replies.
- Re: [I] [Feature][docs] How to run an agent - Monitoring docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/07 11:16:12 UTC, 0 replies.
- [I] [Feature] Support FileEventLog to be stored by default in the FLINK_LOG_DIR directory [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/07 11:26:31 UTC, 0 replies.
- Re: [I] [Feature][docs] How to run an agent - Deployment docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/07 11:32:25 UTC, 0 replies.
- Re: [I] [Feature][docs] Flink-Agents MVP version project docs umbrella [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/07 12:05:59 UTC, 0 replies.
- [PR] [FLINK-38484][ci] Avoid long command line error [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/07 13:52:32 UTC, 0 replies.
- [jira] [Updated] (FLINK-38484) community review github action stopped working - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/07 13:53:00 UTC, 2 replies.
- Re: [PR] [FLINK-38484][ci] Avoid long command line error in community review github action script [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/07 13:53:44 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38484) community review github action stopped working - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/07 14:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38475) Fix community review CI script - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/07 14:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38475) Fix community review CI script - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/07 14:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38484) community review github action stopped working - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/07 14:41:00 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/10/08 02:49:21 UTC, 7 replies.
- [PR] [ci] Add release scripts [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/08 03:21:02 UTC, 2 replies.
- Re: [D] Community Sync [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/08 03:40:38 UTC, 2 replies.
- Re: [I] [Improvement] MVP user experience check [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/08 03:40:52 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/10/08 06:25:49 UTC, 1 replies.
- Re: [PR] [FLINK-37941][table] Exclude partitions in original table when merge strategy is EXCLUDING [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/08 06:25:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/08 06:26:00 UTC, 0 replies.
- [PR] Update version to 0.2-SNAPSHOT [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/08 07:10:39 UTC, 2 replies.
- [jira] [Created] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/10/08 07:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/10/08 09:18:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/08 11:07:00 UTC, 0 replies.
- [PR] [hotfix] Update NOTICE and licenses. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/08 11:35:39 UTC, 1 replies.
- [PR] [FLINK-38486] Harden shutdown by system UDFs [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/10/08 11:38:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/08 11:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-38486] Harden shutdown of system UDFs [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/10/08 11:44:22 UTC, 3 replies.
- [PR] [FLINK-38485] Fix/Improve tests [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/10/08 11:51:10 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/08 12:13:00 UTC, 3 replies.
- Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/08 12:42:31 UTC, 15 replies.
- [jira] [Closed] (FLINK-38480) Continue on error and metadata column support for the HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/08 21:21:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38482) Knit in http connector into Flink docs - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/08 21:24:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38480) Continue on error and metadata column support for the HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/08 21:24:00 UTC, 0 replies.
- [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/10/08 22:23:28 UTC, 14 replies.
- [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/08 22:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/09 00:04:09 UTC, 0 replies.
- Re: [PR] [FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/09 00:04:13 UTC, 1 replies.
- [PR] [FLINK-38404][core] Fix JobMasterTest due to data race [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/10/09 00:37:48 UTC, 10 replies.
- [jira] [Updated] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/09 00:38:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38487) Flink e2e ci failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/09 01:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38487) Flink e2e ci failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/09 01:16:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/09 01:18:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38457) Add AWS Glue Catalog Support - posted by "melin (Jira)" <ji...@apache.org> on 2025/10/09 01:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-30483) Make Avro format support for TIMESTAMP_LTZ - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/10/09 01:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "melin (via GitHub)" <gi...@apache.org> on 2025/10/09 01:53:08 UTC, 0 replies.
- [jira] [Created] (FLINK-38488) Use 'throws Exception' instead of try-catch-fail in tests in flink-tests - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/10/09 02:04:00 UTC, 0 replies.
- [PR] [FLINK-38488][tests] Use 'throws Exception' instead of try-catch-fail… [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/10/09 02:04:44 UTC, 8 replies.
- [jira] [Updated] (FLINK-38488) Use 'throws Exception' instead of try-catch-fail in tests in flink-tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/09 02:05:00 UTC, 5 replies.
- [PR] [BP-2.1][FLINK-38272][runtime] Fix unstable BatchJobRecoveryTest [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/10/09 02:11:48 UTC, 5 replies.
- [jira] [Created] (FLINK-38489) ChangelogNormalize may generate changelog mode without D - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/09 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38489) ChangelogNormalize can generate changelog mode without D - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/09 02:17:00 UTC, 2 replies.
- Re: [PR] [FLINK-38364][streaming-java] Implement async state version of ProcessingTimeoutTrigger [flink] - posted by "jiexray (via GitHub)" <gi...@apache.org> on 2025/10/09 02:32:47 UTC, 5 replies.
- Re: [PR] [BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/10/09 02:34:39 UTC, 10 replies.
- [PR] [doc] Add instructions for java in quickstart doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/09 04:49:41 UTC, 1 replies.
- Re: [PR] [hotfix] Avoid duplicate loop for configuration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/09 06:25:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-38487) Flink e2e ci failed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/09 06:26:00 UTC, 3 replies.
- [PR] [docs][release] Mark 0.1 as latest in docs [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/09 06:52:41 UTC, 1 replies.
- [PR] [doc] Add instructions for java in workflow agent and react agent doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/09 07:06:17 UTC, 1 replies.
- [jira] [Updated] (FLINK-38490) Update japicmp configuration post 1.20.3 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/10/09 07:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38490) Update japicmp configuration post 1.20.2 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/10/09 07:09:00 UTC, 0 replies.
- [PR] [FLINK-38490][release] Update japicmp configuration for 1.20.3 [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/09 07:13:32 UTC, 2 replies.
- [PR] [docs][release] Build 0.1 docs in GitHub Action [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/09 07:15:21 UTC, 1 replies.
- Re: [PR] Add Flink 1.20.3 release [flink-web] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/09 07:22:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38444) Join calculates upsert keys with null keys for left join - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/09 07:28:00 UTC, 0 replies.
- [PR] [FLINK-38487][build] bump vmImage version to ubuntu-24.04 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/09 07:36:18 UTC, 17 replies.
- [PR] [readme] Add user slack channel. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/09 07:43:37 UTC, 1 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "zhangshenghang (via GitHub)" <gi...@apache.org> on 2025/10/09 07:46:15 UTC, 4 replies.
- [jira] [Created] (FLINK-38491) flink-cdc connector-iceberg compaction parallelism error - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2025/10/09 07:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38480) Continue on error and metadata column support for the HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/09 08:10:00 UTC, 0 replies.
- [PR] [hotfix] Add 0.1 to Previous Docs [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/09 08:10:58 UTC, 1 replies.
- [PR] [doc] Update the index page. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/09 08:13:04 UTC, 1 replies.
- [PR] [FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism [flink-cdc] - posted by "fcfangcc (via GitHub)" <gi...@apache.org> on 2025/10/09 08:18:30 UTC, 2 replies.
- [jira] [Updated] (FLINK-38491) flink-cdc connector-iceberg compaction parallelism error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/09 08:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-38268] Fix incorrect serialization of VARIANT type FLOAT [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/10/09 08:23:03 UTC, 1 replies.
- [PR] [doc] Add instructions for java in Prompt, Tool and ChatModel doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/09 08:45:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/09 08:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/09 08:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/09 08:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/09 08:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38490) Update japicmp configuration post 1.20.3 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/10/09 09:09:00 UTC, 0 replies.
- [I] [Tech Debt] Use event-time in workflow quickstart example [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/09 09:27:54 UTC, 0 replies.
- [PR] [docs] Add links for Flink Agents [flink-web] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/09 09:41:13 UTC, 0 replies.
- Re: [PR] Add links for Flink Agents [flink-web] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/09 09:43:22 UTC, 1 replies.
- [PR] [hotfix] Backport docs commit [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/10/09 11:09:14 UTC, 2 replies.
- [jira] [Created] (FLINK-38492) Support Kubernetes Pod Template in SQL Gateway Application Mode Deployment - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/09 11:13:00 UTC, 0 replies.
- [PR] [hotfix][docs] Update overview pages for connector version [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/10/09 11:18:38 UTC, 1 replies.
- [PR] [doc] Add instructions for java in integration and operations docs. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/09 11:26:42 UTC, 3 replies.
- [jira] [Created] (FLINK-38493) Port Calcite's fix for LITERAL is lost while validation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/09 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38493) Port Calcite's fix for LITERAL is lost while validation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/09 12:04:00 UTC, 1 replies.
- [PR] [FLINK-38493][table] Port Calcite's fix for LITERAL is lost while validation [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/09 12:07:13 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/09 12:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/09 12:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-38493][table] Port Calcite's fix for LATERAL is lost while validation [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/09 13:14:04 UTC, 14 replies.
- [jira] [Updated] (FLINK-38493) Port Calcite's fix for LATERAL is lost while validation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/09 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38494) Add Chinese docs - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/09 14:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38494) Add Chinese docs for the HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/09 14:16:00 UTC, 3 replies.
- [PR] [FLINK-38480] Continue on error and metadata column support [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/09 14:21:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-38480) Continue on error and metadata column support for the HTTP connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/09 14:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-38465] Continue on error and metadata column support [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/09 14:23:45 UTC, 12 replies.
- [jira] [Updated] (FLINK-38465) Continue on error and metadata column support for HTTP connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/09 14:24:00 UTC, 3 replies.
- Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] - posted by "ys2843 (via GitHub)" <gi...@apache.org> on 2025/10/09 16:49:11 UTC, 0 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "maheepm-lyft (via GitHub)" <gi...@apache.org> on 2025/10/09 17:09:23 UTC, 8 replies.
- Re: [PR] Debugging the Blue/Green e2e tests [flink-kubernetes-operator] - posted by "maheepm-lyft (via GitHub)" <gi...@apache.org> on 2025/10/09 17:10:22 UTC, 0 replies.
- [PR] [Doc] Reorganize installation guide and simplify quickstart preparation sections [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/09 21:56:28 UTC, 6 replies.
- Re: [PR] [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/10 00:04:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-38492) Support Kubernetes Pod Template in SQL Gateway Application Mode Deployment - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/10 01:49:00 UTC, 0 replies.
- [I] [Feature] Add docs about per-action state consistency [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/10 02:50:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38487) Flink e2e ci failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/10 02:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38487) Flink e2e ci failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/10 03:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/10/10 03:16:00 UTC, 1 replies.
- [I] [Tech Debt] Support deserialize tool function load by user code class loader. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/10 03:56:16 UTC, 1 replies.
- [PR] [doc] Add Consistency Guarantee section in deployment documentation. [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/10 03:59:46 UTC, 3 replies.
- Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2025/10/10 06:14:34 UTC, 8 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/10/10 06:25:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/10 06:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/10 06:33:00 UTC, 0 replies.
- [PR] [doc] Simplify building step in README. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/10 06:55:47 UTC, 1 replies.
- [jira] [Created] (FLINK-38495) Introduce cache in delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/10 08:04:00 UTC, 0 replies.
- [PR] [FLINK-38495][table-runtime] Introduce cache in delta join operator [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/10 08:12:45 UTC, 27 replies.
- [jira] [Updated] (FLINK-38495) Introduce cache in delta join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/10 08:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38487) Flink e2e ci failed - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/10 08:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context [flink] - posted by "xiangyuf (via GitHub)" <gi...@apache.org> on 2025/10/10 09:04:07 UTC, 8 replies.
- Re: [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2025/10/10 09:15:00 UTC, 0 replies.
- Re: [PR] [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/10 09:18:23 UTC, 1 replies.
- [PR] [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport [flink] - posted by "huwh (via GitHub)" <gi...@apache.org> on 2025/10/10 10:35:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/10 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38496) Icerberg yaml sink need extra hadoop jar - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/10 11:32:00 UTC, 0 replies.
- [PR] [FLINK-38225] Sets proper precondition to ensure that GCS operations are retriable [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2025/10/10 11:39:49 UTC, 4 replies.
- [jira] [Updated] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/10 11:40:00 UTC, 0 replies.
- [PR] [FLINK-38496][docs] Icerberg yaml sink need extra hadoop jar. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/10/10 11:45:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-38496) Icerberg yaml sink need extra hadoop jar - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/10 11:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38387) Disable spotless for java 25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 15:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38387) Disable spotless for java 25 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 15:04:00 UTC, 0 replies.
- [PR] Bump io.netty:netty-codec-http from 4.1.108.Final to 4.1.127.Final-redhat-00001 in /flink-kubernetes [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/10/10 15:04:06 UTC, 1 replies.
- Re: [PR] [FLINK-37827][table] Fix use `SHOW CREATE TABLE` for MATERIALIZED_TABLE [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/10 16:52:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38474) Add java25-target profile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 18:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38474) Add java25-target profile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 18:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38493) Port Calcite's fix for LATERAL is lost while validation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 18:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38493) Port Calcite's fix for LATERAL is lost while validation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/10 18:37:00 UTC, 0 replies.
- [PR] [doc] Reorganize installation guide and simplify quickstart preparation sections [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/10 18:39:07 UTC, 2 replies.
- [PR] [hotfix] improve build.sh script [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/10 22:08:34 UTC, 1 replies.
- Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/11 00:04:12 UTC, 2 replies.
- [PR] [BP][FLINK-38496][docs] Iceberg yaml sink need extra Hadoop jar. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/10/11 01:56:56 UTC, 1 replies.
- [PR] [BP-1.20][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/10/11 02:00:11 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37217) In `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/11 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38497) FLIP-535:Introduce RateLimiter to Source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/11 02:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38488) Use 'throws Exception' instead of try-catch-fail in tests in flink-tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/11 03:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/11 05:53:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38498) JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/11 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/10/11 07:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38498) JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/11 07:53:00 UTC, 0 replies.
- [PR] [FLINK-38499][runtime] Limit max sleep time in Curator for Zookeeper HA [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/10/11 07:56:43 UTC, 6 replies.
- [jira] [Updated] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/11 07:57:00 UTC, 4 replies.
- [jira] [Resolved] (FLINK-38473) Upgrade Archunit to 1.4.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/11 08:14:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/11 08:14:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38473) Upgrade Archunit to 1.4.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/11 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2025/10/11 08:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2025/10/11 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38501) Tests crashed for Flink Runtime in test_cron_azure core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/11 09:17:00 UTC, 0 replies.
- [PR] Upgrade os-maven-plugin to 1.7.1 for RISC-V SG2044 support [flink-benchmarks] - posted by "Dayuxiaoshui (via GitHub)" <gi...@apache.org> on 2025/10/11 09:17:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/10/11 10:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/10/11 10:10:00 UTC, 0 replies.
- [PR] [hotfix] Tracks the number of pending manual compactions. [flink] - posted by "littleeleventhwolf (via GitHub)" <gi...@apache.org> on 2025/10/11 14:36:01 UTC, 6 replies.
- [jira] [Created] (FLINK-38502) A number of Hadoop related tests failing with UnsupportedOperationException: getSubject is not supported - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/11 18:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/12 00:05:06 UTC, 0 replies.
- Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2025/10/12 05:29:41 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/10/12 12:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/10/12 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/12 17:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/12 17:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/12 17:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/12 17:42:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/12 20:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/12 20:20:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38501) Tests crashed for Flink Runtime in test_cron_azure core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/13 01:43:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38504) Add restore test for delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/13 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/13 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38505) RegionToRestartInStreamingJobBenchmarkTest failed in test_cron_jdk21 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/13 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/13 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/13 02:18:00 UTC, 0 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/10/13 06:26:00 UTC, 5 replies.
- Re: [PR] FLINK-37953: Add OBF password obfuscation support for SSL configurations [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/13 06:26:03 UTC, 1 replies.
- [PR] [example] Use event time in multiple agent workflow example [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/13 06:35:19 UTC, 2 replies.
- [jira] [Created] (FLINK-38508) Fix can not using python udf in SQL if decorator uses string as input or output types - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/13 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38508) Fix can not use python udf in SQL if decorator uses string as input or output types - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/13 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38508) Allow string type specifications in Python UDF decorator for SQL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/13 07:20:00 UTC, 1 replies.
- [PR] [FLINK-38508][python] Allow string type specifications in Python UDF … [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/13 07:31:25 UTC, 11 replies.
- [jira] [Created] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage - posted by "Royston Tauro (Jira)" <ji...@apache.org> on 2025/10/13 07:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/13 07:59:00 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage - posted by "Royston Tauro (Jira)" <ji...@apache.org> on 2025/10/13 08:19:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38510) Remove targetColumns in SinkReuser - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/10/13 09:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/13 09:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/13 09:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/13 09:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink] - posted by "zhougit86 (via GitHub)" <gi...@apache.org> on 2025/10/13 10:04:01 UTC, 0 replies.
- [I] [Bug] ReActAgent.stopAction()output 未对json md 兜底处理 [flink-agents] - posted by "Ljj09082 (via GitHub)" <gi...@apache.org> on 2025/10/13 10:40:10 UTC, 3 replies.
- Re: [PR] [FLINK-38339][runtime] Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history. [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/10/13 11:10:43 UTC, 0 replies.
- [jira] [Closed] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/13 11:14:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/13 11:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/13 11:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/13 11:29:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38190) Support async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/13 11:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/10/13 11:53:00 UTC, 0 replies.
- [PR] [FLINK-38510][table-planner] Remove the targetColumns from the digest generation of SinkReuser [flink] - posted by "xiangyuf (via GitHub)" <gi...@apache.org> on 2025/10/13 15:02:08 UTC, 1 replies.
- [jira] [Updated] (FLINK-38510) Remove targetColumns in SinkReuser - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/13 15:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38510) Remove targetColumns from the digest generation of SinkReuser - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/10/13 15:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-38510][table-planner] Remove targetColumns from the digest generation of SinkReuser [flink] - posted by "xiangyuf (via GitHub)" <gi...@apache.org> on 2025/10/13 15:28:37 UTC, 5 replies.
- [PR] [FLINK-38104][table] add table api support for model ml_predict [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/10/13 22:04:19 UTC, 3 replies.
- [jira] [Updated] (FLINK-38104) FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/13 22:05:00 UTC, 0 replies.
- [PR] JET-2302 Keep version number in sync w/ manual deployment [flink-statefun] - posted by "kellinwood (via GitHub)" <gi...@apache.org> on 2025/10/13 23:46:30 UTC, 1 replies.
- [jira] [Created] (FLINK-38511) Join that consumes cdc record without delete can be converted to delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/14 03:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38511) Join that consumes cdc record without UB and D can be converted to delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/14 03:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38511) Join that consumes cdc source without delete may be converted to delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/14 03:11:00 UTC, 1 replies.
- [PR] [FLINK-38511][table] Join that consumes cdc source without delete may be converted to delta join [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/14 03:19:53 UTC, 13 replies.
- [jira] [Created] (FLINK-38512) Postgres YAML CDC support database name with middlescore - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/14 03:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38423) Add vector search connector API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/14 06:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38423) Add vector search connector API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/14 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/14 07:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/14 07:38:00 UTC, 2 replies.
- [PR] [FLINK-38513][python]Fix pandas 2.3+ cp39 issue [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/14 07:58:37 UTC, 16 replies.
- [jira] [Updated] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/14 08:01:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/14 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38515) [flink-avro-confluent-registry] Implement OAuth2 mechanism for the Schema Registry authentication - posted by "Sonya Parau (Jira)" <ji...@apache.org> on 2025/10/14 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38516) Add Configuration Option to Enable Read-Only Mode for Flink SQL Gateway - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/10/14 08:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38515) [flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication - posted by "Sonya Parau (Jira)" <ji...@apache.org> on 2025/10/14 08:26:00 UTC, 5 replies.
- [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] - posted by "sonyaparau (via GitHub)" <gi...@apache.org> on 2025/10/14 08:55:22 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/14 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2025/10/14 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38518) RestoreTestBase should deduplicate data based on pk rather than simply concatenating expectedBeforeRestore and expectedAfterRestore - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/14 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38519) Custom Message Keys with PyFlink Kafka Sink - posted by "Sebastian YEPES FERNANDEZ (Jira)" <ji...@apache.org> on 2025/10/14 09:42:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/14 09:57:26 UTC, 0 replies.
- Re: [PR] [BP-2.1][FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/14 10:07:37 UTC, 0 replies.
- [jira] [Created] (FLINK-38520) Postgres YAML CDC support array with null element - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/14 10:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/14 10:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/14 10:10:00 UTC, 0 replies.
- [PR] bump josdk to version 5.1.4 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/10/14 11:16:38 UTC, 0 replies.
- Re: [PR] [FLINK-38424][planner] Support to parse VECTOR_SEARCH function [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/14 11:29:25 UTC, 9 replies.
- [jira] [Created] (FLINK-38521) Update Kubernetes Operator to Java Operator SDK v5.1.4 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/10/14 11:30:00 UTC, 0 replies.
- [PR] [FLINK-38504][table] Add restore tests for delta join [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/14 11:37:28 UTC, 8 replies.
- [jira] [Updated] (FLINK-38504) Add restore test for delta join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/14 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38516) Add Configuration Option to Enable Read-Only Mode for Flink SQL Gateway - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/10/14 11:42:00 UTC, 4 replies.
- [PR] [FLINK-38516][Table SQL/Gateway] Add config for read-only sql gateway [flink] - posted by "rosakng (via GitHub)" <gi...@apache.org> on 2025/10/14 11:52:06 UTC, 6 replies.
- [jira] [Commented] (FLINK-21488) Jdbc XA sink - XID generation conflicts between jobs - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/10/14 12:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-21488) Jdbc XA sink - XID generation conflicts between jobs - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/10/14 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38516) Add configuration option to enable read-only mode for Flink SQL Gateway - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/10/14 12:12:00 UTC, 0 replies.
- [PR] [FLINK-38403] Stabilize UnalignedCheckpoint ITs [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/10/14 12:34:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/14 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. - posted by "John Watson (Jira)" <ji...@apache.org> on 2025/10/14 12:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. - posted by "John Watson (Jira)" <ji...@apache.org> on 2025/10/14 12:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38460) Improve test coverage for SinkUpsertMaterializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/14 12:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. - posted by "John Watson (Jira)" <ji...@apache.org> on 2025/10/14 12:53:00 UTC, 1 replies.
- [PR] [FLINK-38522][cdc connector mysql] use ssl for BinaryLogClient when searching for binlog offset for starting mysql cdc from timestamp [flink-cdc] - posted by "watsonjo737 (via GitHub)" <gi...@apache.org> on 2025/10/14 13:19:43 UTC, 10 replies.
- [jira] [Updated] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for database connections which require SSL. - posted by "John Watson (Jira)" <ji...@apache.org> on 2025/10/14 14:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/14 18:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38513) Github workflow of building python wheels on linux fails - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/10/14 18:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38320) Upgrade Netty version to 4.2.4.Final - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/14 18:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38523) Upgrade Pekko to 1.2.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/14 18:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38523) Upgrade Pekko to 1.2.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/14 18:55:00 UTC, 0 replies.
- [PR] Kafka to iceberg ingestion using dynamic iceberg sink blog post [flink-web] - posted by "swapna267 (via GitHub)" <gi...@apache.org> on 2025/10/14 20:03:33 UTC, 0 replies.
- Re: [PR] [FLINK-33100] Implement YarnJobListFetcher [flink-kubernetes-operator] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/14 20:21:51 UTC, 0 replies.
- Re: [PR] [FLINK-38435][table] Refactor codegen and runner for MLPredict and Lo… [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/10/14 21:01:20 UTC, 8 replies.
- [jira] [Commented] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" - posted by "Sergio Chong (Jira)" <ji...@apache.org> on 2025/10/14 22:26:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS - posted by "Ammar Master (Jira)" <ji...@apache.org> on 2025/10/14 23:39:00 UTC, 0 replies.
- Re: [PR] [hotfix] remove test scope dependency commons-codec in parent pom [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/15 00:05:05 UTC, 1 replies.
- Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/15 00:05:10 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-38060][ci] Fix github action failed to build python wheel on linux [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/15 03:15:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/15 03:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37546) KryoSerializer breaks without Twitter Chill library - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/15 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38524) Can not use python udtf with literal input - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38525) Python udf doesn't handle TIMESTAMP_LTZ correctly - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38526) Pemja convert sql ARRAY object to Tuple - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38524) Can not use python udtf with literal input - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38525) Python udf doesn't handle TIMESTAMP_LTZ correctly - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38526) Pemja convert sql ARRAY object to Tuple - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38464) Introduce OrderedMultiSetState (view) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/15 06:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 06:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38525) Python udf doesn't handle TIMESTAMP_LTZ correctly - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/15 06:57:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38526) Pemja convert sql ARRAY object to Tuple - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/15 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38527) Upgrade Netty version to 4.1.127.Final for Flink LTS 1.20 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/15 06:59:00 UTC, 0 replies.
- [PR] [FLINK-38425][table] Add rule to convert correlate node to vector search physical node [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/15 07:51:04 UTC, 6 replies.
- [jira] [Updated] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/15 07:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38320) Upgrade Netty version to 4.2.4.Final - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/15 08:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/15 08:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/15 08:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/15 08:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38060) Github action build python wheel on linux failed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/15 09:14:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38060) Github action build python wheel on linux failed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/15 09:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38426) Introduce sync vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 09:32:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38426) Introduce sync vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38528) Introduce async vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/15 09:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37487) Merge website pull request - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/15 09:54:00 UTC, 0 replies.
- [PR] [FLINK-38426][table] Introduce sync vector search operator [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/15 12:23:57 UTC, 6 replies.
- [PR] Add Flink 2.1.1 release [flink-web] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/15 14:56:17 UTC, 6 replies.
- [jira] [Created] (FLINK-38529) Silent record dropping when exceeding Kafka max.request.size - posted by "Barak Ben-Nathan (Jira)" <ji...@apache.org> on 2025/10/15 14:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/16 00:04:17 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38528) Introduce async vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 01:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 01:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38530) create python version of Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/10/16 02:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38530) create python version of Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/10/16 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/10/16 02:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38508) Allow string type specifications in Python UDF decorator for SQL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38508) Allow string type specifications in Python UDF decorator for SQL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38508) Allow string type specifications in Python UDF decorator for SQL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:14:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 03:17:00 UTC, 0 replies.
- [PR] [FLINK-38528][table] Introduce async vector search operator [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/16 07:34:04 UTC, 4 replies.
- [jira] [Updated] (FLINK-38528) Introduce async vector search operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/16 07:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38427) Support to serde vector search execnode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 08:12:00 UTC, 0 replies.
- [PR] [FLINK-38427][table] Support to serde VECTOR_SEARCH exec node [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/16 08:32:36 UTC, 4 replies.
- [jira] [Updated] (FLINK-38427) Support to serde vector search execnode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/16 08:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38430) Support runtime config for VECTOR_SEARCH - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/16 08:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-38461] Introduce SinkUpsertMaterializerV2 [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/10/16 09:44:18 UTC, 30 replies.
- [jira] [Updated] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/16 13:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/16 13:21:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/16 15:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38527) Upgrade Netty version to 4.1.128.Final for Flink LTS 1.20 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/10/16 17:47:00 UTC, 1 replies.
- [PR] [FLINK-38527] Upgrade Netty version to 4.1.128.Final [flink-shaded] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/10/16 17:58:24 UTC, 3 replies.
- Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/17 00:04:16 UTC, 0 replies.
- Re: [PR] [FLINK-38279] Add SnapshotPendingSplitsState to MySQL checkpoint stat… [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/10/17 01:56:52 UTC, 1 replies.
- [PR] Add Flink 2.0.1 release [flink-web] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/17 05:49:36 UTC, 6 replies.
- [PR] [hotfix] Correcting improper uses of the Pemja [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/17 07:10:27 UTC, 2 replies.
- Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/17 07:42:21 UTC, 1 replies.
- [I] [Bug] Python code under e2e_test cannot import the mcp module [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/17 08:03:58 UTC, 0 replies.
- [PR] [runtime] Execute action within user code class loader context. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/17 09:43:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-37436) flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 17:59:00 UTC, 1 replies.
- Re: [PR] [FLINK-37436] Fix that flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/17 18:05:17 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37436) flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 18:06:00 UTC, 0 replies.
- Re: [PR] Fix CI and upgrade to use Flink 1.18.1 [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/17 18:07:31 UTC, 1 replies.
- Re: [PR] [FLINK-35477],[FLINK-37299] Solve the problem that when not starting from the Checkpoint (CK), the cursor is always reset to the set initial cursor position. [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/17 18:13:43 UTC, 0 replies.
- Re: [PR] [FLINK-37299][Connector/Pulsar] Flink stateless startup cannot contin… [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/17 18:16:50 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37299) Flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 18:18:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-37299) Flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 18:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37299) Flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 18:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35477) Pulsar connector resets existing subscription - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/17 18:23:00 UTC, 1 replies.
- Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/17 18:53:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/10/18 08:56:00 UTC, 0 replies.
- [I] [Feature][integration][java] Support explicit tool call handling in OllamaChatModel [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/10/18 15:45:49 UTC, 1 replies.
- [PR] [Feature][Integrations][Java] Support explicit tool call handling in OllamaChatModel [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/10/18 16:00:54 UTC, 5 replies.
- [PR] [FLINK-33392][docs] Add the documentation pages for balanced tasks scheduling. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/18 17:09:50 UTC, 12 replies.
- [jira] [Updated] (FLINK-33392) Add the documentation page for balanced tasks scheduling - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/18 17:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-37630] Support flink cdc pipeline Yarn session mode [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/19 00:05:33 UTC, 0 replies.
- Re: [PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/19 06:25:43 UTC, 1 replies.
- [jira] [Created] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same - posted by "sherhomhuang (Jira)" <ji...@apache.org> on 2025/10/19 06:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same which cause loss data when restore from gtid . - posted by "sherhomhuang (Jira)" <ji...@apache.org> on 2025/10/19 07:01:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same, which may cause loss data when restore from gtid . - posted by "sherhomhuang (Jira)" <ji...@apache.org> on 2025/10/19 07:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same, which may cause loss data when restored from gtid . - posted by "sherhomhuang (Jira)" <ji...@apache.org> on 2025/10/19 07:07:00 UTC, 22 replies.
- [jira] [Updated] (FLINK-38529) Silent record dropping when exceeding Kafka max.request.size - posted by "Barak Ben-Nathan (Jira)" <ji...@apache.org> on 2025/10/19 07:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same, which may cause loss data when restored from gtid . - posted by "sherhomhuang (Jira)" <ji...@apache.org> on 2025/10/19 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/10/19 16:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 00:05:24 UTC, 1 replies.
- Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 00:05:28 UTC, 1 replies.
- [jira] [Closed] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 02:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33388) Support tasks balancing at TM level for Default Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/20 02:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 02:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 02:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33388) Support tasks balancing at TM level for Default Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/20 02:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33387) Introduce the abstraction and the interface about loading - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/20 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 02:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 02:31:00 UTC, 7 replies.
- [jira] [Resolved] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/20 02:32:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/20 02:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/10/20 02:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 02:33:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 02:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/20 04:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/20 04:05:00 UTC, 0 replies.
- [PR] Config [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/20 05:54:24 UTC, 1 replies.
- [PR] [hotfix] PulsarSourceEnumerator class code format violations. [flink-connector-pulsar] - posted by "zhuangchong (via GitHub)" <gi...@apache.org> on 2025/10/20 06:08:39 UTC, 1 replies.
- Re: [PR] Bump commons-beanutils:commons-beanutils from 1.8.3 to 1.10.1.redhat-00001 in /flink-yarn [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 06:26:07 UTC, 0 replies.
- Re: [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-filesystems/flink-s3-fs-presto [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 06:26:09 UTC, 0 replies.
- Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 06:26:11 UTC, 0 replies.
- Re: [PR] [FLINK-37854][table] Support DATE_FORMAT with zone [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 06:26:15 UTC, 1 replies.
- Re: [PR] [FLINK-37988] Allows AsyncTableFunction to have empty results for left join [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/20 06:26:19 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38428) Support to call vector search with literal value - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/20 06:44:00 UTC, 0 replies.
- [PR] [FLINK-38428][table] Support to run vector search with constant value [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/20 06:56:39 UTC, 14 replies.
- [jira] [Updated] (FLINK-38428) Support to call vector search with literal value - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/20 06:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38529) Silent record dropping when exceeding Kafka max.request.size - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/10/20 07:00:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38535) CheckpointIntervalDuringBacklogITCase failed in test_cron_adaptive_scheduler tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/20 07:34:00 UTC, 0 replies.
- [PR] F38461 rnd [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/20 07:57:58 UTC, 4 replies.
- [jira] [Created] (FLINK-38537) Fix the bug in StatsSummaryDto#equals method - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 08:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38537) Fix the bug in StatsSummaryDto#equals method - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 08:02:00 UTC, 2 replies.
- [PR] [FLINK-38532][table][FLIP-551] Make FRESHNESS Optional for Materialized Tables [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/10/20 08:02:43 UTC, 1 replies.
- [jira] [Updated] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/20 08:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38537) Fix the bug in StatsSummaryDto#equals method - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 08:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-38532][table][FLIP-551] Make `FRESHNESS` Optional for Materialized Tables [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/20 08:12:45 UTC, 25 replies.
- Re: [PR] [FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2025/10/20 08:54:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-38537) Fix the bug that can't compare correctly Double.NaN related attributes in StatsSummaryDto#equals method - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 09:09:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38537) Fix the bug that can't compare Double.NaN related attributes in StatsSummaryDto#equals method - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/10/20 09:09:00 UTC, 0 replies.
- [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/20 09:55:28 UTC, 1 replies.
- [jira] [Created] (FLINK-38538) Flink Autoscaler: Need Option to Autoscale Based Primarily (or Solely) on Busy Metric, Not Output Ratio - posted by "Varun (Jira)" <ji...@apache.org> on 2025/10/20 11:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38538) Flink Autoscaler: Need Option to Autoscale Based Primarily (or Solely) on Busy Metric, Not Output Ratio - posted by "Varun (Jira)" <ji...@apache.org> on 2025/10/20 11:32:00 UTC, 4 replies.
- Re: [PR] [FLINK-38510][table-planner] Remove targetColumns from the digest generation in SinkReuser [flink] - posted by "xiangyuf (via GitHub)" <gi...@apache.org> on 2025/10/20 11:32:26 UTC, 3 replies.
- [I] [Feature] [flink-agents] - posted by "tsaiggo (via GitHub)" <gi...@apache.org> on 2025/10/20 15:34:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table - posted by "Diljeet Singh (Jira)" <ji...@apache.org> on 2025/10/20 18:36:00 UTC, 1 replies.
- [PR] fixing ChangelogNormalizeRestoreTest test [flink] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2025/10/20 22:54:15 UTC, 5 replies.
- [jira] [Assigned] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/21 03:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/21 06:16:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/21 06:16:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/21 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 08:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 08:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 08:52:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 09:06:00 UTC, 0 replies.
- Re: [D] Planning Flink Agents 0.1 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 09:16:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap with memory state backend - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 09:21:00 UTC, 0 replies.
- [D] Planning Flink Agents 0.2 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 09:30:03 UTC, 4 replies.
- Re: [D] MVP Design Doc - (WIP, incrementally updating) [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 09:30:35 UTC, 0 replies.
- Re: [D] MVP (release-0.1) Design Doc [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 09:31:02 UTC, 0 replies.
- Re: [D] Short-Term Memory Design [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 09:31:19 UTC, 0 replies.
- Re: [D] Resource & Resource Provider Design [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/21 09:31:40 UTC, 0 replies.
- Re: [D] Vector Store and Embedding Model Integration for Flink Agents [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/21 09:32:07 UTC, 0 replies.
- Re: [D] Replay-based Per Action State Consistency [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/10/21 09:33:00 UTC, 0 replies.
- Re: [D] Asynchronous Execution for Flink Agents [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/10/21 09:33:22 UTC, 0 replies.
- Re: [D] Prompt & Tool & ChatModel Design [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/21 09:33:38 UTC, 0 replies.
- Re: [D] Flink Agents Metrics Design [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/21 09:33:43 UTC, 0 replies.
- Re: [I] [Feature] Use MCP SDK to replace custom MCP/agent annotations [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/10/21 10:53:15 UTC, 2 replies.
- [jira] [Closed] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/10/21 11:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38426) Introduce sync vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/21 11:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38426) Introduce sync vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/21 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/10/21 11:53:00 UTC, 0 replies.
- [PR] [FLINK-38540] Fix unintended object reuse in `TransformExpressionKey` [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/10/21 11:57:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/21 11:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap with memory state backend - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/10/21 12:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/21 12:33:00 UTC, 0 replies.
- [PR] [FLINK-38497][connector] FLIP-535:Introduce RateLimiter to Source. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/10/21 12:52:17 UTC, 32 replies.
- [jira] [Updated] (FLINK-38497) FLIP-535:Introduce RateLimiter to Source - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/21 12:53:00 UTC, 2 replies.
- [PR] [doc] fix: wrong branch name in doc [flink-agents] - posted by "gyang94 (via GitHub)" <gi...@apache.org> on 2025/10/21 13:20:42 UTC, 2 replies.
- [jira] [Updated] (FLINK-35761) FLIP-547: Support checkpoint during recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/21 14:25:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.allow-on-recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/21 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38542) Recover output buffers of upstream task on downstream task side directly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/21 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38543) Change the overall UC restore process, JM and task initialization - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/21 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38544) Filtering record before processing with spilling strategy - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/21 14:31:00 UTC, 0 replies.
- Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/21 14:47:29 UTC, 3 replies.
- Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/21 14:48:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/10/21 15:29:00 UTC, 1 replies.
- Re: [PR] [FLINK-35477] Make initial cursor position configurable [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/21 15:40:50 UTC, 3 replies.
- [jira] [Closed] (FLINK-35477) Pulsar connector resets existing subscription - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:42:00 UTC, 0 replies.
- Re: [PR] PulsarSourceEnumerator class code format violations. [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/21 15:42:35 UTC, 1 replies.
- Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/21 15:46:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:51:00 UTC, 2 replies.
- Re: [PR] [FLINK-35468] Update isEnableAutoAcknowledgeMessage config comment [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/21 15:52:41 UTC, 1 replies.
- [jira] [Assigned] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38545) Update Pulsar connector to Flink 1.20 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38545) Update Pulsar connector to Flink 1.20 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/21 15:59:00 UTC, 1 replies.
- Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/22 00:04:37 UTC, 4 replies.
- [I] [Bug] Tongyi model failed to handle tool calls [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/22 01:37:59 UTC, 1 replies.
- [PR] [hotfix] Always include assistant message after prompt applied [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/10/22 01:40:52 UTC, 1 replies.
- [PR] Pashley/flink 38350 release 1.20 [flink] - posted by "pra91 (via GitHub)" <gi...@apache.org> on 2025/10/22 03:19:54 UTC, 1 replies.
- [PR] [FLINK-38537][runtime] Fix the bug that can't compare correctly Double.NaN related attributes in StatsSummaryDto#equals method [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/22 03:40:57 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/22 03:51: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/10/22 06:26:00 UTC, 2 replies.
- Re: [PR] [hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/22 06:26:03 UTC, 1 replies.
- Re: [PR] [DON"T REVIEW] Empty commit to trigger a CI test for FLINK-37892 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/22 06:26:10 UTC, 1 replies.
- [jira] [Created] (FLINK-38546) Improve error message for table discovery failure due to MySQL permission - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/10/22 08:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38546) Improve error message for table discovery failure due to MySQL permission - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/10/22 08:11:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38495) Introduce cache in delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/22 08:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/22 08:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38495) Introduce cache in delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/22 08:17:00 UTC, 0 replies.
- [PR] [FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/10/22 08:22:14 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38436) Add document for VECTOR_SEARCH function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/22 09:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38528) Introduce async vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/22 09:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38528) Introduce async vector search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/22 09:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for database connections which require SSL. - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/22 09:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for database connections which require SSL. - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/22 09:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/22 12:48:42 UTC, 4 replies.
- [jira] [Closed] (FLINK-38465) Continue on error and metadata column support for HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/22 12:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34886) Support Sybase database - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 13:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34888) How to do MySQL to MySQL pipeline - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 13:34:00 UTC, 0 replies.
- [I] [Feature] Azure LLM Integration for the Agent [flink-agents] - posted by "tsaiggo (via GitHub)" <gi...@apache.org> on 2025/10/22 14:03:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-34856) [Bug] timeout when Invocating Remote RPC. - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 14:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34856) [Bug] timeout when Invocating Remote RPC. - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 14:28:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-34849) Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 14:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34801) [Bug] An insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_ - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/22 14:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38537) Fix the bug that can't compare correctly Double.NaN related attributes in StatsSummaryDto#equals method - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/10/22 14:43:00 UTC, 0 replies.
- [PR] [FLINK-38494] Add Chinese docs folder [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/22 14:43:38 UTC, 2 replies.
- Re: [PR] [DEBUG][FLINK-38461] rnd [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/22 15:59:44 UTC, 0 replies.
- [jira] [Created] (FLINK-38547) Upgrade protobuf-java from 3.x to 4.32.1 with compatibility patch for parquet-protobuf - posted by "Khaled Hammouda (Jira)" <ji...@apache.org> on 2025/10/22 18:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38547) Upgrade protobuf-java from 3.x to 4.32.1 with compatibility patch for parquet-protobuf - posted by "Khaled Hammouda (Jira)" <ji...@apache.org> on 2025/10/22 18:06:00 UTC, 4 replies.
- [PR] [FLINK-38547] [flink-protobuf] Upgrade protobuf to 4.32.1 [flink] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2025/10/22 18:46:00 UTC, 6 replies.
- [PR] [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/22 19:38:09 UTC, 5 replies.
- [jira] [Created] (FLINK-38548) Blue/Green Deployments - posted by "Prem Santosh (Jira)" <ji...@apache.org> on 2025/10/22 23:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38548) Blue/Green Deployments renames too many spec fields - posted by "Prem Santosh (Jira)" <ji...@apache.org> on 2025/10/22 23:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38548) Blue/Green Deployments rename too many spec fields - posted by "Prem Santosh (Jira)" <ji...@apache.org> on 2025/10/22 23:12:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38549) Support limiting context window size for Model Functions - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/10/23 03:26:00 UTC, 0 replies.
- [PR] [FLINK-38549][model] Support limiting context window size [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/10/23 03:56:01 UTC, 4 replies.
- [jira] [Updated] (FLINK-38549) Support limiting context window size for Model Functions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 - posted by "Sachin Mittal (Jira)" <ji...@apache.org> on 2025/10/23 04:00:00 UTC, 0 replies.
- [PR] Fix for FLINK-38550 [flink-cdc] - posted by "sjmittal (via GitHub)" <gi...@apache.org> on 2025/10/23 04:06:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 04:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-36456] Add support to pass Datadog API Key as environment variable [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:25:57 UTC, 1 replies.
- Re: [PR] [FLINK-37593][table] Add some Reduce Expression Rules [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:02 UTC, 0 replies.
- Re: [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:04 UTC, 0 replies.
- Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:06 UTC, 0 replies.
- Re: [PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:07 UTC, 0 replies.
- Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:09 UTC, 0 replies.
- Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:12 UTC, 0 replies.
- Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:13 UTC, 0 replies.
- Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:15 UTC, 0 replies.
- Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:17 UTC, 0 replies.
- Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:18 UTC, 0 replies.
- Re: [PR] [FLINK-37938] ml_evaluation accumulator implementation [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:25 UTC, 1 replies.
- Re: [PR] [FLINK-37921][table] Replace TableKeyedAsyncWaitOperator with new operator under new async framework [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/23 06:26:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 06:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38428) Support to call vector search with literal value - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/23 07:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38428) Support to call vector search with literal value - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/23 07:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38427) Support to serde vector search execnode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/23 07:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38427) Support to serde vector search execnode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/23 07:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/10/23 08:04:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/23 08:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38546) Improve error message for table discovery failure due to MySQL permission - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/23 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38551) Extend MultiJoin tests based on current join tests - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/23 09:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38551) Extend MultiJoin tests based on current join tests - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/23 09:09:00 UTC, 0 replies.
- [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/23 09:43:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-37607) Blocklist timeout check may lost - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/10/23 09:58:00 UTC, 2 replies.
- [PR] [FLINK-33653][runtime] Introduce a benchmark for balanced tasks scheduling. [flink-benchmarks] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/23 10:51:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-33653) Introduce a benchmark for balanced tasks scheduling - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 10:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/23 12:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/23 12:41:00 UTC, 0 replies.
- [PR] [BP-2.1][FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/23 12:49:03 UTC, 2 replies.
- [PR] [FLINK-34735][cdc][docs] "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation [flink-cdc] - posted by "edwardzcn-decade (via GitHub)" <gi...@apache.org> on 2025/10/23 13:26:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 13:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/23 13:33:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/23 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38552) FlinkStateSnapshot does not work if operator's namespace not in watchNamespaces - posted by "Maksim Aniskov (Jira)" <ji...@apache.org> on 2025/10/23 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38553) Identity casts of ROW types are not detected - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/10/23 14:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38553) Identity casts of ROW types are not detected - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/10/23 14:24:00 UTC, 1 replies.
- [PR] [FLINK-38552] [Helm] Fix FlinkStateSnapshot when operator's namespace not in watchNamespaces [flink-kubernetes-operator] - posted by "MaksimAniskov (via GitHub)" <gi...@apache.org> on 2025/10/23 14:27:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-38552) FlinkStateSnapshot does not work if operator's namespace not in watchNamespaces - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 14:28:00 UTC, 0 replies.
- [PR] [FLINK-38553][table-planner] CastRuleProvider should treat identity casts with highest precedence [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/10/23 15:03:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-38548) Blue/Green Deployments rename too many spec fields - posted by "Sergio Chong (Jira)" <ji...@apache.org> on 2025/10/23 16:11:00 UTC, 2 replies.
- Re: [PR] [FLINK-38430][table] Support runtime config for VECTOR_SEARCH [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/10/23 16:52:46 UTC, 4 replies.
- [jira] [Updated] (FLINK-38430) Support runtime config for VECTOR_SEARCH - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/23 16:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-37244] mention scylladb in docs [flink-connector-cassandra] - posted by "andrii-kysylevskyi (via GitHub)" <gi...@apache.org> on 2025/10/23 20:12:52 UTC, 3 replies.
- [jira] [Created] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/23 20:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38553) Identity casts of ROW types are not detected - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/10/23 21:45:00 UTC, 0 replies.
- [PR] [FLINK-38548] Rename only the name of child deployment for blue/green deployments [flink-kubernetes-operator] - posted by "ardakuyumcu (via GitHub)" <gi...@apache.org> on 2025/10/23 21:52:28 UTC, 4 replies.
- Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/24 00:04:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/24 02:16:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/24 02:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). - posted by "Kiruban Kamaraj (Jira)" <ji...@apache.org> on 2025/10/24 02:47:00 UTC, 10 replies.
- [jira] [Created] (FLINK-38556) Filter & Project can exists between source and deltajoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/24 02:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38556) Support Filter & Project between source and delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/24 03:00:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/24 03:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/24 03:57:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38494) Add Chinese docs for the HTTP connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/24 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38557) Upgrade Presto to resolve multiple vulnerabilities - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2025/10/24 07:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] - posted by "laughingman7743 (via GitHub)" <gi...@apache.org> on 2025/10/24 07:52:08 UTC, 0 replies.
- [jira] [Created] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2025/10/24 08:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2025/10/24 08:32:00 UTC, 2 replies.
- [PR] Add Hudi sink connector support [flink-cdc] - posted by "voonhous (via GitHub)" <gi...@apache.org> on 2025/10/24 08:39:02 UTC, 8 replies.
- [jira] [Updated] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/24 08:40:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/24 08:45:00 UTC, 0 replies.
- [PR] [BP-2.1][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory #27138 [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/24 08:45:29 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/24 08:48:08 UTC, 2 replies.
- Re: [PR] [BP-2.1][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/10/24 08:50:15 UTC, 1 replies.
- [PR] [FLINK-38190][python] Support unordered mode of async function in Python DataStream API [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/24 08:50:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-38190) Support async function in Python DataStream API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/24 08:51:00 UTC, 0 replies.
- [PR] [BP-1.2.0][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/24 08:51:18 UTC, 0 replies.
- [PR] [BP-1.19][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/10/24 08:55:32 UTC, 4 replies.
- Re: [PR] [BP-1.20][FLINK-35556] Fix constant in RocksDBSharedResourcesFactory [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/10/24 08:56:37 UTC, 1 replies.
- [jira] [Created] (FLINK-38559) Support unorder mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38559) Support unorder mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:03:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38560) Support ordered mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38561) Add retry support for async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38562) Support thread mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38563) Add documentation for async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38563) Add documentation for async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/24 09:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/24 09:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/24 09:36:00 UTC, 1 replies.
- [PR] [FLINK-38554][table] Fix rowCount cost for FlinkLogicalMultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/10/24 10:34:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/24 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/24 11:22:00 UTC, 0 replies.
- [PR] [FLINK-38564][connector] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. [flink] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/10/24 11:36:46 UTC, 11 replies.
- [jira] [Updated] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/24 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/24 12:20:00 UTC, 1 replies.
- [PR] [hotfix] Move docs content to the correct location [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/24 13:14:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Eric Nascimento (Jira)" <ji...@apache.org> on 2025/10/24 14:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Eric Nascimento (Jira)" <ji...@apache.org> on 2025/10/24 14:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/24 14:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/10/24 14:59:00 UTC, 0 replies.
- [PR] [hotfix][docs] Add `avro.` prefix for `timestamp_mapping.legacy` format option key [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/24 15:32:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-37515) FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/10/24 17:38:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/24 22:46:00 UTC, 0 replies.
- [PR] [FLINK-38565][table] Reduce `TRY_CAST` chain if source and target types are same [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/24 22:49:30 UTC, 2 replies.
- [jira] [Updated] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/24 22:50:00 UTC, 0 replies.
- [PR] [FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. [flink-cdc] - posted by "5herhom (via GitHub)" <gi...@apache.org> on 2025/10/25 15:11:27 UTC, 1 replies.
- Re: [PR] [FLINK-38559][python] Support unordered mode of async function in Python DataStream API [flink] - posted by "charlesdong1991 (via GitHub)" <gi...@apache.org> on 2025/10/25 15:24:34 UTC, 12 replies.
- [jira] [Updated] (FLINK-38559) Support unorder mode of async function in Python DataStream API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/25 15:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35474) During the process of catching up after a restart, Flink CDC uses the latest table information to parse old Mysql binlogs. - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/25 15:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-37585] [cdc-connector][mysql] Fixed the data of the newly added table cannot be read [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/26 00:05:20 UTC, 1 replies.
- [jira] [Created] (FLINK-38566) Support CEP DSL - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2025/10/26 02:14:00 UTC, 0 replies.
- [PR] [FLINK-38566] Support CEP DSL [flink] - posted by "kaori-seasons (via GitHub)" <gi...@apache.org> on 2025/10/26 02:14:32 UTC, 7 replies.
- [jira] [Updated] (FLINK-38566) Support CEP DSL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/26 02:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/10/26 03:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/10/26 03:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38566) Support CEP DSL - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2025/10/26 04:27:00 UTC, 2 replies.
- [PR] [FLINK-38545] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/26 05:14:17 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38545) Update Pulsar connector to Flink 1.20 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/26 07:04:00 UTC, 0 replies.
- Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/10/26 08:00:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-35572) flink db2 cdc default value error - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/26 11:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35701) SqlServer the primary key type is uniqueidentifier, the scan.incremental.snapshot.chunk.size parameter does not take effect during split chunk - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/26 14:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35774) The cache of transform is not updated after process schema change event - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/26 15:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35774) The cache of transform is not updated after process schema change event - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/26 15:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to the target table. - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/26 15:57:00 UTC, 0 replies.
- [PR] [hotfix] [docs] Fixed a typo in state_backends.md [flink] - posted by "Mafidyuz (via GitHub)" <gi...@apache.org> on 2025/10/26 20:56:21 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38431) Support VECTOR_SEARCH in batch mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/27 01:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38430) Support runtime config for VECTOR_SEARCH - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/27 01:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38430) Support runtime config for VECTOR_SEARCH - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/27 01:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to the target table. - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/10/27 01:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35774) The cache of transform is not updated after process schema change event - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/10/27 01:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38511) Join that consumes cdc source without delete may be converted to delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/27 01:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38511) Join that consumes cdc source without delete may be converted to delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/27 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/27 02:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/27 02:54:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38569) ReadingMetadataSpec should not be created if there are no metadataKeys to be read - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/27 03:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38569) ReadingMetadataSpec should not be generated if there are no metadataKeys to be read - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/27 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/10/27 04:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38571) Index is lost in CTAS and RTAS - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/27 05:46:00 UTC, 0 replies.
- [PR] [FLINK-38431][table] Support VECTOR_SEARCH in batch mode [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/10/27 05:49:49 UTC, 6 replies.
- [jira] [Updated] (FLINK-38431) Support VECTOR_SEARCH in batch mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/27 05:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/10/27 06:15:00 UTC, 0 replies.
- Re: [PR] Run ci [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/27 06:26:19 UTC, 1 replies.
- [PR] [FLINK-38568][mysql-cdc] Optimize binlog split lookup using binary search [flink-cdc] - posted by "huyuanfeng2018 (via GitHub)" <gi...@apache.org> on 2025/10/27 06:45:30 UTC, 1 replies.
- [jira] [Created] (FLINK-38572) Support controlling randomness and format of Chat Model Function - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/10/27 07:36:00 UTC, 0 replies.
- [PR] [FLINK-38572][model] Support controlling randomness and format of Chat Model Function [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/10/27 07:53:26 UTC, 2 replies.
- [jira] [Updated] (FLINK-38572) Support controlling randomness and format of Chat Model Function - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/27 07:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38561) Add retry support for async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/27 08:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/27 08:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/27 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38573) Add support for array datatype - posted by "Marton Greber (Jira)" <ji...@apache.org> on 2025/10/27 08:56:00 UTC, 0 replies.
- [PR] [FLINK-38479] Problems after upgrading the operator from 1.12.1 to 1.13.0 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/10/27 09:09:41 UTC, 0 replies.
- [PR] [FLINK-38487][build] bump vmImage version to ubuntu-24.04 in GHA [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/27 09:16:16 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/10/27 09:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Oleksandr Nitavskyi (Jira)" <ji...@apache.org> on 2025/10/27 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/27 10:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/27 10:14:00 UTC, 2 replies.
- [PR] [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/27 10:24:43 UTC, 9 replies.
- [jira] [Commented] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/27 10:34:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/27 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator - posted by "Marton Greber (Jira)" <ji...@apache.org> on 2025/10/27 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38576) Align commonJoinKey in MultiJoin for logical and physical rules - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/27 11:57:00 UTC, 0 replies.
- [PR] [FLINK-20539][table] Type mismatch when useing computed ROW column [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/27 11:57:19 UTC, 9 replies.
- [PR] [FLINK-38556][table] Support filter and project between source and delta join [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/10/27 12:40:56 UTC, 11 replies.
- [jira] [Commented] (FLINK-35917) Failed to deserialize data of EventHeaderV4 - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 13:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2025/10/27 13:43:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-35936) paimon cdc schema evolution failure when restart job - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 13:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35936) paimon cdc schema evolution failure when restart job - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 13:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35951) Flink CDC startup exception using jar package - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 14:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35913) The issue of using StreamExecutioneEnvironment to execute multiple jobs in a program on Flink CDC - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 14:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38573) Add support for array datatype - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/27 16:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/27 16:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-38545] Update to Flink 1.20.3 and Pulsar 3.0.5 [flink-connector-pulsar] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/10/27 16:38:34 UTC, 3 replies.
- [jira] [Closed] (FLINK-38545) Update Pulsar connector to Flink 1.20 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/10/27 17:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" - posted by "Sergio Chong (Jira)" <ji...@apache.org> on 2025/10/27 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38577) linkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2025/10/27 17:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38577) linkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2025/10/27 17:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38577) FlinkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2025/10/27 17:55:00 UTC, 1 replies.
- Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink] - posted by "shrutisinghania (via GitHub)" <gi...@apache.org> on 2025/10/27 18:10:30 UTC, 0 replies.
- [jira] [Created] (FLINK-38578) Invalid KinesisStreamsSource AWS_CREDENTIALS_PROVIDER_OPTION conversion - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/10/27 19:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38578) Invalid KinesisStreamsSource AWS_CREDENTIALS_PROVIDER_OPTION conversion - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/10/27 19:33:00 UTC, 0 replies.
- [PR] [FLINK-38517] Fixed equal check to happen after inplace modifications diffResult [flink-kubernetes-operator] - posted by "drossos (via GitHub)" <gi...@apache.org> on 2025/10/27 21:28:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/27 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38579) NonEquivCond in join and Filters pushed down in source should also affect the upstream changelog just like Filter in Calc - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/28 02:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38579) NonEquivCond in join and Filters pushed down in source should also affect the upstream changelog just like Filter in Calc - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/28 02:12:00 UTC, 1 replies.
- Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/10/28 02:55:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-33389) Support tasks balancing at slot level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/28 02:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33389) Support tasks balancing at slot level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/28 02:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33389) Support tasks balancing at slot level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/28 02:59:00 UTC, 0 replies.
- [PR] [FLINK-38558] Require copy when use heap timer [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/28 06:02:30 UTC, 5 replies.
- [jira] [Updated] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/28 06:03:00 UTC, 0 replies.
- [PR] [doc] Fix typo in overview page [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/10/28 06:10:09 UTC, 0 replies.
- Re: [PR] [FLINK-38151] Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/28 06:26:15 UTC, 0 replies.
- [PR] [FLINK-33653][runtime] Introduce a benchmark for balanced tasks scheduling. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/10/28 06:47:40 UTC, 1 replies.
- [jira] [Created] (FLINK-38580) Inconsistent data between Table API and DataStream API when using datagen connector - posted by "lajith (Jira)" <ji...@apache.org> on 2025/10/28 06:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38580) Inconsistent data between Table API and DataStream API when using datagen connector - posted by "lajith (Jira)" <ji...@apache.org> on 2025/10/28 07:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/28 07:52:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/28 07:55:00 UTC, 0 replies.
- [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] - posted by "whhe (via GitHub)" <gi...@apache.org> on 2025/10/28 07:55:34 UTC, 0 replies.
- [PR] [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/28 10:04:41 UTC, 5 replies.
- Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/10/28 10:41:31 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33390) Support slot balancing at TM level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/28 10:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33390) Support slot balancing at TM level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/28 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38581) Model Function supports error handling strategy - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/10/28 10:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38581) Model Function supports error handling strategy - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/10/28 10:50:00 UTC, 1 replies.
- [PR] [FLINK-38581][model] Model Function supports error handling strategy [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/10/28 11:33:06 UTC, 12 replies.
- [jira] [Commented] (FLINK-36309) Flink CDC Paimon Sink commit failed should log stackTrace - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/28 14:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36309) Flink CDC Paimon Sink commit failed should log stackTrace - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/28 14:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37924) Support variant field accessing - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/10/28 14:11:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37924) Support variant field accessing - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/10/28 14:12:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38582) DeltaGlobalCommitter stopped commit to delta log - posted by "Eric Nascimento (Jira)" <ji...@apache.org> on 2025/10/28 14:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38582) DeltaGlobalCommitter stopped commit to delta log - posted by "Eric Nascimento (Jira)" <ji...@apache.org> on 2025/10/28 14:50:00 UTC, 5 replies.
- [jira] [Created] (FLINK-38583) Flink job does not restart when environment variable changes. - posted by "Manish Jain (Jira)" <ji...@apache.org> on 2025/10/28 16:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36514) Unable to override include/exclude schema types in lenient mode - posted by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/28 16:48:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session - posted by "Yaroslav (Jira)" <ji...@apache.org> on 2025/10/28 22:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38559) Support unorder mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 01:46:00 UTC, 0 replies.
- [PR] [FLINK-38561][python] Add retry support for async function in Python DataStream API [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/29 01:58:36 UTC, 10 replies.
- [jira] [Updated] (FLINK-38561) Add retry support for async function in Python DataStream API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 01:59:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/10/29 02:46:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38584) Support checkpoint external path as Prometheus info-style metric - posted by "sohurdc (Jira)" <ji...@apache.org> on 2025/10/29 03:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36514) Unable to override include/exclude schema types in lenient mode - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/29 03:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36514) Unable to override include/exclude schema types in lenient mode - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/29 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2025/10/29 03:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38560) Support ordered mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 03:47:00 UTC, 0 replies.
- [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] - posted by "sohurdc (via GitHub)" <gi...@apache.org> on 2025/10/29 08:02:32 UTC, 3 replies.
- [jira] [Updated] (FLINK-38584) Support checkpoint external path as Prometheus info-style metric - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 08:03:00 UTC, 0 replies.
- [PR] [FLINK-38576][table-planner] Align commonJoinKey in MultiJoin for logical and physical rules [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/10/29 08:24:24 UTC, 8 replies.
- [jira] [Updated] (FLINK-38576) Align commonJoinKey in MultiJoin for logical and physical rules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 08:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution - posted by "Francis (Jira)" <ji...@apache.org> on 2025/10/29 08:33:00 UTC, 7 replies.
- [I] [Bug] Updates to messageContext in ChatModelAction are not persisted [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/29 08:53:19 UTC, 0 replies.
- [PR] [hotfix] toolCallContext not updated in ChatModelAction, causing data loss [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/10/29 09:00:53 UTC, 4 replies.
- [jira] [Created] (FLINK-38586) ClassCastException when using Delta Join with lookup cache - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2025/10/29 09:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler. [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/10/29 09:39:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-33391) Support tasks balancing at TM level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/29 09:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33391) Support tasks balancing at TM level for Adaptive Scheduler - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/29 09:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/29 09:43:00 UTC, 0 replies.
- [PR] [FLINK-38586][table-runtime] ClassCastException when using Delta Join with lookup cache [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/10/29 09:44:49 UTC, 6 replies.
- [jira] [Closed] (FLINK-38556) Support Filter & Project between source and delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/29 09:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38556) Support Filter & Project between source and delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/10/29 09:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38586) ClassCastException when using Delta Join with lookup cache - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 09:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*` - posted by "Lorenzo Affetti (Jira)" <ji...@apache.org> on 2025/10/29 10:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] - posted by "affo (via GitHub)" <gi...@apache.org> on 2025/10/29 10:24:44 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution - posted by "Francis (Jira)" <ji...@apache.org> on 2025/10/29 10:47:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38587) docker entrypoint script cannot handle FLINK_PROPERTIES that include spaces - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/10/29 12:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38587) docker entrypoint script cannot handle FLINK_PROPERTIES that include spaces - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/10/29 12:48:00 UTC, 0 replies.
- [PR] [feature][java][chatmodels] Add Azure AI chat model integration [flink-agents] - posted by "tsaiggo (via GitHub)" <gi...@apache.org> on 2025/10/29 13:25:50 UTC, 3 replies.
- [PR] [FLINK-38536] Add debugging for test failure [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/29 13:30:24 UTC, 4 replies.
- [jira] [Updated] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 13:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38561) Add retry support for async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38588) StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory is failing - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 14:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38588) StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory is failing - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 14:42:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38588) StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory is failing - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/29 15:25:00 UTC, 0 replies.
- [PR] [FLINK-38588][python] Fix test case StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/29 15:25:21 UTC, 2 replies.
- [PR] [FLINK-38560][python] Support ordered mode for async function in Python DataStream API [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/29 15:30:41 UTC, 8 replies.
- [jira] [Updated] (FLINK-38560) Support ordered mode of async function in Python DataStream API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/29 15:31:00 UTC, 0 replies.
- [PR] [FLINK-37244] Added scylladb tests, documentation and README [flink-connector-cassandra] - posted by "andrii-kysylevskyi (via GitHub)" <gi...@apache.org> on 2025/10/30 00:39:55 UTC, 1 replies.
- [jira] [Created] (FLINK-38589) Add documentation for FLIP-535:Introduce RateLimiter to Source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/30 01:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38589) Add documentation for FLIP-535:Introduce RateLimiter to Source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/30 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38590) Pypi does not support source distribution with underscore naming - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/30 03:04:00 UTC, 0 replies.
- [PR] [FLINK-38590][python] Upgrade setuptools to >=75.3 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/30 03:58:17 UTC, 8 replies.
- [jira] [Updated] (FLINK-38590) Pypi does not support source distribution with underscore naming - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/30 03:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38588) StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory is failing - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/30 05:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38560) Support ordered mode of async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/30 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38591) Add async function examples of Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/30 05:48:00 UTC, 0 replies.
- Re: [PR] Bump webpack-dev-server and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/10/30 06:25:54 UTC, 0 replies.
- Re: [PR] [FLINK-38404][core] Fix JobMasterTest by making it scheduler-type aware [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/10/30 06:27:47 UTC, 12 replies.
- [jira] [Updated] (FLINK-38590) Pypi does not support source distribution with hyphen naming - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/30 07:29:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38592) Native Flink S3 FileSystem - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2025/10/30 08:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35951) Flink CDC startup exception using jar package - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/30 08:44:00 UTC, 0 replies.
- [PR] Add GPG key for 2.0.1 release [flink-docker] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/30 08:44:12 UTC, 5 replies.
- [jira] [Created] (FLINK-38593) Flink CDC Source E2E Tests / test failed in CI - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/30 08:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38593) Flink CDC Source E2E Tests / test failed in CI - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/30 08:46:00 UTC, 1 replies.
- [PR] Update Dockerfiles for 2.0.1 release [flink-docker] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/10/30 08:46:50 UTC, 2 replies.
- [PR] [FLINK-38593][test][sqlserver] Fix unstable sqlserver e2e tests via adding more time to wait SqlserverAgent Ready [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/10/30 08:48:03 UTC, 1 replies.
- [PR] Add GPG key for 2.1.1 release [flink-docker] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/30 09:29:01 UTC, 2 replies.
- [PR] Update Dockerfiles for 2.1.1 release [flink-docker] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/10/30 10:20:31 UTC, 2 replies.
- [jira] [Closed] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*` - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/10/30 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38594) CI error ./pyflink/table/tests/test_udf.py:23:1: F401 'pytz' imported but unused - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/30 11:09:00 UTC, 0 replies.
- [PR] [FLINK-38594][python] remove unused import [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/30 11:14:37 UTC, 2 replies.
- [jira] [Updated] (FLINK-38594) CI error ./pyflink/table/tests/test_udf.py:23:1: F401 'pytz' imported but unused - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/30 11:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38593) Flink CDC Source E2E Tests / test failed in CI - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/30 11:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/10/30 11:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/10/30 11:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38590) Pypi does not support source distribution with hyphen naming - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/30 13:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38594) CI error ./pyflink/table/tests/test_udf.py:23:1: F401 'pytz' imported but unused - posted by "david radley (Jira)" <ji...@apache.org> on 2025/10/30 13:24:00 UTC, 0 replies.
- [PR] [FLINK-38594][pyflink] test latest flake8 with CI - do not merge [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/10/30 13:43:02 UTC, 3 replies.
- [jira] [Created] (FLINK-38595) Extend MultiJoin tests for further validation - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/10/30 17:14:00 UTC, 0 replies.
- [PR] [FLINK-38595][table] Add tests for multiple features with MJ [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/10/30 17:35:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-38595) Extend MultiJoin tests for further validation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/30 17:36:00 UTC, 0 replies.
- [PR] Fix a race condition in consumer creation by adding a retry with delay [flink-connector-pulsar] - posted by "vbabenkoru (via GitHub)" <gi...@apache.org> on 2025/10/30 17:48:08 UTC, 2 replies.
- [jira] [Created] (FLINK-38596) The comment of the created MaxCompute table is incorrect - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/30 20:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38597) Add request audit logging with pluggable sinks (GCS support) - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/10/30 23:57:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38597) Add request audit logging with pluggable sinks (GCS support) - posted by "Rosa Seohwa Kang (Jira)" <ji...@apache.org> on 2025/10/30 23:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38598) stringWrite.4.chinese(Java21) performance regression - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 01:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 01:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38599) Add documentation to explain how Source re-assign splits once recovery - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 01:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38497) FLIP-535:Introduce RateLimiter to Source - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 02:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 02:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/10/31 02:45:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/10/31 02:49:00 UTC, 0 replies.
- [PR] [hotfix] Adapt ollama example after supporting explicit tool call handling in OllamaChatModel. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/10/31 03:10:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-38598) stringWrite.4.chinese(Java21) performance regression - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/31 03:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38598) stringWrite.4.chinese(Java21) performance regression - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/31 03:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37266) Python CLI arguments doesn't work in session mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/31 03:34:00 UTC, 0 replies.
- [PR] [FLINK-37266][python] Fix the issue that Python dependencies options doesn't work for PythonDriver [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/31 03:35:45 UTC, 2 replies.
- [jira] [Updated] (FLINK-37266) Python CLI arguments doesn't work in session mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/31 03:36:00 UTC, 0 replies.
- [PR] [refactor] chore: support ci mutli tests [flink-agents] - posted by "kitalkuyo-gita (via GitHub)" <gi...@apache.org> on 2025/10/31 03:55:50 UTC, 0 replies.
- [jira] [Created] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition - posted by "Victor Babenko (Jira)" <ji...@apache.org> on 2025/10/31 04:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition - posted by "Victor Babenko (Jira)" <ji...@apache.org> on 2025/10/31 04:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition - posted by "Victor Babenko (Jira)" <ji...@apache.org> on 2025/10/31 04:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/31 06:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/10/31 06:25:00 UTC, 0 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/10/31 06:25:46 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/10/31 06:25:48 UTC, 0 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/10/31 06:25:50 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/10/31 06:28:00 UTC, 0 replies.
- [I] [Bug] The test case fails to run on Windows [flink-agents] - posted by "tsaiggo (via GitHub)" <gi...@apache.org> on 2025/10/31 07:12:50 UTC, 1 replies.
- [jira] [Created] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers - posted by "Ciprian Anton (Jira)" <ji...@apache.org> on 2025/10/31 07:16:00 UTC, 0 replies.
- [PR] [FLINK-38564][docs]FLIP-537: Add documentation to explain how Source re-assign splits once recovery in sources.md. [flink] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/10/31 08:35:26 UTC, 4 replies.
- [PR] [doc] Add document for FLIP-535:Introduce RateLimiter to Source. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/10/31 09:20:59 UTC, 4 replies.
- [jira] [Closed] (FLINK-38431) Support VECTOR_SEARCH in batch mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/31 09:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/31 09:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/31 09:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38431) Support VECTOR_SEARCH in batch mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/10/31 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38602) test_cron_adaptive_scheduler python failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 09:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38602) test_cron_adaptive_scheduler python failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 09:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38602) test_cron_adaptive_scheduler python failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/10/31 09:29:00 UTC, 0 replies.
- [PR] [FLINK-38602][python] Correct misuse of typehint [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/10/31 09:40:26 UTC, 4 replies.
- [jira] [Updated] (FLINK-38602) test_cron_adaptive_scheduler python failed - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/31 09:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/10/31 09:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38536][tests] Add debugging for test failure [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/10/31 09:55:16 UTC, 3 replies.
- [jira] [Closed] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38604) AutoRescalingITCase.testCheckpointRescalingInKeyedState failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 10:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/10/31 12:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38602) test_cron_adaptive_scheduler python failed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/10/31 14:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38605) Feature: Stateless Ordered Async - posted by "Zach (Jira)" <ji...@apache.org> on 2025/10/31 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38605) Feature: Stateless Ordered Wait - posted by "Zach (Jira)" <ji...@apache.org> on 2025/10/31 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38606) Support Flink Mongodb connector on latest version of Flink 2.1.0 - posted by "Rahul Teke (Jira)" <ji...@apache.org> on 2025/10/31 17:58:00 UTC, 0 replies.
- [PR] [FLINK-38606][Connectors/MongoDB] Support for Flink 2.1.0 API [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2025/10/31 18:03:55 UTC, 1 replies.
- [jira] [Updated] (FLINK-38606) Support Flink Mongodb connector on latest version of Flink 2.1.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/31 18:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38607) Do not store plans with same name twice in plan test files - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/10/31 20:44:00 UTC, 0 replies.
- [PR] [FLINK-38607][table] Do not store plans with same name twice in plan test files [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/10/31 20:47:41 UTC, 4 replies.
- [jira] [Updated] (FLINK-38607) Do not store plans with same name twice in plan test files - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/10/31 20:48:00 UTC, 1 replies.