commits  

Messages by Thread

• (flink) branch release-2.3 updated: [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain martijnvisser
• (flink) branch release-2.4 updated: [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain martijnvisser
• (flink) branch master updated: [FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down snuyanzin
• (flink-kubernetes-operator) branch main updated: [FLINK-40991][operator] Ignore unknown fields when reading ClusterHealthInfo (#1221) gyfora
• (flink) branch master updated: [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join gustavodemorais
• (flink) branch release-2.3 updated: [FLINK-41104][python] Return true from MapState.contains for keys mapped to None dianfu
• (flink) branch release-2.3 updated: [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) dianfu
• (flink) branch master updated (3e6471436eb -> f9abda3bbef) pnowojski
  • (flink) 03/04: [FLINK-41256][runtime] Fail on operators changing the current key out of order in BATCH execution pnowojski
  • (flink) 04/04: [FLINK-41256][runtime] Don't set the current key in KeyedSortPartitionOperator pnowojski
  • (flink) 02/04: [FLINK-41256][runtime] Use moveToNextKey on the keyed input path of key-sorted inputs pnowojski
  • (flink) 01/04: [FLINK-41256][runtime] Add moveToNextKey to KeyContext and KeyedStateBackend pnowojski
• (flink-agents) branch main updated: [hotfix][ci] Finalize PyArrow 11 on exit in Flink 1.20 tests (#1343) wenjin
• (flink) branch master updated: [FLINK-41260][table] Improve error msg by rejecting ORDER BY in ARRAY_AGG and JSON_ARRAYAGG during planning gustavodemorais
• (flink-web) branch asf-site updated (88e86315d2 -> 18807d5e81) wenjin
  • (flink-web) 01/02: Announce Flink Agents 0.4.0 wenjin
• (flink) branch release-1.20 updated: [FLINK-41104][python] Return true from MapState.contains for keys mapped to None dianfu
• (flink) branch release-2.4 updated: [FLINK-41104][python] Return true from MapState.contains for keys mapped to None dianfu
• (flink) branch master updated: [FLINK-41104][python] Return true from MapState.contains for keys mapped to None dianfu
• (flink) branch release-1.20 updated: [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) dianfu
• (flink) branch release-2.4 updated: [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) dianfu
• (flink) branch master updated: [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) dianfu
• (flink) branch release-1.20 updated: [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) dianfu
• (flink) branch release-2.3 updated: [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) dianfu
• (flink) branch release-2.4 updated: [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) dianfu
• (flink) branch master updated: [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) dianfu
• (flink) branch release-2.4 updated: [FLINK-40196][table] Remove IS_NOT_NAN in favor of NOT IS_NAN (#29639) dianfu
• (flink) branch master updated: [FLINK-40196][table] Remove IS_NOT_NAN in favor of NOT IS_NAN (#29639) dianfu
• (flink-kubernetes-operator) branch main updated: [FLINK-41222][autoscaler] Accept a conflicting ConfigMap write that Kubernetes already applied (#1234) gyfora
• (flink-agents) branch release-0.4 updated: [hotfix][docs] Use 0.4.0 release defaults on release-0.4 (#1340) wenjin
• (flink) branch master updated: [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain martijnvisser
• (flink-agents) branch main updated: [integrations][java][python][docs] Send images and documents in tool results to Anthropic (#1331) wenjin
• (flink-connector-jdbc) branch v4.1 updated: [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs martijnvisser
• (flink-kubernetes-operator) branch main updated: [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator (#1227) gyfora
• (flink-connector-aws) branch main updated: [FLINK-40938] Support `AT_TIMESTAMP` initial position in DynamoDB Streams source fcsaky
• (flink) branch master updated: [hotfix][ci] Use blobless fetch in Azure single-branch checkout snuyanzin
• (flink) branch master updated: [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key twalthr
• (flink-kubernetes-operator) branch main updated: [FLINK-41242] Report the original exception class in `status.error` (#1233) rmetzger
• (flink) branch master updated: [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` snuyanzin
• (flink) branch master updated: [FLINK-40948][table] Maintain window properties for different joins snuyanzin
• (flink-kubernetes-operator) branch main updated: [FLINK-41031] Close operator-owned resources on shutdown and exit on startup failure (#1224) gyfora
• (flink-connector-aws) branch main updated: [FLINK-41047] Do not assert JDK-specific connection-refused text in sink writer tests fcsaky
• (flink) branch master updated (6968bc461ef -> d9af54c7690) pnowojski
  • (flink) 02/04: [FLINK-41217][connectors] Generate no data points for a count of 0 in DataGeneratorSource pnowojski
  • (flink) 03/04: [FLINK-41217][table] Add ValuesSource, a FLIP-27 source over the rows of VALUES pnowojski
  • (flink) 01/04: [FLINK-41217][core] Support empty sequences in NumberSequenceSource pnowojski
  • (flink) 04/04: [FLINK-41217][table-planner] Don't emit the rows of VALUES again after a restore pnowojski
• (flink) branch master updated (f00dd5a9db2 -> f8cd4aad141) martijnvisser
• (flink-agents) branch main updated: [hotfix][docs] Finalize Flink Agents 0.4.0 release defaults (#1339) wenjin
• (flink-agents) annotated tag release-0.4.0 updated (ef2636fe5 -> f4a388667) wenjin
• svn commit: r88880 - dev/flink/flink-agents-0.4.0-rc1 release/flink/flink-agents-0.4.0 xtsong
• (flink) branch release-2.4 updated (1fa0b04b8ac -> 30f7ee50e12) martijnvisser
  • (flink) 01/02: [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition martijnvisser
  • (flink) 02/02: [FLINK-41048][container] Avoid JMX port race condition martijnvisser
• (flink) branch release-2.4 updated: [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins (#29646) panyuepeng
• (flink) branch dependabot/maven/flink-python/io.opentelemetry-opentelemetry-api-1.67.0 created (now 6d5b14a849c) github-bot
• (flink) branch master updated (469332bf294 -> f00dd5a9db2) dianfu
• (flink-cdc) branch master updated: [FLINK-41201][pipeline-connector/fluss] Reuse sink writer metric group (#4598) hongshun
• (flink) branch master updated (e634da0bfa7 -> 43a9d4bc319) ramin
  • (flink) 01/03: [FLINK-41243][table] Support VARIANT field access with a non-literal key ramin
  • (flink) 03/03: [FLINK-41241][table] Use VariantFieldGetter for v['key'] and CAST to ROW ramin
  • (flink) 02/03: [FLINK-41241][core] Add VariantFieldGetter to read an object field by a fixed key ramin
• (flink) branch master updated (3e87ae6b12e -> 469332bf294) ramin
  • (flink) 02/02: [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET ramin
  • (flink) 01/02: [hotfix][python] Say NULL instead of None in the json_length docstring ramin
• (flink-kubernetes-operator) branch main updated: [FLINK-37448] Report actual TaskManager count in `status.taskManager.replicas` (#1146) rmetzger
• (flink) branch master updated: [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs (#29609) martijnvisser
• (flink) branch release-2.4 updated: [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs (#29609) martijnvisser
• (flink) branch release-2.4 updated: [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE (#29637) panyuepeng
• (flink) branch release-2.4 updated (a065f5beb87 -> 85d807e130f) ramin
  • (flink) 01/03: [FLINK-41243][table] Support VARIANT field access with a non-literal key ramin
  • (flink) 03/03: [FLINK-41241][table] Use VariantFieldGetter for v['key'] and CAST to ROW ramin
  • (flink) 02/03: [FLINK-41241][core] Add VariantFieldGetter to read an object field by a fixed key ramin
• (flink-connector-jdbc) branch main updated: [FLINK-40733][connector-jdbc] Re-enable the Trino tests martijnvisser
• (flink) branch release-2.3 updated: [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs (#29609) martijnvisser
• (flink-connector-http) branch main updated: [hotfix] Add docs data, update CI and enable japicmp ahead of 1.1.0 (#59) davidrad
• (flink-connector-jdbc) branch dependabot/maven/com.google.guava-guava-33.7.1-jre created (now ec500cb3) github-bot
• (flink-connector-jdbc) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now 2fb499ae) github-bot
• (flink-connector-jdbc) branch main updated: [FLINK-41208][connector-jdbc] Only accept TYPE_SCROLL_INSENSITIVE for exactly-once JdbcSource martijnvisser
• (flink-connector-jdbc) branch main updated: [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs martijnvisser
• (flink) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now fed41e402e3) github-bot
• (flink) branch dependabot/maven/flink-table/com.google.guava-guava-33.7.1-jre created (now 862f75fd58f) github-bot
• (flink) branch master updated: [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA snuyanzin
• (flink) branch release-2.3 updated: [FLINK-41245][python] Fix missing allow_nested support (#29641) dianfu
• (flink) branch release-1.20 updated: [FLINK-41246][python] Fix nested Row conversion (#29643) dianfu
• (flink-agents) branch main updated: [integration][java] Send user images and documents through the OpenAI Responses API (#1275) wenjin
• (flink-benchmarks) branch master updated: [FLINK-41061] Reduce adaptive benchmark sleep frequency panyuepeng
• (flink-connector-kafka) branch v5.1 updated: [BP-5.1][FLINK-41203][docs] Help users pick between the Kafka SQL connectors (#343) martijnvisser
• (flink-connector-shared-utils) branch ci_utils updated (e182717 -> 60cefa5) martijnvisser
  • (flink-connector-shared-utils) 02/02: [FLINK-40629][ci] Honour the Maven wrapper version in the Python job martijnvisser
  • (flink-connector-shared-utils) 01/02: [FLINK-40629][ci] Keep the license check honest on Maven 3.9 martijnvisser
• (flink-connector-kafka) branch v5.0 updated: [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors (#341) martijnvisser
• (flink-connector-kafka) branch main updated: [FLINK-41203][docs] Help users pick between the Kafka SQL connectors (#340) martijnvisser
• (flink-benchmarks) branch dev-2.4 updated: [FLINK-41061] Reduce adaptive benchmark sleep frequency panyuepeng
• (flink) branch master updated: [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins gustavodemorais
• (flink) branch master updated: [FLINK-40896][table] Add built-in DEDUPLICATE_KEEP_FIRST process table function twalthr
• (flink) branch release-2.2 updated: [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose martijnvisser
• (flink) branch release-2.3 updated: [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose martijnvisser
• (flink) branch release-1.20 updated: [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose martijnvisser
• (flink) branch master updated: [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose martijnvisser
• (flink) branch release-2.4 updated: [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose martijnvisser
• (flink) branch release-2.3 updated (be5fb2b4647 -> 7186bbd3842) martijnvisser
  • (flink) 01/02: [FLINK-33186][tests] Fix flakiness in CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished (#28800) martijnvisser
  • (flink) 02/02: [FLINK-33186][tests] Re-disable periodic checkpoints in CheckpointAfterAllTasksFinishedITCase tests (#29517) martijnvisser
• (flink-connector-aws) branch main updated: [FLINK-39098] Bump `testcontainers` to 1.21.4 for Docker API compatibility fcsaky
• (flink-agents) branch main updated: [docs] Standardize Alibaba Cloud Model Studio naming (#1329) wenjin
• (flink) branch master updated: [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE panyuepeng
• (flink) branch release-2.4 updated (3ac4c5ace26 -> 0ccdfc56b91) ramin
  • (flink) 02/03: [hotfix][docs] Sync the zh VARIANT data type docs with en ramin
  • (flink) 03/03: [FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes ramin
  • (flink) 01/03: [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields ramin
• (flink-agents) branch main updated: [hotfix][python] Include NOTICE in Python distributions wenjin
• (flink) branch release-2.4 updated: [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 fanrui
• (flink-connector-jdbc) branch main updated: [FLINK-41230][build] Declare flink-connector-base as provided martijnvisser
• (flink-agents) branch main updated (4e8f7dcc4 -> 060d5f879) wenjin
• (flink) branch release-1.20 updated: [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas (#29526) dianfu
• (flink-benchmarks) branch master updated: [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 panyuepeng
• (flink) branch release-2.4 updated: [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions (#29603) dianfu
• (flink) branch master updated: [FLINK-41199][python] Decode NULL values in nested collected results (#29605) dianfu
• (flink) branch release-2.4 updated: [FLINK-41199][python] Decode NULL values in nested collected results (#29605) dianfu
• (flink-benchmarks) branch dev-2.4 updated: [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 panyuepeng
• (flink) branch release-2.3 updated: [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas (#29526) dianfu
• (flink) branch release-2.4 updated: [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas (#29526) dianfu
• (flink) branch master updated: [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas (#29526) dianfu
• (flink) branch release-2.3 updated: [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions (#29603) dianfu
• (flink) branch release-2.3 updated: [FLINK-41199][python] Decode NULL values in nested collected results (#29605) dianfu
• (flink) branch release-1.20 updated: [FLINK-41199][python] Decode NULL values in nested collected results (#29605) dianfu
• (flink) branch release-1.20 updated: [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions (#29603) dianfu
• (flink) branch master updated: [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions (#29603) dianfu
• (flink-connector-kafka) branch v5.1 created (now 04084234) martijnvisser
• (flink) branch master updated: [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 fanrui
• (flink-connector-mongodb) branch v2.0 updated: [FLINK-39098] Fix v2.0 CI: Bump testcontainers to 1.21.4, Flink to 1.20.5 and drop 1.19 fcsaky
• (flink-connector-pulsar) branch main updated: [FLINK-41009] Ignore negative Pulsar message IDs in checkpoint metadata fcsaky
• (flink-connector-kafka) annotated tag v5.1.0-rc1 updated (0399ea6e -> 0a5e74dd) martijnvisser
• (flink) branch release-2.3 updated (b33d146c13c -> f40140e5da7) panyuepeng
  • (flink) 01/02: implemented ForStFlinkFileSystem's rename API for created dirs panyuepeng
  • (flink) 02/02: added validation framework to guard for Forst and object stores panyuepeng
• (flink) branch master updated (ccdab3c44f7 -> dab40d31eba) ramin
  • (flink) 01/03: [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields ramin
  • (flink) 03/03: [FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes ramin
  • (flink) 02/03: [hotfix][docs] Sync the zh VARIANT data type docs with en ramin
• (flink) branch release-2.4 updated: [BP-2.4][FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects (#29616) ramin
• (flink-connector-kafka) branch v5.1 updated: [hotfix][docs] Add doc version data yaml martijnvisser
• (flink-connector-shared-utils) branch release_utils updated: [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases (#63) martijnvisser
• (flink-connector-http) branch main updated: [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch martijnvisser
• (flink) branch master updated: [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins gustavodemorais
• (flink-connector-shared-utils) branch release_utils updated: [FLINK-41154] Make release_utils work on macOS and Linux (#62) martijnvisser
• (flink-connector-jdbc) branch main updated: [hotfix][build] Update version to 5.0-SNAPSHOT martijnvisser
• (flink) branch release-2.4 updated: [FLINK-40936][table] Reject VARIANT elements and keys in functions and operators that compare them (#29610) ramin
• (flink-agents) branch main updated: [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) (#1160) wenjin
• (flink) branch release-2.4 updated: [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause martijnvisser
• (flink) branch master updated: [FLINK-40936][table] Reject VARIANT elements and keys in functions and operators that compare them (#29416) ramin
• (flink) branch master updated: [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG gustavodemorais
• (flink) branch master updated: [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause martijnvisser
• (flink) branch master updated: [FLINK-41065][table] Allow process table functions to exclude state entries per call twalthr
• (flink-connector-cassandra) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.4 created (now f6a8f87) github-bot
• (flink) branch release-1.20 updated: [hotfix][docs] Fix link to DataStream operators overview martijnvisser
• (flink-connector-cassandra) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 created (now 4325ad5) github-bot
• (flink-connector-cassandra) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now a69f5cf) github-bot
• (flink-connector-cassandra) branch main updated: [hotfix][ci] Skip CI on certain paths martijnvisser
• (flink) branch release-2.4 updated: [FLINK-34625][python] Fix state TTL read cache disabling (#29576) dianfu
• (flink) branch release-2.3 updated: [FLINK-34625][python] Fix state TTL read cache disabling (#29576) dianfu
• (flink) branch master updated: [FLINK-34625][python] Fix state TTL read cache disabling (#29576) dianfu
• (flink-agents) annotated tag release-0.4.0-rc1 updated (ef2636fe5 -> c13d479ff) wenjin
• svn commit: r88779 - in dev/flink/flink-agents-0.4.0-rc1: . python wenjin
• (flink-agents) branch release-0.4 updated: [hotfix][python] Include NOTICE in Python distributions wenjin
• (flink-docker) branch dev-master updated: [FLINK-41119][release] Update dev-master to point to 2.5 panyuepeng
• (flink) branch master updated: [FLINK-41122] Add version 2.5 and update nightly build action panyuepeng
• (flink) branch master updated: [FLINK-41119][release] Build docs for release-2.4 branch panyuepeng
• (flink) branch master updated: [FLINK-41178][docs/tests] Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files panyuepeng
• (flink-connector-http) branch v1.0 updated (e9a8ad6 -> ae842ea) martijnvisser
  • (flink-connector-http) 01/02: [hotfix][docs] Add docs data for the SQL connector download table martijnvisser
  • (flink-connector-http) 02/02: [hotfix] Ignore unused dependencies for snapshots martijnvisser
• (flink-docker) branch dev-2.5 created (now 1229f28) panyuepeng
  • (flink-docker) 01/01: [FLINK-41119][release] Create dev-2.5 panyuepeng
• (flink-connector-kafka) branch main updated: [FLINK-41158][build] Bump Testcontainers to 2.0.5 martijnvisser
• (flink-benchmarks) branch dev-2.4 created (now 123532a) panyuepeng
• (flink-connector-jdbc) branch v4.1 updated: [FLINK-41156][build] Bump Testcontainers to 1.21.4 martijnvisser
• (flink) branch master updated: [FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects (#29579) ramin
• (flink-connector-jdbc) branch v3.4 updated: [FLINK-41156][build] Bump Testcontainers to 1.21.4 martijnvisser
• (flink) branch master updated: [FLINK-40949][table-runtime] Update `UnsliceAssigners` `NULL` window exception message snuyanzin
• (flink) branch master updated: Update version to 2.5-SNAPSHOT panyuepeng
• (flink) branch release-2.4 created (now 40f350ad671) panyuepeng
  • (flink) 01/01: Update for 2.4.0 panyuepeng
• (flink-connector-pulsar) branch main updated: [FLINK-41009] Use a single transaction per checkpoint fcsaky
• (flink) branch master updated: [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.9 created (now 39b25b3aff5) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-2a462d8dbc created (now b40ff4e68e9) github-bot
• (flink) branch master updated: [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 martijnvisser
• (flink-connector-kafka) branch main updated: [FLINK-40621][Connectors/Kafka] Flush before fencing in producer reset test (#310) martijnvisser
• (flink-connector-cassandra) branch dependabot/maven/flink-connector-cassandra/org.apache.logging.log4j-log4j-core-2.25.3 updated (ecda1ba -> aa5a1a5) github-bot
• (flink) branch master updated: [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. panyuepeng
• (flink-connector-kafka) branch main updated (bb1ed100 -> 01e1a774) martijnvisser
  • (flink-connector-kafka) 02/02: [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes martijnvisser
  • (flink-connector-kafka) 01/02: [hotfix][tests] Honour initialDiscoveryFinished in KafkaSourceEnumeratorTest martijnvisser
• (flink) branch master updated: [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper snuyanzin
• (flink-ci-docker) branch main updated: [FLINK-41117][ci] Use ubuntu 26 in ci docker image snuyanzin
• (flink) branch master updated: [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends snuyanzin
• (flink-agents) branch main updated: Update version to 1.0-SNAPSHOT wenjin
• (flink-agents) branch release-0.4 created (now 786acbb3b) wenjin

• Earlier messages
• Later messages