dev  

Messages by Thread

• [jira] [Created] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt Aaron He (Jira)
• [jira] [Created] (FLINK-41096) Wrong result when a Table with a non-equi correlated scalar subquery is used twice in one query Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll Aaron He (Jira)
• [jira] [Created] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors Aaron He (Jira)
• [jira] [Created] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads Aaron He (Jira)
• [jira] [Created] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll Aaron He (Jira)
• [jira] [Created] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
• [jira] [Created] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• [DISCUSS] Supporting Flink 2.2/2.3 for flink-connector-aws M Junaid
• [jira] [Created] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib
• [jira] [Created] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• [VOTE] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re: [VOTE] FLIP-616: Materialized Tables support for Table API Ramin Gharib
  • Re: [VOTE] FLIP-616: Materialized Tables support for Table API Timo Walther
  • Re: [VOTE] FLIP-616: Materialized Tables support for Table API Gustavo de Morais
• [jira] [Created] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects Ramin Gharib (Jira)
• [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Martijn Visser
  • Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Gyula Fóra
  • Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Gabor Somogyi
• [jira] [Created] (FLINK-41085) AppendOnlyTopNFunction emits an inconsistent changelog after cache eviction when sorting on NaN Bettle (Jira)
• [jira] [Created] (FLINK-41084) Common & Source-Specific Metrics sukang (Jira)
• [jira] [Created] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41082) Polish Flink CDC docs and fix format issues Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41081) Provide EN / ZH bilingual docs for Flink CDC Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41080) [UMBRELLA] Polish Flink CDC docs and enrich contents Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task Martijn Visser (Jira)
• [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
• [jira] [Created] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision Luca Castelli (Jira)
• [jira] [Created] (FLINK-41072) Test configuration randomization on GitHub Actions always uses the same seed Martijn Visser (Jira)
• [jira] [Created] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• [jira] [Created] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• [jira] [Created] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 Martijn Visser (Jira)
• [REQUEST] Unassigned bug/flaky test issues for 2.4 Mika Naylor via dev
• [jira] [Created] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• [jira] [Created] (FLINK-41067) Window and interval joins store rows whose join key can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs Timo Walther (Jira)
• [jira] [Created] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files Martijn Visser (Jira)
• [jira] [Created] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization Jira
• [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Timo Walther
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Aleksandr Savonin
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib David Anderson
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Sangkyoon Nam
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Purushottam Sinha
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Mika Naylor via dev
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Efrat Levitan
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Austin Cawley-Edwards
  • Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Samrat Deb
• [jira] [Created] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents Moritz Manner (Jira)
• [jira] [Created] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
• [REQUEST] Creating versions 2.4.1 and 2.5.0 in Jira Mika Naylor via dev
  • Re: [REQUEST] Creating versions 2.4.1 and 2.5.0 in Jira Rui Fan
• [jira] [Created] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• [jira] [Created] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() Martijn Visser (Jira)
• [jira] [Created] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules Hongshun Wang (Jira)
• [jira] [Created] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events Yanquan Lv (Jira)
• [jira] [Created] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL Martijn Visser (Jira)
• [jira] [Created] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• [jira] [Created] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
• [jira] [Created] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment Gerk Elznik (Jira)
• [jira] [Created] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently Martijn Visser (Jira)
• [jira] [Created] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• [jira] [Created] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Martijn Visser (Jira)
• [jira] [Created] (FLINK-41046) HBaseConnectorITCase.testTableSinkDisabledBufferFlush expected [+I[1, 6]] but was [+I[1, 1]] Martijn Visser (Jira)
• [jira] [Created] (FLINK-41045) unning Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register Martijn Visser (Jira)
• [jira] [Created] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Martijn Visser (Jira)
• [jira] [Created] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException Martijn Visser (Jira)
• [jira] [Created] (FLINK-41041) Maven waits until the time budget after a JDK 8 surefire fork crashes with SIGSEGV in libjvm.so Martijn Visser (Jira)
• [jira] [Created] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
• [jira] [Created] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions Pritam Kumar (Jira)
• [jira] [Created] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41038) WHERE CAST(x AS DECIMAL(10, 2)) IS NULL returns NULL for x when the cast overflows Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Biao Geng (Jira)
• [jira] [Created] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-41031) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT Pritam Kumar (Jira)
• [jira] [Created] (FLINK-41029) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) Saurabh Kanawade (Jira)
• Cobble-Flink adds async state support for Apache Flink 2.x Zakelly Lan
• [jira] [Created] (FLINK-41024) Upgrade PyFlink docs to Sphinx 9.1 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile Martijn Visser (Jira)
• [jira] [Created] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink Hongshun Wang (Jira)
• [jira] [Created] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods Guotao Ding (Jira)
• [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Sonal Maheshwari
  • Re: [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Xiqian YU
• [jira] [Created] (FLINK-41021) Update commons-beanutils to 1.11.0 and jsoup to 1.23.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41022) Update lz4-java to 1.12.0 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41020) PyFlink docs: Update dependencies with open Dependabot advisories Martijn Visser (Jira)
• [jira] [Created] (FLINK-41019) COMPILE PLAN does not record table.exec.sink.nested-constraint-enforcer, so EXECUTE PLAN uses the cluster's value sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-41018) Introduce BIT_COUNT as a built-in function for SQL and Table API Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41017) Use DecimalData#isCompact while casting Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled Sangkyoon Nam (Jira)
• [jira] [Created] (FLINK-41013) Use a hash consistent with SQL equality to match MAP keys and array elements Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41015) [JUnit5 Migration] Migrate the remaining of the junit4 testing class to junit5 of flink-test-utils module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-41012) Schema change apply failure leads to unrecoverable crash loop: redundant skip + null evolved schema leak after job restart zhanglu153 (Jira)
• [jira] [Created] (FLINK-41011) [pipeline-connector/doris] Auto-created Doris table drops NOT NULL constraint of source columns tchivs (Jira)
• [jira] [Created] (FLINK-41010) [cdc-base] NPE in HybridSplitAssigner.createStreamSplit when failed snapshot splits are re-added after assigner finished tchivs (Jira)
• [jira] [Created] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Yubiao Feng (Jira)
• [jira] [Created] (FLINK-41008) Support multi-table transaction stream load in StarRocks pipeline connector peiyu (Jira)
• [jira] [Created] (FLINK-41007) ON CONFLICT clause is silently ignored when table.exec.sink.upsert-materialize is NONE sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-41006) upgrade starrocks connector to 1.2.16 peiyu (Jira)
• [jira] [Created] (FLINK-41005) MiniCluster should clean up partially started services when start() fails Dale Lane (Jira)
• [jira] [Created] (FLINK-41004) Column expansion does not work with REQUIRE_ON_TIME trait Timo Walther (Jira)
• [jira] [Created] (FLINK-41003) Bump Pulsar version to 4.0.14 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-41002) Move test-only defaults out of MiniClusterConfiguration Dale Lane (Jira)
• [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Jacky Lau
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Zhang Chaoming
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Ran Tao
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Jacky Lau
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Yong Liu
• [jira] [Created] (FLINK-41001) OpenAI model provider rejects compatible string input types Liu Liu (Jira)
• [DISCUSS] Flink CDC 3.8 Kick Off Yanquan Lv
  • Re: [DISCUSS] Flink CDC 3.8 Kick Off Xiqian YU
  • Re: [DISCUSS] Flink CDC 3.8 Kick Off Leonard Xu
• [jira] [Created] (FLINK-40997) Streaming join picks a random state key among equal-length upsert keys Mate Czagany (Jira)
• [DISCUSS] Release flink-connector-pulsar v5.0.0 Ferenc Csaky via dev
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Mate Czagany
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Ferenc Csaky via dev
• [jira] [Created] (FLINK-41000) Pulsar 5.0 support Hongbo Miao (Jira)
• [jira] [Created] (FLINK-40999) [cdc-composer] Factory JAR path resolution fails with "URI is not hierarchical" for relative usrlib paths in application mode wind.wang (Jira)
• [jira] [Created] (FLINK-40998) Web dashboard: Update dependencies with open Dependabot advisories Martijn Visser (Jira)
• [jira] [Created] (FLINK-40996) Make TRY_PARSE_JSON, PARSE_JSON reuse parsed json Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40995) Draft pull requests are not excluded from the community review label scan sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40994) Upgrade paimon to 2.1.0 peiyu (Jira)
• [jira] [Created] (FLINK-40993) State Processor API writes an unrestorable savepoint from a checkpoint taken with file merging sepuri sai krishna (Jira)
• [DISCUSS] A New Flink Native Engine StreamFusion Based On DataFusion Jacky Lau
• [jira] [Created] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-40990) MySQL CDC source suppresses terminal missing-schema errors and keeps checkpointing without CDC Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40989) MAP equality compares numeric values by reference Martijn Visser (Jira)
• [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
• [REMINDER] Flink 2.4 feature freeze planned for 20 October Sumin Joo
• [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Biao Geng (Jira)
• [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink VISHAL B (Jira)
• [jira] [Created] (FLINK-40984) Port the batch aggregate ITCases in flink-table-planner to Java Martijn Visser (Jira)
• [jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Rango (Jira)
• [jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks Martijn Visser (Jira)
• [jira] [Created] (FLINK-40978) Cast from VARIANT through FromVariantConverter Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hanyu Zheng (Jira)
• [jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• [jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse Martijn Visser (Jira)
• [jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• [jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize Martijn Visser (Jira)
• [jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer Martijn Visser (Jira)
• [jira] [Created] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder Hanyu Zheng (Jira)
• [jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Martijn Visser (Jira)
• [jira] [Created] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history Hao Yu (Jira)
• Help with Confluence account creation Sumin Joo
  • Re: Help with Confluence account creation Rui Fan
  • Re: Help with Confluence account creation Sumin Joo
• [SUMMARY] Flink 2.4 Release Sync - 09.10.26 Sumin Joo
• [DISCUSS] Flink Community Skills Rui Fan
  • Re: [DISCUSS] Flink Community Skills Purushottam Sinha
  • Re: [DISCUSS] Flink Community Skills Krishna Sai
  • Re: [DISCUSS] Flink Community Skills Gustavo de Morais
• [ANNOUNCE] Apache Flink CDC 3.7.0 released Xiqian YU
  • Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Yanquan Lv
• [RESULT][VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
• [DISCUSS] Apache Flink 1.20.6 release Rui Fan
• [DISCUSS] Apache Flink 2.2.2 release Rui Fan
• [DISCUSS] Apache Flink 2.3.1 release Rui Fan
• [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
  • Re: [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Gen Luo
  • Re: [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
• [jira] [Created] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Timo Theusner (Jira)
• [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re:[DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
  • Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re:Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
  • Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re:Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
  • Re: Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Gustavo de Morais
  • Re: Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner

• Earlier messages