Messages by Thread
-
(flink-ml) branch master updated: [hotfix] Restrict GHA to once per month
snuyanzin
-
(flink-web) branch asf-site updated (2fb78b0239 -> fef86fb0cc)
gyfora
-
(flink-kubernetes-operator) annotated tag release-1.15.0-rc2 deleted (was 0c4aa9ed)
gyfora
-
(flink-kubernetes-operator) annotated tag release-1.15.0 updated (79d730ba -> 77deebe7)
gyfora
-
svn commit: r84755 - dev/flink/flink-kubernetes-operator-1.15.0-rc2 release/flink/flink-kubernetes-operator-1.15.0
gyfora
-
(flink) branch master updated: [FLINK-38503] Adapt `DefaultClusterClientServiceLoader` to java 25
snuyanzin
-
(flink-connector-elasticsearch) branch main updated: [FLINK-39747][test] Upgrade test to junit 5 and remove junit4 dependency
guoweijie
-
(flink) branch master updated: [FLINK-39750][tests] Drop `FailsOnJava11`
snuyanzin
-
(flink) branch master updated: [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+
snuyanzin
-
(flink) branch master updated: [hotfix][docs] Fix duplicate word typos in documentation
snuyanzin
-
(flink) branch master updated: [FLINK-39619][docs] Add release notes for Flink 2.3
danderson
-
(flink) branch release-2.3 updated: [FLINK-39156][docs] Document ON CONFLICT (#28237)
gustavodemorais
-
(flink-cdc) branch master updated: [minor][hotfix][pipeline-connector/fluss] Fix CdcAsFlussRow.java file location to match package declaration
leonard
-
(flink-agents) branch main updated: [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations (#680)
xtsong
-
(flink-agents) branch main updated: [doc] Refactor the installation documentation based on install.sh (#700)
xtsong
-
(flink) branch master updated: [FLINK-39738] Use pekko ask() instead of tell() to ack the checkpoint
roman
-
(flink) branch master updated: [FLINK-39746][build] Add jdk25 profile in `common_docker.sh`
snuyanzin
-
(flink-agents) branch main updated: [INFRA] Set up default rulesets for default and release branches (#681)
xtsong
-
(flink-agents) branch infrastructure-ruleset-bot/default-branch-protection updated (ed14662f -> e14bbf65)
xtsong
-
(flink) branch release-2.1 updated: [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable (#28092)
panyuepeng
-
(flink) branch release-2.1 updated: [FLINK-39401][table-runtime] Extend raw format to support line-delimiter option (#28082)
panyuepeng
-
(flink-agents) branch release-0.1 updated (e86eb8ba -> c7c3efc0)
xtsong
-
(flink) branch master updated: [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs
lincoln
-
(flink-agents) branch release-0.2 updated: [ci] Add local rsync-deployments composite action
xtsong
-
(flink-agents) branch release-0.1 updated: [ci] Add local rsync-deployments composite action
xtsong
-
(flink-agents) branch main updated (962d5871 -> dd308754)
xtsong
-
(flink) branch master updated (91e58c24cee -> 6f422510a8f)
roman
-
(flink-benchmarks) branch master updated: [FLINK-38944][benchmark] Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner
panyuepeng
-
(flink) annotated tag release-2.3.0-rc1 updated (af1eb40210c -> 8f749e19523)
panyuepeng
-
svn commit: r84702 - in dev/flink/flink-2.3.0-rc1: . python
panyuepeng
-
(flink) branch master updated: [FLINK-39742][tests] FlinkImageBuilder checks for Java 25
snuyanzin
-
(flink-connector-aws) branch main updated: [INFRA] Set up default protection ruleset for default and release branches
fcsaky
-
(flink) branch release-2.0 updated: [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records
fanrui
-
(flink) branch release-2.1 updated: [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records
fanrui
-
(flink) branch release-2.2 updated: [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records
fanrui
-
(flink-cdc) branch master updated: [FLINK-39407][cdcup] Mount shared data volume on Flink containers for Paimon sink (#4408)
yux
-
(flink) branch release-2.2 updated: [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion
snuyanzin
-
(flink) branch master updated: [FLINK-39736][build] Do not allow Security Manager for jdk24+
snuyanzin
-
(flink) branch release-2.1 updated: [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion
snuyanzin
-
(flink-connector-kudu) branch dependabot/maven/org.apache.flink-flink-table-runtime-1.20.4 created (now 8835c75)
github-bot
-
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-api-java-2.2.1 created (now 7e3e326)
github-bot
-
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-runtime-2.2.1 created (now ac3e465)
github-bot
-
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-planner_2.12-2.2.1 created (now b57f2ec)
github-bot
-
(flink) branch master updated: [FLINK-39734][ci] Exclude 2.1 and 2.2 from GHA nightly
snuyanzin
-
(flink-agents) branch main updated: [tools]Import Wizard for Installation Setup (#599)
wenjin
-
(flink) branch master updated: [FLINK-39733][build] Do not use `net.jcip.annotations`
snuyanzin
-
(flink) branch master updated: [FLINK-39156][docs] Document ON CONFLICT
gustavodemorais
-
(flink) branch master updated: [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion
snuyanzin
-
(flink) branch master updated: [FLINK-39731][table] Port from Calcite fix for `SqlValidatorImpl` should reject `MATCH_RECOGNIZE` with duplicate `MEASURE`
snuyanzin
-
svn commit: r84678 - release/flink
fanrui
-
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/lodash-4.17.23 deleted (was f5640b6bf76)
github-bot
-
(flink) branch master updated: [hotfix] Fix compiliation for java 11 (#28225)
fhueske
-
(flink-connector-kafka) branch main updated: [FLINK-39705] Remove Zookeeper references
fanrui
-
(flink) branch master updated: [hotfix][doc] Add flink-s3-fs-native in AGENTS.md
gaborgsomogyi
-
(flink-connector-http) annotated tag v1.0.0-rc2 updated (e9a8ad6 -> 94ed2c8)
davidrad
-
svn commit: r84673 - dev/flink/flink-connector-http-1.0.0-rc2
davidrad
-
(flink) branch master updated: [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics (#28199)
fhueske
-
(flink-agents) branch main updated: [build] Ignore .claude directory
xtsong
-
(flink) branch master updated: [FLINK-39709][s3]Update documentation for native-s3 Implementation (#28200)
gaborgsomogyi
-
(flink) branch master updated: [hotfix][docs] Fix incorrect HashMapStateBackend recommendations (#28094)
davidrad
-
(flink) branch master updated (0515b156355 -> a9c40d34d95)
snuyanzin
-
(flink) branch master updated (4644cabd8bf -> 0515b156355)
davidrad
-
(flink-connector-elasticsearch) branch main updated: [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders
guoweijie
-
(flink) branch release-2.2 updated: [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings
snuyanzin
-
(flink) branch release-1.20 updated: [FLINK-39714][docs] Add AGENTS.md and AI disclosure
snuyanzin
-
(flink-agents) branch main updated (cc4362df -> 2fa1a3d6)
wenjin
-
(flink) branch release-2.3 updated: [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings
snuyanzin
-
(flink) branch release-2.3 updated: [FLINK-39714][docs] Add AGENTS.md
snuyanzin
-
(flink) branch release-2.2 updated: [FLINK-39714][docs] Add AGENTS.md and AI disclosure
snuyanzin
-
(flink) branch release-2.0 updated: [FLINK-39714][docs] Add AGENTS.md and AI disclosure
snuyanzin
-
(flink) branch release-2.1 updated: [FLINK-39714][docs] Add AGENTS.md and AI disclosure
snuyanzin
-
(flink) branch master updated: [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG (#28164)
fhueske
-
(flink-agents) branch main updated (989a92e3 -> cc4362df)
wenjin
-
(flink) branch master updated (4ac4c4a08e0 -> 3c7a45a61b3)
arvid
-
(flink-connector-elasticsearch) branch main updated: [FLINK-39716] Fix time unit for network timeout options
guoweijie
-
(flink) branch master updated (9a72fde4824 -> 4ac4c4a08e0)
arvid
-
(flink) branch release-2.1 updated: [FLINK-39672][docs] Document Java records as supported POJO types
leonard
-
(flink) branch release-2.3 updated: [FLINK-39672][docs] Document Java records as supported POJO types
leonard
-
(flink) branch release-2.2 updated: [FLINK-39672][docs] Document Java records as supported POJO types
leonard
-
(flink) branch release-1.20 updated: [FLINK-39672][docs] Document Java records as supported POJO types
leonard
-
(flink) branch release-2.0 updated: [FLINK-39672][docs] Document Java records as supported POJO types
leonard
-
(flink-connector-elasticsearch) branch v4.0 updated: [FLINK-39706][ci] Add flink 2.1 testing for v4.0 branch (#150)
wenjin
-
(flink-connector-elasticsearch) branch main updated: [FLINK-39706][ci] Remove flink 2.1 testing from es connector main branch (#149)
wenjin
-
(flink-cdc) branch master updated: [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation (#4401)
yux
-
(flink) branch dependabot/uv/flink-python/docs/idna-3.15 created (now da75b22852b)
github-bot
-
(flink-connector-kafka) branch main updated (aba208f6 -> ab300d26)
fanrui
-
(flink-connector-kafka) branch main updated: [hotfix] Bump flink.version to 2.1.2
fanrui
-
(flink-connector-kafka) branch main updated (0caa1c9c -> 887d5941)
fanrui
-
(flink-connector-elasticsearch) branch main updated: [FLINK-38721] Support vector search for es connector. (#137)
wenjin
-
(flink-agents) branch main updated: [hotfix] Make Ollama embedding test actually run in CI (#686)
wenjin
-
(flink-agents) branch main updated: [hotfix] Move chat-model os.environ mutations out of module scope in e2e tests (#689)
wenjin
-
(flink) branch master updated: [FLINK-39662][table] Support `ALTER MATERIALIZED TABLE ... SET (...)` conversion
snuyanzin
-
(flink) branch master updated: [hotfix] Fix misprint in upload artifact condition
snuyanzin
-
(flink) branch master updated: [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings
roman
-
(flink) branch master updated: [hotfix] Bump download-artifact action to v8 as GHA requires
snuyanzin
-
(flink) branch release-1.20 updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python
snuyanzin
-
(flink) branch master updated: [FLINK-39503][runtime-web] Auto-fit "Job Overview" DAG height and add recenter control
fcsaky
-
(flink-connector-http) branch main updated: [FLINK-39689] Make template placeholders consistent
fcsaky
-
(flink) branch master updated: [FLINK-39685][table] Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements
gaborgsomogyi
-
(flink) branch master updated: [FLINK-39663][table] Support `ALTER MATERIALIZED TABLE ... RESET (...)` conversion
snuyanzin
-
(flink) branch master updated: [hotfix][ci] Bump artifact-upload version
snuyanzin
-
(flink-agents) branch main updated (66225cd7 -> 5182f253)
wenjin
-
(flink) branch master updated: [FLINK-39377][table] Add initial implementation of ProcessTableFunctionTestHarness (#27928)
fhueske
-
(flink-cdc) branch master updated: [FLINK-39682] Fix unable to invoke TO_DATE with TIMESTAMP types (#4397)
yux
-
(flink) branch master updated: [hotfix][flink-tests] Fix duplicated dependency & plugin (#28023)
davidrad
-
(flink) branch release-2.3 updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python
snuyanzin
-
(flink) branch master updated (b5a1575f4b4 -> 1c61abced02)
leonard
-
(flink) branch release-2.1 updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python
snuyanzin
-
(flink-kubernetes-operator) branch main updated: [FLINK-39646][examples] Update python example to Flink 2.2 (#1111)
fanrui
-
(flink) branch master updated: [FLINK-39666][table] Fix edge-case bugs in TO_TIMESTAMP_LTZ precision handling
twalthr
-
(flink) branch release-2.0 updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python
snuyanzin
-
(flink) branch release-2.2 updated: [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python
snuyanzin
-
(flink-connector-http) branch main updated: [hotfix] Fix weekly CI branches
fcsaky
-
(flink) branch master updated: [FLINK-39616][docs] Document ORDER BY usage with FROM_CHANGELOG (#28166)
fhueske
-
(flink-cdc) branch master updated: [FLINK-39696][runtime] Use source partition for distributed flush events (#4400)
yux
-
(flink-agents) branch main updated: [api] Specify model in ChatModelSetup (Java + Python) (#685)
wenjin
-
(flink-connector-elasticsearch) branch v3.1 updated: [hotfix] Disable zk ha to fix weekly ci
guoweijie
-
(flink-connector-elasticsearch) branch v4.0 updated (4efa4be -> 73e71a2)
guoweijie
-
(flink-agents) branch main updated: [integrations][java] Fix OpenSearchVectorStore for Amazon OpenSearch Serverless (#678)
wenjin
-
(flink-agents) branch main updated: [test] Enable e2e test for long-term memory after bump to flink 2.2.1
wenjin
-
(flink-agents) branch main updated: [Feature][Integration][Java] Add Milvus vector store integration (#663)
wenjin
-
(flink-cdc) branch master updated: Set up default protection ruleset for default and release branches (#4399)
yux
-
(flink-cdc) branch infrastructure-ruleset-bot/default-branch-protection deleted (was 71fd80309)
yux
-
(flink-cdc) branch master updated: [FLINK-39684] Fix PaimonWriterHelper NullPointerException when handling REPLACE events (#4398)
yux
-
(flink) branch master updated: [FLINK-39647] Downgrade presto-hive to 0.294
snuyanzin
-
(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) 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) branch asf-site updated (bcd5e8c3a5 -> d3a9d442f5)
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) branch test-3.1 deleted (was 0bde96e)
guoweijie
-
(flink-connector-elasticsearch) branch debug-weekly-ci created (now fd4fe0e)
guoweijie
-
(flink-connector-elasticsearch) branch test-3.1 updated (6d57871 -> 0bde96e)
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-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