dev  

Messages by Thread

• [jira] [Created] (FLINK-41233) The fast profile in flink-connector-parent no longer skips japicmp Martijn Visser (Jira)
• [jira] [Created] (FLINK-41234) Bump build plugins in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41235) Remove maven-eclipse-plugin from flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41232) Enable SBOM generation in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41231) Publish SBOM artifacts for flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Created] (FLINK-41230) Declare flink-connector-base as provided in flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Created] (FLINK-41214) Declare a materialized table with Table#materializeInto Timo Theusner (Jira)
• [jira] [Created] (FLINK-41229) StreamNetworkThroughputBenchmark hangs instead of failing when the receiver thread fails Martijn Visser (Jira)
• [jira] [Created] (FLINK-41212) Reject FULL refresh mode from a plain TableEnvironment Timo Theusner (Jira)
• [jira] [Created] (FLINK-41210) Add fluent StartMode factories Timo Theusner (Jira)
• [jira] [Created] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Hanyu Zheng (Jira)
• [VOTE] Release Apache Flink Kafka Connector 5.1.0, release candidate rc1 martijnvisser
  • Re: [VOTE] Release Apache Flink Kafka Connector 5.1.0, release candidate rc1 Purushottam Sinha
  • Re: [VOTE] Release Apache Flink Kafka Connector 5.1.0, release candidate rc1 snuyanzin
  • Re: [VOTE] Release Apache Flink Kafka Connector 5.1.0, release candidate rc1 Sylwester Lachiewicz
• [jira] [Created] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps Sangkyoon Nam (Jira)
• [jira] [Created] (FLINK-41224) Filter out rows with a NULL join key before streaming inner joins Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41227) AVG on TINYINT, SMALLINT and INT overflows when SplitAggregateRule splits distinct aggregates Ankur Kotwal. (Jira)
• [jira] [Created] (FLINK-41218) Add per-record result processing for HTTP sink batch responses Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41211) List materialized tables of a given catalog and database Timo Theusner (Jira)
• [jira] [Created] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41225) Mini-batch join: the unique-key bundles fold an UPDATE_AFTER and the following DELETE into nothing, so the stored row is never retracted Yoni (Jira)
• [jira] [Created] (FLINK-41223) Batch joins drop NULL-safe matches on IS NOT DISTINCT FROM keys when column statistics report many NULLs Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41221) Support changelog streams in the HTTP table sink Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41222) Autoscaler reports an error when a ConfigMap write is applied but the client's retry conflicts Alex Kukhar (Jira)
• [jira] [Created] (FLINK-41219) Add an idempotency key header per HTTP sink request entry Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41220) Honour Retry-After and add jitter to HTTP sink retry delays Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41215) Drop a materialized table by path from TableEnvironment Timo Theusner (Jira)
• [jira] [Created] (FLINK-41213) Submit refresh jobs from programs deployed in application mode Timo Theusner (Jira)
• [jira] [Created] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment Timo Theusner (Jira)
• [jira] [Created] (FLINK-41208) JdbcSourceBuilder accepts ResultSet.CONCUR_READ_ONLY as a result set type for exactly-once Purushottam Sinha (Jira)
• [ANNOUNCE] Flink 2.4 Branch Cut Mika Naylor via dev
• [jira] [Created] (FLINK-41207) Fluss pipeline source does not checkpoint consumed offsets across empty log intervals Xiaobing Fang (Jira)
• [REQUEST] PMC help for 2.4 release Azure Devops change for flink-master-mirror Mika Naylor via dev
  • Re: [REQUEST] PMC help for 2.4 release Azure Devops change for flink-master-mirror Martijn Visser
