commits
Thread
Date
Earlier messages
Messages by Date
2026/07/18
(flink-cdc) branch master updated: [FLINK-40161][mysql] Log original MySQL DDL events before parsing (#4478)
kunni
2026/07/18
(flink-agents) branch release-0.3 updated: [python] Tolerate Java tool params without a description (#915)
wenjin
2026/07/18
(flink-agents) branch main updated: [python] Tolerate Java tool params without a description (#915)
wenjin
2026/07/17
(flink) 01/03: [FLINK-39522] Restructure StreamTask channel-state recovery into an async future chain
fanrui
2026/07/17
(flink) branch master updated (32afcef2ec3 -> 98ab58c023e)
fanrui
2026/07/17
(flink) 03/03: [FLINK-39522] Defer task finish until recovery completes
fanrui
2026/07/17
(flink) 02/03: [FLINK-39522][network] Remove recovery flags and the filtering-complete future from the gate API
fanrui
2026/07/17
(flink) branch flink-40020-master created (now 099a8cfbd09)
danderson
2026/07/17
(flink) branch master updated: [FLINK-40160][table] Fix casting `NaN` to `FLOAT` or `DOUBLE`
snuyanzin
2026/07/17
(flink-web) 01/01: [hotfix][docs] Remove inconsistent parameter descriptions.
panyuepeng
2026/07/17
(flink) branch hotfix_0717_01 updated (807bf84d99d -> f5b46c39ce5)
panyuepeng
2026/07/17
(flink-web) branch hotfix_0717_01 created (now 633d86409b)
panyuepeng
2026/07/17
(flink) branch master updated: [FLINK-40157][state/ForSt] Fix MapState putAll value serialization (#28762)
zakelly
2026/07/17
(flink) branch hotfix_0717_01 created (now 807bf84d99d)
panyuepeng
2026/07/17
(flink) 01/01: [hotfix][docs] Remove inconsistent parameter descriptions.
panyuepeng
2026/07/17
(flink) branch master updated: [hotfix][ci] Add more artifacts to skip GHA
snuyanzin
2026/07/17
(flink) branch release-2.2 updated: [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused
pnowojski
2026/07/17
(flink) branch release-2.3 updated: [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused
pnowojski
2026/07/17
(flink) branch master updated (a9ae79b1867 -> a8835bd3731)
pnowojski
2026/07/17
(flink) branch master updated: [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot (#28717)
gyfora
2026/07/17
(flink-connector-kafka) branch dependabot/maven/org.assertj-assertj-core-3.27.7 deleted (was 3953e566)
github-bot
2026/07/17
(flink-connector-kafka) branch dependabot/maven/org.apache.avro-avro-1.12.1 deleted (was 16295f02)
github-bot
2026/07/16
(flink-kubernetes-operator) branch main updated: [FLINK-40155][helm] Run chart CI and e2e tests on Helm 4
gyfora
2026/07/16
(flink) branch master updated: [FLINK-40153][table] Fix resolving inherited metadata columns used by watermarks in LIKE clause
lincoln
2026/07/16
(flink) branch flink-40020 created (now b3847a9a0f9)
danderson
2026/07/16
(flink) branch master updated: [FLINK-40034][runtime-web] Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 (#28710)
martijnvisser
2026/07/16
(flink) branch release-2.3 updated: [FLINK-40118][runtime-web] Use REST endpoint field instead of removed host field (#28756)
panyuepeng
2026/07/16
(flink) branch release-2.2 updated: [FLINK-40118][runtime-web] Use REST endpoint field instead of removed host field (#28755)
panyuepeng
2026/07/16
(flink) branch release-2.1 updated: [FLINK-40118][runtime-web] Use REST endpoint field instead of removed host field (#28754)
panyuepeng
2026/07/16
(flink-agents) branch release-0.3 updated: [api][java] Substitute prompt placeholders in a single pass (#908)
wenjin
2026/07/16
(flink-agents) branch main updated: [api][java] Substitute prompt placeholders in a single pass (#908)
wenjin
2026/07/16
(flink-agents) branch main updated: [infra] Add CLAUDE.md importing AGENTS.md (#910)
wenjin
2026/07/15
(flink) branch master updated: [FLINK-40118][runtime-web] Use REST endpoint field instead of removed host field (#28712)
panyuepeng
2026/07/15
(flink) branch master updated: [FLINK-40138][tests] Drive JUnit 5 lifecycle when generating migration test snapshots (#28753)
danderson
2026/07/15
(flink) 01/01: [FLINK-40138][tests] Drive JUnit 5 lifecycle when generating migration test snapshots
danderson
2026/07/15
(flink) branch flink-40138 created (now c73cacd92bb)
danderson
2026/07/15
(flink) branch release-2.3 updated: [FLINK-40138][tests] Drive JUnit 5 lifecycle when generating migration test snapshots (#28739)
danderson
2026/07/15
(flink) branch master updated: [hotfix][table] Fix compilation with jdk11
snuyanzin
2026/07/15
(flink) branch master updated: [FLINK-37925][table] Support casting from `VARIANT` to primitive types
snuyanzin
2026/07/15
(flink) branch master updated: [FLINK-39943][table] Fix nullability of IS JSON functions (#28741)
fhueske
2026/07/15
(flink-kubernetes-operator) branch main updated: [FLINK-40119] Reset deploymentReadyTimestamp on abort to prevent premature blue delete on next deploy (#1159)
gyfora
2026/07/15
(flink) branch master updated: [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check
martijnvisser
2026/07/15
(flink) branch master updated: [FLINK-39784][table] Forbid SNAPSHOT outside a LATERAL context (#28674)
fhueske
2026/07/15
(flink) branch master updated: [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism
pnowojski
2026/07/15
(flink-agents) branch main updated: [infra] Add AGENTS.md version freshness check (#903)
wenjin
2026/07/14
(flink-agents) 01/05: [dist] Add Flink 2.3 distribution and make it the default (#856)
wenjin
2026/07/14
(flink-agents) branch release-0.3 updated (86ec7052 -> ea245810)
wenjin
2026/07/14
(flink-agents) 04/05: [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 (#888)
wenjin
2026/07/14
(flink-agents) 03/05: [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope (#874)
wenjin
2026/07/14
(flink-agents) 02/05: [hotfix] Propagate action task Errors from mailbox (#880)
wenjin
2026/07/14
(flink-agents) 05/05: [tools] Keep install plan edits consistent (#899)
wenjin
2026/07/14
(flink-cdc) branch master updated (b18f95e67 -> be5399f72)
yux
2026/07/14
(flink-agents) branch main updated: [integration][openai] Update stale default model gpt-3.5-turbo to gpt-4o-mini (#906)
wenjin
2026/07/14
(flink) branch master updated: [FLINK-40095][table-planner] Fix JSON aggregation functions failing in group window aggregate (#28682)
xuyangzhong
2026/07/14
(flink-agents) branch main updated (6f020c50 -> 55ccb13e)
wenjin
2026/07/14
(flink-kubernetes-operator) branch main updated: [FLINK-40092] Finalize BlueGreen transition after deleting previous deployment (#1154)
gyfora
2026/07/14
(flink-connector-kafka) branch main updated: [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release (#283)
bli
2026/07/14
(flink) branch master updated: [FLINK-40067][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished
martijnvisser
2026/07/14
(flink) 01/01: [FLINK-40138][tests] Drive JUnit 5 lifecycle when generating migration test snapshots
danderson
2026/07/14
(flink) branch fix/migration-generator-junit5 created (now a3278fe8c2f)
danderson
2026/07/14
(flink) branch master updated: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction
mapohl
2026/07/14
(flink) branch master updated: [FLINK-40134][ci] Bump maven-rat-plugin to 0.17
snuyanzin
2026/07/14
(flink) branch FLINK-40086 deleted (was 967a4a135e6)
mapohl
2026/07/14
(flink-agents) branch main updated: [tools] Keep install plan edits consistent (#899)
wenjin
2026/07/14
(flink) 01/01: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction
mapohl
2026/07/14
(flink) branch FLINK-40086 created (now 967a4a135e6)
mapohl
2026/07/13
(flink-cdc) branch master updated: [FLINK-39777][common] Add TableId partitioning strategy configuration (#4423)
kunni
2026/07/13
(flink-agents) branch main updated: [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 (#888)
wenjin
2026/07/13
(flink-cdc) branch master updated: [docs][connect/postgres] Improve Incremental Snapshot Reading formatting and references (#4472)
yux
2026/07/13
(flink-cdc) branch master updated: [hotfix][ci] Exclude Flink compatibility modules from Javadocs generation (#4470)
yux
2026/07/13
(flink) branch master updated: [FLINK-40036][tests] Support custom MockEnvironment in multi-input harness and state-parameterized tests (#28589)
roman
2026/07/13
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-64e7abbcba deleted (was f298dd40181)
github-bot
2026/07/13
(flink) branch release-2.3 updated: [FLINK-40124][ci] Do not store cache on every run if no dependency changed
snuyanzin
2026/07/13
(flink) branch release-1.20 updated: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction (#28702)
davidrad
2026/07/13
(flink) branch release-2.2 updated: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction (#28701)
davidrad
2026/07/13
(flink) branch release-2.3 updated: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction (#28700)
davidrad
2026/07/13
(flink-connector-mongodb) branch main updated: [FLINK-40066] Update `flink-connector-parent` to 2.0.0 and Flink to 2.1.2
fcsaky
2026/07/13
(flink-connector-hbase) branch main updated: [hotfix] Match HBase version in `HBaseITCase`
fcsaky
2026/07/13
(flink-connector-hbase) branch main updated: [FLINK-40133] Update HBase version to 2.6.6
fcsaky
2026/07/13
(flink-cdc) branch master updated: [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink (#4471)
kunni
2026/07/13
(flink) branch master updated: [FLINK-40124][ci] Do not store cache on every run if no dependency changed
snuyanzin
2026/07/13
(flink-agents) branch main updated: [ci] Bound the runtime of the integration-test jobs (#892)
wenjin
2026/07/13
(flink-agents) branch main updated: [ci] Retry Ollama install and propagate download failures (#891)
wenjin
2026/07/12
(flink) branch master updated: [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase
snuyanzin
2026/07/12
(flink-agents) branch main updated: [test][python] Avoid forking MCP test server from PyFlink process (#896)
wenjin
2026/07/12
(flink) branch master updated: [hotfix][runtime-web] Fix savepointPath query parameter in JarService.runJob() (#28722)
rmetzger
2026/07/12
(flink-agents) branch main updated: [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase (#879)
wenjin
2026/07/12
(flink-agents) branch main updated: [python] Remove the Python local execution path (#882)
wenjin
2026/07/12
(flink-cdc) branch master updated: [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner (#4469)
yux
2026/07/12
(flink) branch release-1.20 updated: [FLINK-40125][ci] Add auto cancel for concurrently running jobs
snuyanzin
2026/07/12
(flink) branch release-2.2 updated: [FLINK-40125][ci] Add auto cancel for concurrently running jobs
snuyanzin
2026/07/12
(flink) branch release-2.1 updated: [FLINK-40125][ci] Add auto cancel for concurrently running jobs
snuyanzin
2026/07/12
(flink) branch release-2.3 updated: [FLINK-40125][ci] Add auto cancel for concurrently running jobs
snuyanzin
2026/07/12
(flink) branch master updated (b464b331dbd -> bfad2e8e4e9)
snuyanzin
2026/07/12
(flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 deleted (was 0c36072d)
github-bot
2026/07/11
(flink) branch master updated: [FLINK-40109] Verify Kerberos keytab logs after the YARN application is killed
martijnvisser
2026/07/11
(flink) branch master updated: [hotfix] Use `systemPropertyVariables` instead of `systemProperties`
snuyanzin
2026/07/10
(flink) 02/08: [FLINK-39521][network] BufferManager: gate credit notification behind notifyInitiallyEnabled
fanrui
2026/07/10
(flink) 06/08: [FLINK-39521][network] Convert recovered channels via the push interface; thread needsRecovery through gates
fanrui
2026/07/10
(flink) 04/08: [FLINK-39521][network] LocalInputChannel: push-based recovery state
fanrui
2026/07/10
(flink) 05/08: [FLINK-39521][network] RemoteInputChannel: push-based recovery state
fanrui
2026/07/10
(flink) 07/08: [FLINK-39521][network] Propagate needsRecovery in PartitionRequest; start view reader with zero credit
fanrui
2026/07/10
(flink) branch master updated (4732a5210a8 -> c2f0c123409)
fanrui
2026/07/10
(flink) 03/08: [FLINK-39521][network] Add RecoverableInputChannel contract and recovery sentinels
fanrui
2026/07/10
(flink) 01/08: [FLINK-39521][test] Temporarily remove during-recovery flag from ITCase randomization
fanrui
2026/07/10
(flink) 08/08: [FLINK-39521][network] CheckpointedInputGate: consume EndOfFetchedChannelStateEvent
fanrui
2026/07/10
(flink-kubernetes-operator) branch main updated: [FLINK-38795] Support Flink 2.0+ HA in standalone mode
fcsaky
2026/07/10
(flink-kubernetes-operator) branch main updated: [hotfix] Fix typos in operator documentation, comments and scripts (#1148)
fanrui
2026/07/10
(flink-agents) branch main updated: [docs] Clarify review policy (#890)
wenjin
2026/07/10
(flink-agents) branch main updated: [python] Backfill remote test coverage ahead of local execution path removal (#881)
wenjin
2026/07/10
(flink-cdc) branch master updated: [FLINK-39760][postgres] Fix missing JTS core dependency of PostgreSQL YAML connector (#4467)
kunni
2026/07/10
(flink) branch master updated: [FLINK-40111][table-planner] Fall back to retract for a keyless sink without an upsert key
twalthr
2026/07/10
(flink) branch master updated: [FLINK-40112][table-planner] Report changelog mode mismatch instead of a generic planning error
twalthr
2026/07/09
(flink) branch release-2.2 updated: [hotfix] Fix misprint in upload artifact condition
snuyanzin
2026/07/09
(flink-cdc) branch master updated: [hotfix] Bump Mockito for JDK 17 tests (#4463)
kunni
2026/07/09
(flink-connector-elasticsearch) branch v4.0 updated: [FLINK-38054] Fix OperationSerializer issue for es8 sink
guoweijie
2026/07/09
(flink) branch release-1.20 updated: [hotfix] Fix misprint in upload artifact condition
snuyanzin
2026/07/09
(flink) branch release-2.1 updated: [hotfix] Fix misprint in upload artifact condition
snuyanzin
2026/07/09
(flink) branch release-2.3 updated: [hotfix] Fix misprint in upload artifact condition
snuyanzin
2026/07/09
(flink) branch release-2.1 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run
snuyanzin
2026/07/09
(flink) branch release-2.2 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run
snuyanzin
2026/07/09
(flink) branch release-2.3 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run
snuyanzin
2026/07/09
(flink) branch release-1.20 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run
snuyanzin
2026/07/09
(flink) branch master updated: [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 (#27745)
martijnvisser
2026/07/09
svn commit: r85798 - dev/flink/flink-connector-jdbc-4.1.0-rc4
panyuepeng
2026/07/09
(flink-connector-jdbc) annotated tag v4.1.0-rc4 updated (a528bf5c -> 079d1baa)
panyuepeng
2026/07/09
svn commit: r85797 - dev/flink/flink-connector-jdbc-3.4.0-rc4
panyuepeng
2026/07/09
(flink-connector-jdbc) annotated tag v3.4.0-rc4 updated (72282c57 -> beab454c)
panyuepeng
2026/07/09
(flink) branch release-2.2 updated (1c7d62e404d -> 82c1e4eb6d1)
martijnvisser
2026/07/09
(flink) 01/05: [FLINK-39387][Test] Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
martijnvisser
2026/07/09
(flink) 02/05: [FLINK-39914][runtime] Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation (#28398)
martijnvisser
2026/07/09
(flink) 05/05: [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. (#28434)
martijnvisser
2026/07/09
(flink) 04/05: [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
martijnvisser
2026/07/09
(flink) 03/05: [FLINK-39922][runtime/test] Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain (#28425)
martijnvisser
2026/07/09
(flink) branch master updated: [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse (#27959)
fcsaky
2026/07/09
(flink-connector-aws) branch main updated: [FLINK-40065] Update `flink-connector-parent` to 2.0.0 and Flink to 2.1.2
fcsaky
2026/07/09
(flink-kubernetes-operator) branch main updated: [FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory
gyfora
2026/07/09
(flink-kubernetes-operator) branch main updated: [FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module
gyfora
2026/07/09
(flink-kubernetes-operator) branch main updated: [FLINK-40107] Group example modules under an examples aggregator pom
gyfora
2026/07/09
(flink-kubernetes-operator) branch main updated: [hotfix] Cleanup api compatibility test execution
gyfora
2026/07/09
(flink) branch master updated: [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed
martijnvisser
2026/07/09
(flink) branch master updated: [FLINK-40084][build] maven-shade-plugin does not respect multi release jars
snuyanzin
2026/07/09
(flink) 05/05: [FLINK-39520][network] Additive logging overload; widen releaseAllResources visibility
fanrui
2026/07/09
(flink) 03/05: [FLINK-39520][checkpoint] Extract AbstractInputChannelRecoveredStateHandler with concrete no-filtering/filtering handlers
fanrui
2026/07/09
(flink) branch master updated (7f770b87178 -> 8cd1c0ec657)
fanrui
2026/07/09
(flink) 02/05: [FLINK-39520][network] Decouple LocalInputChannel recovery wiring from toBeConsumedBuffers
fanrui
2026/07/09
(flink) 04/05: [FLINK-39520][network] Add InputGate#getChannel(InputChannelInfo)
fanrui
2026/07/09
(flink) 01/05: [hotfix] Report END_OF_INPUT from multiple-input processor when all inputs finished
fanrui
2026/07/08
(flink) branch master updated: [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause
mapohl
2026/07/08
(flink) branch master updated: [FLINK-40096][table] Migrate `EXPLAIN` `CTAS`/`RTAS` Explain tests to Java
snuyanzin
2026/07/08
(flink-connector-elasticsearch) branch main updated: [FLINK-38429] Improve perf for Elasticsearch 8 connector
guoweijie
2026/07/08
(flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-11.2.0.jre8 created (now 1ae7aa9f)
github-bot
2026/07/08
(flink-connector-jdbc) branch main updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#205)
panyuepeng
2026/07/08
(flink-connector-jdbc) branch v3.4 updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#207)
panyuepeng
2026/07/08
(flink-connector-jdbc) branch v4.1 updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#206)
panyuepeng
2026/07/08
(flink) branch master updated (3e3e270c98d -> a1dcc9d5bec)
martijnvisser
2026/07/08
(flink-shaded) branch master updated: [FLINK-40090][docs] Add cryptography export notice to README
martijnvisser
2026/07/08
(flink-connector-elasticsearch) branch main updated: [FLINK-38054] Fix OperationSerializer issue for es8 sink
guoweijie
2026/07/08
(flink) branch release-2.3 updated: [hotfix] Bump download-artifact action to v8 as GHA requires
snuyanzin
2026/07/08
(flink-cdc) branch master updated: [FLINK-40091][connect/paimon] Upgrade Paimon SDK to 1.4.2 (#4465)
yux
2026/07/08
(flink-agents) branch main updated: [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope (#874)
wenjin
2026/07/08
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-planner_2.12-2.2.1 deleted (was b57f2ec)
github-bot
2026/07/08
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-runtime-2.2.1 deleted (was ac3e465)
github-bot
2026/07/08
(flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-api-java-2.2.1 deleted (was 7e3e326)
github-bot
2026/07/08
(flink-connector-http) branch main updated: [FLINK-40030][connector-http] Add architecture tests (#50)
davidrad
2026/07/08
(flink-agents) branch main updated: [hotfix] Propagate action task Errors from mailbox (#880)
wenjin
2026/07/07
(flink) branch release-2.3 updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions
snuyanzin
2026/07/07
(flink-agents) branch release-0.3 updated: [python] Remove PyFlink gateway fallback from AgentConfigOptions (#867)
wenjin
2026/07/07
(flink-agents) branch main updated: [python] Remove PyFlink gateway fallback from AgentConfigOptions (#867)
wenjin
2026/07/07
(flink-agents) branch main updated: [infra] Add AGENTS.md (#878)
wenjin
2026/07/07
(flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-core/org.apache.derby-derby-10.17.1.0 created (now 0a233f6d)
github-bot
2026/07/07
(flink-docker) branch dev-master updated: [FLINK-39924] Size jemalloc narenas from container CPU allowance
roman
2026/07/07
(flink) branch master updated: [FLINK-39923][state] Fix RocksDB Statistics native memory leak (#28489)
roman
2026/07/07
(flink) branch master updated: [FLINK-40039][table] Fix `CTAS`/`RTAS` when used with set-semantic PTFs
snuyanzin
2026/07/07
(flink) branch master updated: [FLINK-36334][tests] Enable TraversableSerializerUpgradeTest
snuyanzin
2026/07/07
(flink) branch master updated: [FLINK-39715][table] Sync SQL and table api behavior for queries with sort
snuyanzin
2026/07/07
(flink) branch release-2.2 updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions
snuyanzin
2026/07/07
svn commit: r85728 - dev/flink/flink-connector-jdbc-3.4.0-rc3
panyuepeng
2026/07/07
(flink-connector-jdbc) annotated tag v3.4.0-rc3 updated (5616f5eb -> dca63b3a)
panyuepeng
2026/07/07
(flink) branch release-1.20 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit`
snuyanzin
2026/07/07
(flink) branch master updated: [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config)
martijnvisser
2026/07/07
(flink) branch master updated: [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 (#28601)
martijnvisser
2026/07/07
(flink-cdc) branch master updated: [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions (#4380)
yux
2026/07/07
(flink-agents) branch main updated: [ci] Use maintained 'temurin' distribution for setup-java (#873)
wenjin
2026/07/07
(flink) branch release-2.2 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit`
snuyanzin
2026/07/07
(flink) branch master updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions
snuyanzin
2026/07/07
(flink) branch master updated: [FLINK-32695][e2e] Migrate SqlToolbox watermark push-down source to Source V2
martijnvisser
2026/07/07
(flink) branch master updated: [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window
martijnvisser
2026/07/07
(flink) 02/02: [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest
martijnvisser
2026/07/07
(flink) branch release-2.2 updated (65428744ebe -> 387edaa04ab)
martijnvisser
2026/07/07
(flink) 01/02: [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060)
martijnvisser
2026/07/07
(flink) branch release-2.3 updated (8321c1b666d -> 0fc5a00df34)
martijnvisser
2026/07/07
(flink) 01/02: [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
martijnvisser
2026/07/07
(flink) 02/02: [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. (#28434)
martijnvisser
2026/07/06
(flink) branch release-2.1 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit`
snuyanzin
2026/07/06
(flink) branch release-2.3 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit`
snuyanzin
2026/07/06
(flink-connector-jdbc) branch v3.4 updated: [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download (#203)
panyuepeng
2026/07/06
(flink-connector-kafka) branch main updated: [FLINK-38919][docs] Document PyFlink per-cluster offsets (#280)
bli
2026/07/06
(flink) branch release-1.20 updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test
martijnvisser
2026/07/06
(flink) branch release-2.2 updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test
martijnvisser
Earlier messages