commits  

Messages by Thread

• (flink-connector-opensearch) branch main updated: [hotfix] Make `PackagingITCase` Windows-friendly snuyanzin
• (flink) branch master updated: [hotfix][state/tests] Dispose keyed state backend in testMapStateWithNullValue fanrui
• (flink-agents) branch main updated: [hotfix] Remove unused DurableExecutionManager.maybePruneState helper (#682) wenjin
• (flink-agents) branch main updated (2a4c858b -> cfb71270) wenjin
  • (flink-agents) 01/02: [hotfix] Embed on Python side for cross-language vector store wenjin
  • (flink-agents) 02/02: [dependency] Update flink version and constraint. wenjin
• (flink-agents) branch main updated: [api] Defensive-copy collection inputs in user-constructed events + add contract test (#677) wenjin
• (flink) branch master updated: [FLINK-39671][model-triton] Drop redundant jackson version pins; inherit BOM fcsaky
• (flink) branch master updated: [FLINK-39166][s3] Add bucket-level configuration support to Native S3 FileSystem gaborgsomogyi
• (flink) branch master updated: [hotfix] Fix missing eslint enforcement under `runtime-web` fcsaky
• (flink-connector-kudu) branch infrastructure-ruleset-bot/default-branch-protection deleted (was fa3b2c9) fcsaky
• (flink-connector-kudu) branch main updated: [INFRA] Set up default protection ruleset for default and release branches fcsaky
• (flink-agents) branch main updated: [runtime] Handle notifyCheckpointAborted to stop leaking checkpoint entries (#667) wenjin
• (flink) branch master updated: [hotfix][build] Use sparse-checkout paths for Flink template in GHA snuyanzin
• (flink-web) branch asf-site updated (d3a9d442f5 -> 2fb78b0239) martijnvisser
  • (flink-web) 01/02: CVE-2026-35194 martijnvisser
• (flink-web) branch asf-site updated (bcd5e8c3a5 -> d3a9d442f5) snuyanzin
  • (flink-web) 01/02: Add Flink 2.2.1 release snuyanzin
• (flink-agents) branch main updated: [infra] Add daily workflow to label closed issues missing fixVersion (#605) wenjin
• (flink-connector-elasticsearch) branch test-3.1 created (now 0bde96e) guoweijie
  • (flink-connector-elasticsearch) 01/01: debug guoweijie
• (flink-connector-elasticsearch) branch test-3.1 deleted (was 0bde96e) guoweijie
• (flink-connector-elasticsearch) branch debug-weekly-ci created (now fd4fe0e) guoweijie
  • (flink-connector-elasticsearch) 01/01: debug guoweijie
• (flink-connector-elasticsearch) branch test-3.1 updated (6d57871 -> 0bde96e) guoweijie
  • (flink-connector-elasticsearch) 01/01: debug guoweijie
• (flink-agents) branch main updated: [Feature][Java] Add java event listeners config (#641) wenjin
• (flink-agents) branch main updated: [runtime] Lock null-store symmetry invariant in DurableExecutionManager (#666) wenjin
• (flink-agents) branch main updated (b38ae211 -> 8174771f) wenjin
• (flink-connector-elasticsearch) branch main updated: [FLINK-39681][Connectors/ElasticSearch] Bump flink to 2.2.1 guoweijie
• (flink-agents) branch release-0.2 updated: [hotfix] Register all resource types added via Agent.addResource (#671) wenjin
• (flink-connector-elasticsearch) branch main updated: [hotfix] Update copyright year to 2026 guoweijie
• (flink-cdc) branch master updated: [FLINK-37731][pipeline-paimon]Support Postpone Bucket (#4386) kunni
• (flink-agents) branch main updated: [hotfix][docs] Revert accidental hugo-book submodule bump from #628 (#672) wenjin
• (flink) branch master updated: [FLINK-39672][docs] Document Java records as supported POJO types leonard
• (flink-web) branch asf-site updated (a70f4c5318 -> bcd5e8c3a5) leonard
  • (flink-web) 02/02: rebuild website leonard
  • (flink-web) 01/02: [hotfix] update slack invite url leonard
• (flink-agents) branch main updated: [runtime] Add comprehensive tests for ActionExecutionOperator manager classes (#659) wenjin
• (flink-connector-elasticsearch) branch main updated: [FLINK-28109][elasticsearch] Remove dead .id(key) call in RowElasticsearchEmitter guoweijie
• (flink-agents) branch main updated: [hotfix] Register all resource types added via Agent.addResource (#668) wenjin
• (flink-connector-elasticsearch) branch main updated: [hotfix] Correct branch in ci guoweijie
• (flink-agents) branch main updated: [feature][runtime] Support Fluss as ActionStateStore backend (#628) sxnan
• (flink) branch master updated: [hotfix][build] Concurrent runs for PR should be cancelled snuyanzin
• svn commit: r84507 - dev/flink/flink-connector-pulsar-4.2.0-rc1 fcsaky
• svn commit: r84506 - dev/flink/flink-connector-pulsar-4.2.0-rc1 fcsaky
• (flink-connector-pulsar) annotated tag v4.2.0-rc1 updated (ddf3cee -> c67371b) fcsaky
• (flink-connector-pulsar) branch main updated: [hotfix] Update releasing submodule fcsaky
• (flink-connector-pulsar) branch main updated: [hotfix] Update NOTICE file copyright year fcsaky
• (flink-connector-http) branch main updated: [FLINK-39506] Build with Flink version 2 (#39) davidrad
• (flink) branch master updated: [hotfix][docs] Bump externalized connector docs refs to latest minor releases (#28095) davidrad
• (flink) branch master updated: [hotfix][flink-connector-base] Fix duplicated dependency & plugin (#28024) davidrad
• (flink-docker) branch master updated: Update Dockerfiles for 2.2.1 release snuyanzin
• (flink-agents) branch main updated: [infra] Skip spotless in non-lint CI jobs to isolate code-style failures (#664) wenjin
• (flink-docker) branch dev-2.2 updated: Add GPG key for 2.2.1 release snuyanzin
• (flink) branch master updated: [FLINK-39607][s3] Add missing Nullable annotation and precondition for config gaborgsomogyi
• (flink-agents) branch main updated: [feature] Enable EventLog display in WebUI by default (#638) wenjin
• (flink-agents) branch main updated (e617645a -> 3abbb20d) wenjin
• (flink-web) branch kafka-conn-5.0.0 created (now c52ed34722) fcsaky
  • (flink-web) 01/01: Add Kafka Connector 5.0.0 fcsaky
• svn commit: r84484 - dev/flink/flink-connector-kafka-5.0.0-rc1 fcsaky
• (flink-connector-kafka) annotated tag v5.0.0-rc1 updated (2960af0e -> b1c10696) fcsaky
• (flink-connector-kafka) branch main updated: [hotfix] Update Maven Wrapper fcsaky
• (flink) branch master updated: [FLINK-39649][table] `REGEXP_EXTRACT` plan-time validation and hot-path log cleanup snuyanzin
• (flink) branch master updated: [FLINK-39632][table] Add fromChangelog() / toChangelog() convenience methods to PartitionedTable (#28128) fhueske
• (flink-connector-elasticsearch) branch main updated: [hotfix] Update ci run flink versions guoweijie
• (flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.4 created (now 3f2554f0) github-bot
• (flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 deleted (was 67feb64e) github-bot
• (flink-connector-kafka) branch main updated: [FLINK-38790] Update CI to Flink 2.2, adjust code gaborgsomogyi
• (flink-agents) branch release-0.2 updated: Fix prune state corner cases around checkpoints (#649) xtsong
• (flink-agents) branch main updated: [infra] Add bosiew.tian as collaborator on github. wenjin
• (flink-agents) branch main updated (c72f8f6f -> eca17418) wenjin
  • (flink-agents) 01/04: [api][java] Inject output format prompt after the first system prompt for ReAct agent. wenjin
  • (flink-agents) 03/04: [plan][java] Add bash tool in java. wenjin
  • (flink-agents) 04/04: [api][runtime][java] Support agent skills in Java. wenjin
• (flink-agents) branch main updated: [runtime] Support per-event-type configurable log levels for event log (#609) wenjin
• (flink) branch master updated: [FLINK-39396][table] Simplify early return condition in `SqlLikeChainChecker` snuyanzin
• (flink) branch dependabot/uv/flink-python/docs/urllib3-2.7.0 created (now 8c15883f31d) github-bot
• (flink) annotated tag release-2.2.1 updated (450c63e9618 -> f4d62a2fb2e) snuyanzin
• svn commit: r84462 - dev/flink/flink-2.2.1-rc3 release/flink/flink-2.2.1 snuyanzin
• (flink) branch master updated: [FLINK-39642][s3] Fix Illegal argument error message gaborgsomogyi
• (flink) branch master updated: [hotfix][build] Bump netty to 4.2.13.Final snuyanzin
• (flink) branch master updated: [FLINK-39647] Upgrade presto-hive to 0.297 snuyanzin
• (flink) branch master updated: [FLINK-39603][s3] Optimize NativeS3InputStream via seeks and reduce IOPS gaborgsomogyi
• (flink-web) branch asf-site updated (42fd9faf04 -> a70f4c5318) snuyanzin
  • (flink-web) 01/02: Add Flink 2.1.2 release snuyanzin
• (flink) branch master updated: [FLINK-39638][table] Make codegen reuse result of JSON parse in `JSON_VALUE`, `JSON_QUERY` snuyanzin
• (flink-docker) branch master updated: Update Dockerfiles for 2.1.2 release snuyanzin
• (flink-docker) branch dev-2.1 updated: Add GPG key for 2.1.2 release snuyanzin
• (flink) branch master updated: [FLINK-39623][table-planner] Make `CAST(BYTES AS STRING)` strict on invalid `UTF-8` snuyanzin
• (flink) annotated tag release-2.1.2 updated (eb05ad268cd -> 5cc8b8d3827) snuyanzin
• svn commit: r84437 - dev/flink/flink-2.1.2-rc2 release/flink/flink-2.1.2 snuyanzin
• (flink-web) branch asf-site updated (6f57e8c0b4 -> 42fd9faf04) snuyanzin
  • (flink-web) 01/02: Add Flink 2.0.2 release snuyanzin
• (flink-docker) branch master updated: Update Dockerfiles for 2.0.2 release snuyanzin
• (flink-docker) branch dev-2.0 updated: Add GPG key for 2.0.2 release snuyanzin
• (flink-agents) branch main updated: [doc] Update document for vector store. (#654) wenjin
• (flink-agents) branch main updated: [Doc] Update Custom Event Definition Documentation (#651) wenjin
• (flink-agents) branch main updated: [Doc] Introduce Mem0 based Long-Term Memory (#637) wenjin
• (flink) branch master updated: [FLINK-39527][JUnit5 Migration][e2e] Migrate flink-end-to-end-tests to JUnit 5 (#28040) panyuepeng
• (flink) branch master updated: [FLINK-38943][runtime] Avoid duplicate serialization in adaptive broadcast (#28135) panyuepeng
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.16 deleted (was cfb35d90a3b) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/core-20.3.16 deleted (was 634c7bc4e9e) github-bot
• (flink-connector-hive) branch main updated (98e4258c -> f94c0202) snuyanzin
  • (flink-connector-hive) 03/15: [FLINK-36085][table] Refactor SHOW operations with LIKE/ILIKE snuyanzin
  • (flink-connector-hive) 08/15: [FLINK-36369][table] Move deprecated user-visible classes in table-api-java-bridge to the legacy package snuyanzin
  • (flink-connector-hive) 10/15: [FLINK-36245] Relocate deprecated SourceFunction / SinkFunction and remove deprecated Sink V1 in 2.0 (#25331) snuyanzin
  • (flink-connector-hive) 11/15: [FLINK-36336] Remove deprecated dataset API exclude table module snuyanzin
  • (flink-connector-hive) 01/15: [FLINK-35702][parquet] support parquet read nested in nested (#24991) snuyanzin
  • (flink-connector-hive) 02/15: [hotfix][parquet] Fix dependences and variable name problems in FLINK-35702 (#25004) snuyanzin
  • (flink-connector-hive) 05/15: [FLINK-29741][scala] Remove flink-scala and flink-streaming-scala dependency exclude table module snuyanzin
  • (flink-connector-hive) 09/15: [FLINK-36366][core] Remove deprecate API in flink-core exclude connector and state part snuyanzin
  • (flink-connector-hive) 15/15: [hotfix] Dependency convergence snuyanzin
  • (flink-connector-hive) 14/15: [hotfix] Use jdk11 as minimum for Flink 2.0 snuyanzin
  • (flink-connector-hive) 12/15: [hotfix] Remove minor unused deprecated method/class snuyanzin
  • (flink-connector-hive) 13/15: [hotfix] Make it compilable with Flink 2.0-preview snuyanzin
  • (flink-connector-hive) 06/15: [FLINK-36273][table] Remove all deprecated configuration in 2.0 in flink-connector-hive module snuyanzin
  • (flink-connector-hive) 04/15: [FLINK-36249][streaming-java] Remove RestartStrategy-related configuration getters/setters that return/set complex Java objects. snuyanzin
  • (flink-connector-hive) 07/15: [FLINK-36369][table] Move deprecated user-visible classes in table-common to the legacy package snuyanzin
• (flink-connector-opensearch) branch dependabot/maven/flink-connector-opensearch3/org.apache.httpcomponents.client5-httpclient5-5.6.1 created (now 250874a) github-bot
• (flink) annotated tag release-2.0.2 updated (a2a1e271cd6 -> 139ebc674a3) snuyanzin
• svn commit: r84418 - dev/flink/flink-2.0.2-rc4 release/flink/flink-2.0.2 snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/babel/plugin-transform-modules-systemjs-7.29.4 created (now 421bd642842) github-bot
• (flink) branch release-2.3 updated: [FLINK-39641][runtime-web] Fix unstable position of the Rescales Tab (#28133) panyuepeng
• (flink) branch master updated: [FLINK-39641][runtime-web] Fix unstable position of the Rescales Tab (#28131) panyuepeng
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.2 created (now 313c81f8bb9) github-bot
• (flink) branch master updated: [FLINK-39537][table] Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG twalthr
• [I] oralce date java.lang.RuntimeException: Could not serialize event 'DataChangeEvent [flink-cdc] via GitHub
  • Re: [I] oralce date java.lang.RuntimeException: Could not serialize event 'DataChangeEvent [flink-cdc] via GitHub
  • Re: [I] oralce date java.lang.RuntimeException: Could not serialize event 'DataChangeEvent [flink-cdc] via GitHub
  • Re: [I] oralce date java.lang.RuntimeException: Could not serialize event 'DataChangeEvent [flink-cdc] via GitHub
  • Re: [I] oralce date java.lang.RuntimeException: Could not serialize event 'DataChangeEvent [flink-cdc] via GitHub
• (flink) branch master updated: [FLINK-39558][table] `LogicalUnnestRule`: use Calcite `Uncollect` rowType instead of `LogicalType` round-trip snuyanzin
• (flink) branch master updated: [FLINK-39614][table] Support `TO_CHANGELOG`: retract stream -> retract with set semantics snuyanzin
• (flink) branch master updated: [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` snuyanzin
• (flink-agents) branch main updated: [ci] Fix test failures due to event refactor. wenjin
• (flink) branch master updated: [FLINK-39225][model] Add retry support for triton inference (#27561) dianfu
• (flink-agents) branch main updated: Fix prune state corner cases around checkpoints (#603) xtsong
• (flink-kubernetes-operator) annotated tag release-1.15.0-rc2 updated (79d730ba -> 0c4aa9ed) gyfora
• (flink-kubernetes-operator) annotated tag release-1.15.0-rc1 deleted (was f06c7ea4) gyfora
• svn commit: r84385 - dev/flink/flink-kubernetes-operator-1.15.0-rc2 gyfora
• svn commit: r84384 - dev/flink/flink-kubernetes-operator-1.15.0-rc1 gyfora
• (flink-kubernetes-operator) branch release-1.15 updated: [FLINK-39618] FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-39618] FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options gyfora
• (flink-agents) branch main updated: [fix] Update flink version constraint. wenjin
• (flink) branch master updated: [hotfix][kubernetes] Minor polish codes in flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java to reduce premature and unnecessary variable declarations (#26512) panyuepeng
• (flink-agents) branch main updated (985c6d80 -> 3a828071) wenjin
  • (flink-agents) 02/02: [api][runtime] Implement Mem0LongTermMemory on the Java side wenjin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-8b8c83898a created (now 642228331b4) github-bot
• (flink-web) branch asf-site updated: Remove accidentally committed Vim swap file and update .gitignore (#848) davidrad
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-backward-compatibility/org.postgresql-postgresql-42.7.11 created (now 12e7dc3b) github-bot
• (flink-kubernetes-operator) branch dependabot/maven/flink-autoscaler-plugin-jdbc/org.postgresql-postgresql-42.7.11 created (now 784b45bb) github-bot
• (flink-web) branch asf-site updated: Add April 2026 Flink community update blog post (#839) davidrad
• (flink) branch master updated: [FLINK-37121][docs] Fix syntax and examples in create table statement doc (#28119) davidrad
• (flink) branch master updated: [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions twalthr
• (flink-web) branch asf-site updated (2e77139aa6 -> 2de15623bc) snuyanzin
  • (flink-web) 01/02: Add Flink 1.20.4 release snuyanzin
• (flink-docker) branch master updated (126315d -> 4bf53e7) snuyanzin
  • (flink-docker) 02/02: [INFRA-27887] Use pinned allowed versions for actions snuyanzin
  • (flink-docker) 01/02: [INFRA-27887] Add workflow to check if actions versions are allowed snuyanzin
• (flink) branch master updated: [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow snuyanzin
• (flink) branch master updated: [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector gaborgsomogyi
• (flink) branch master updated: [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API twalthr
• (flink) branch master updated: [hotfix][docs] Correct registerOnTime reference in PTF documentation fhueske
• (flink) branch master updated: [hotfix][docs] Fix inaccurate description of slot sharing benefit (#28109) davidrad
• (flink-docker) branch master updated: Update Dockerfiles for 1.20.4 release snuyanzin
• (flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 updated (8b784fdd -> 67feb64e) github-bot
• (flink-docker) branch dev-1.20 updated: Add GPG key for 1.20.4 release snuyanzin
• (flink-agents) branch main updated: [ci] Remove invalid api key. wenjin
• (flink) annotated tag release-1.20.4 updated (f6265b2a32f -> 4263d89167f) snuyanzin
• svn commit: r84307 - dev/flink/flink-1.20.4-rc1 release/flink/flink-1.20.4 snuyanzin
• (flink) branch release-1.20 updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink) branch release-2.2 updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink) branch release-2.3 updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink-shaded) branch master updated: [FLINK-39557] Generate correct Multi-Release JAR files for Jackson and Swagger snuyanzin
• (flink) branch master updated: [hotfix][ci] Ignore GHA build on non-code changes snuyanzin
• (flink) branch release-2.1 updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink) branch release-2.0 updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink) branch master updated: [FLINK-39561][security] Extend sensitive key redaction with missing access key patterns and user-configurable additional keys gaborgsomogyi
• (flink) branch master updated: [FLINK-39595][ci] Use GHA cache per branch snuyanzin
• (flink) branch dependabot/maven/com.squareup.okhttp3-okhttp-4.10.0.redhat-00002 deleted (was 32a5e575d4f) github-bot
• (flink) branch dependabot/maven/flink-runtime/com.squareup.okhttp3-okhttp-4.10.0.redhat-00002 deleted (was 706f6d89a26) github-bot
• (flink) branch master updated: [FLINK-39598][table] Update jline to 3.30.12 snuyanzin
• (flink-kubernetes-operator) annotated tag release-1.15.0-rc1 updated (ebc7b313 -> f06c7ea4) gyfora
• svn commit: r84293 - dev/flink/flink-kubernetes-operator-1.15.0-rc1 gyfora
• (flink-kubernetes-operator) branch release-1.15 created (now cf21e5a9) gyfora
  • (flink-kubernetes-operator) 01/01: [release] doc updates gyfora
• (flink-kubernetes-operator) branch main updated: [release] Update version to 1.16-SNAPSHOT gyfora
• (flink-kubernetes-operator) branch main updated: [hotfix] Add missing compatibility checks (#1108) gyfora
• (flink) branch master updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python snuyanzin
• (flink) annotated tag release-2.1.2-rc1 deleted (was 47f6f34d0b8) snuyanzin
• (flink-connector-pulsar) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.4 updated (bcc5f8f -> 1a536e9) github-bot
• (flink-connector-pulsar) branch dependabot/maven/org.assertj-assertj-core-3.27.7 updated (37de152 -> c10ffb4) github-bot
• (flink-connector-pulsar) branch dependabot/maven/org.apache.logging.log4j-log4j-1.2-api-2.25.4 updated (894f2d6 -> 4594090) github-bot
• (flink-connector-pulsar) branch main updated: [FLINK-38545] Fix weekly CI pipeline fcsaky
• (flink) annotated tag release-2.1.2-rc2 updated (eb05ad268cd -> 906e6807b2f) snuyanzin
• svn commit: r84275 - in dev/flink/flink-2.1.2-rc2: . python snuyanzin
• svn commit: r84274 - dev/flink/flink-2.1.2-rc1 snuyanzin
• (flink-shaded) branch dependabot/maven/flink-shaded-zookeeper-parent/flink-shaded-zookeeper-38/org.apache.zookeeper-zookeeper-3.8.6 created (now 32c18c8) github-bot
• (flink-shaded) branch master updated: [FLINK-39562] Upgrade Netty to 4.2.12.Final snuyanzin

• Earlier messages