• [jira] [Created] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• [jira] [Created] (FLINK-41205) FLIP-616: Materialized Tables support for Table API Timo Theusner (Jira)
• [jira] [Created] (FLINK-41204) VARIANT JSON parsing replaces unpaired surrogates with '?' instead of failing Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41203) Help users pick between the Kafka, Upsert Kafka and Dynamic Kafka SQL connectors Martijn Visser (Jira)
• [RESULT][VOTE] FLIP-616: Materialized Tables support for Table API Timo Theusner
• [jira] [Created] (FLINK-41202) Make connector integrations easier to find from the Flink docs Martijn Visser (Jira)
• [jira] [Created] (FLINK-41201) Fluss pipeline sink error counters remain zero after write failures Xiaobing Fang (Jira)
• [VOTE] Apache Flink Agents Release 0.4.0, release candidate #1 wenjin
• [jira] [Created] (FLINK-41200) GROUP BY over an outer join with a non-equi join condition drops rows (batch mode) Yusuf YILDIZ (Jira)
• [jira] [Created] (FLINK-41199) PyFlink result collection fails for NULL values inside nested rows and collections Luo Zhengjie (Jira)
• [jira] [Created] (FLINK-41198) Add a configurable option for RocksDB max_manifest_file_size pia park (Jira)
• [jira] [Created] (FLINK-41197) Multi-table DROP may bypass tables.exclude when binlog newly-added table discovery is enabled Jira
• [jira] [Created] (FLINK-41196) PyFlink Table.to_pandas() changes TIMESTAMP_LTZ instants in non-UTC session time zones Biao Geng (Jira)
• [jira] [Created] (FLINK-41195) Avoid flushing Python bundles during task cancellation Dian Fu (Jira)
• [jira] [Created] (FLINK-41194) Use PulsarAdmin to make PulsarSink transaction commits idempotent during recovery Yubiao Feng (Jira)
• [jira] [Created] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 Rui Fan (Jira)
• [jira] [Created] (FLINK-41174) Migrate KubernetesHighAvailabilityRecoverFromSavepointITCase to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41192) HTTP sink request never completes when a retry attempt throws Martijn Visser (Jira)
• [jira] [Created] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41186) Migrate graph and partitioner tests in flink-streaming-java and flink-runtime to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41191) Upgrade Testcontainers to 1.21.4 on the flink-connector-opensearch v1.2 branch Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41170) Migrate classloading jar programs and shared util sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41187) Remove StreamSource from StreamTask tests that guard surviving behaviour Martijn Visser (Jira)
• [jira] [Created] (FLINK-41188) Rewrite InterruptSensitiveRestoreTest without SourceStreamTask Martijn Visser (Jira)
• [jira] [Created] (FLINK-41190) Migrate TestProtobufSourceFunction to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41189) Migrate small planner test sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41185) Migrate YarnTestJob to a self-contained Source V2 source Martijn Visser (Jira)
• [jira] [Created] (FLINK-41182) Migrate AutoRescalingITCase and RescalingITCase sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41183) Migrate the RegionFailoverITCase source to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41184) Migrate TestEventSource of the operator lifecycle test jobs to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41181) Filesystem sink silently drops all rows when the last partition column name starts with '_' or '.' Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41176) Migrate flink-connector-files sink ITCase sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41171) Migrate the operator restore test jobs KeyedJob and NonKeyedJob to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41162) Migrate CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41179) VAR_POP / STDDEV_POP give wrong, non-deterministic results with mini-batch two-phase aggregation over an updating input Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41159) Remove unused SourceFunction test sources from flink-yarn-tests Martijn Visser (Jira)
• [jira] [Created] (FLINK-41165) Migrate the remaining checkpointing ITCases with generated sources to DataGeneratorSource Martijn Visser (Jira)
• [jira] [Created] (FLINK-41168) Migrate recovery and scheduling ITCases to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41166) Migrate SavepointITCase sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41169) Migrate streaming runtime ITCases to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41163) Migrate KeyedStateCheckpointingITCase and CoStreamCheckpointingITCase to DataGeneratorSource Martijn Visser (Jira)
• [jira] [Created] (FLINK-41161) Migrate TimestampITCase to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41160) Migrate CheckpointedStreamingProgram to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41177) Checkpointed-position test source for hook-driven checkpointing ITCases Martijn Visser (Jira)
• [jira] [Created] (FLINK-41175) Migrate S5CmdOnSeaweedFsITCase to FailingCheckpointedSource Martijn Visser (Jira)
• [jira] [Created] (FLINK-41172) Migrate flink-state-processing-api test sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41173) Migrate AbstractQueryableStateTestBase sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41167) Migrate the remaining checkpointing ITCases with controllable sources to Source V2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41156) Upgrade Testcontainers to 1.21.4 on the JDBC connector v4.1 and v3.4 branches to support Docker 29 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41155) Add stage_source_release_atr.sh for Apache Trusted Releases Martijn Visser (Jira)
• [jira] [Created] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux Martijn Visser (Jira)
• [jira] [Created] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41146) Release Testing Instructions: FLIP-547 V2: Filtering record before processing with spilling strategy Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41151) Release Testing Instructions: FLINK-39268: Support Common Subexpression Elimination (CSE) in Calc Code Generation Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41149) Release Testing Instructions: FLIP-585: Introduce Lazy Loading for HistoryServer Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41141) Release Testing Instructions: FLIP-574 Metadata Filter Push-Down for Table Sources Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41150) Release Testing Instructions: FLIP-599: State Catalog Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41148) Release Testing Instructions: FLIP-584: Support Pluggable Storage Backend for HistoryServer Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41140) Release Testing Instructions: FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41139) Release Testing Instructions: FLIP-567: Introduce a ProcessTableFunction Test Harness Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41133) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
• [jira] [Created] (FLINK-41136) Exactly-once JdbcSink in BATCH mode fails for good after its committer restarts mid-commit Martijn Visser (Jira)
• [jira] [Created] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41129) [release-2.4] Add release notes Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41126) [release-2.4] Triage release blockers in JIRA Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41127) [release-2.4] Review and update documentation Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41125) [release-2.4] Cross-team testing Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41124) [release-2.4] Review release notes in JIRA Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41123) [release-2.4] Prepare RC0 release Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource Martijn Visser (Jira)
• [PR] [FLINK-41117][ci] Use ubuntu 26 in ci docker image [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-41117][ci] Use ubuntu 26 in ci docker image [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation David Peacock (Jira)
• [jira] [Created] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
• [jira] [Created] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Dian Fu (Jira)
• [DISCUSS] Make ON CONFLICT optional by default in Flink 2.4 Gustavo de Morais
• [jira] [Created] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Moritz Manner (Jira)
• [jira] [Created] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
• [jira] [Created] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• [jira] [Created] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• [jira] [Created] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• [jira] [Created] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Dian Fu (Jira)
• [jira] [Created] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira)
• [DISCUSS] FLINK-37987: JdbcDynamicTableSink to Sink V2 in place Martijn Visser
  • Re: [DISCUSS] FLINK-37987: JdbcDynamicTableSink to Sink V2 in place Krishna Sai
  • Re: [DISCUSS] FLINK-37987: JdbcDynamicTableSink to Sink V2 in place Yanquan Lv
• [jira] [Created] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• [jira] [Created] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• [jira] [Created] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41098) Streaming mode: IN / NOT IN in the SELECT list drops all rows when the subquery result is empty Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41097) AVG returns NULL for a group with a NULL value once adaptive local hash aggregation switches to bypass mode Yaoxuan Wu (Jira)
• [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
  • Re: [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib
  • Re: [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Timo Walther
• [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
  • Re:Re: [VOTE] FLIP-616: Materialized Tables support for Table API Xuyang
• [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
  • Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Ferenc Csaky via dev
  • Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Gustavo de Morais
  • Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Yanquan Lv
• [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)

• Earlier messages