commits
Thread
Date
Earlier messages
Messages by Thread
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/hono-4.13.1 created (now 68671cd8e27)
github-bot
(flink) branch master updated: [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode (#28500)
panyuepeng
(flink) branch master updated: [FLINK-40169][table] Add target option to the EARLY_FIRE hint (#28827)
panyuepeng
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.3.1 created (now bf1ddee7833)
github-bot
(flink) branch dependabot/maven/flink-docs/org.jsoup-jsoup-1.23.1 created (now 4a3777dda89)
github-bot
(flink) branch master updated: [hotfix][ci] Bump GitHub script action to version 9
snuyanzin
(flink) branch master updated: [FLINK-40345][checkpoint] Do not recycle the failed buffer twice in FilteringHandler
fanrui
(flink-kubernetes-operator) branch dependabot/maven/flink-kubernetes-docs/org.jsoup-jsoup-1.23.1 created (now 870c9881)
github-bot
(flink-kubernetes-operator) branch main updated: [FLINK-40341] Bump jackson-bom to 2.21.5 (#1171)
gyfora
(flink-cdc) branch master updated: [FLINK-40223][runtime] Support additional Flink SQL string functions in YAML Transform (#4488)
yux
(flink-cdc) branch master updated: [FLINK-40337][runtime] Preserve operator precedence in generated Janino expressions (#4499)
yux
(flink) branch snuyanzin-patch-1 created (now 3d633b50584)
snuyanzin
(flink) 01/01: [hotfix][ci] Bump GitHub script action to version 9
snuyanzin
(flink-agents) branch main updated (334c0cd3 -> 432e90d8)
wenjin
(flink-agents) 03/03: [e2e] Stabilize standalone example tests
wenjin
(flink-agents) 02/03: [python] Synchronize Chroma client initialization
wenjin
(flink-agents) 01/03: [infra] Ignore local Codex configuration
wenjin
(flink) branch master updated: [FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads
fcsaky
(flink) branch master updated: [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter
fanrui
(flink) branch master updated: [FLINK-40339][table] Do not read buffer entries after removing them
gustavodemorais
(flink) branch release-1.20 updated: [FLINK-40143][core] Fix displayed restart strategy for config option based restart strategies
fcsaky
(flink-agents-demos) branch main updated: Update Flink Agents to 0.3.1 (#8)
sxnan
(flink) branch master updated: [FLINK-39984][runtime][webUI] Support LITE/FULL thread dump modes
tangyun
(flink) branch master updated (5eb36d43879 -> 90dcc69fd4e)
gustavodemorais
(flink-agents) branch main updated: [e2e] Add nightly e2e test for submitting examples to flink standalone cluster (#708)
wenjin
(flink-kubernetes-operator) branch main updated: [FLINK-39356] Fix NPE during FlinkStateSnapshot cleanup when status is null (#1169)
gyfora
(flink) branch master updated: [FLINK-40270][connector-base][runtime] Make source threads job-attributable via MDC propagation and thread names
roman
(flink) branch master updated: [FLINK-40332][table] Prevent path traversal in FileCatalogStore catalog names
gaborgsomogyi
(flink-kubernetes-operator) branch main updated: [FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect (#1152)
gyfora
(flink) branch release-2.3 updated: [FLINK-40324][table] Append-only should stay unmaterialized without an ON CONFLICT clause
gustavodemorais
(flink) branch release-1.20 updated (378f8081b3f -> 9e051eb66df)
snuyanzin
(flink) 01/03: [FLINK-40307][table] `RestoreTestCompletenessTest` was never executed in CI
snuyanzin
(flink) 03/03: [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements
snuyanzin
(flink) 02/03: [FLINK-40284][tests] Make tests ending with `Tests` executing in CI
snuyanzin
(flink) branch release-2.2 updated (2e995ffa29e -> e76147fe65c)
snuyanzin
(flink) 01/04: [FLINK-40307][table] `RestoreTestCompleteness` was never executed in CI
snuyanzin
(flink) 03/04: [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements
snuyanzin
(flink) 04/04: [FLINK-40317][tests] Make DeletesByKeySemanticTests more stable
snuyanzin
(flink) 02/04: [FLINK-40284][tests] Make tests ending with `Tests` executing in CI
snuyanzin
(flink-kubernetes-operator) branch main updated: [FLINK-39881] Add AGENTS.md and generative AI tooling disclosure to PR template (#1133)
gyfora
(flink-agents) branch main updated: [hotfix][runtime] Close the Kafka consumer when the producer fails to close (#948)
wenjin
(flink) branch master updated: [FLINK-40305][core] Decode `VARIANT` strings and object keys as UTF-8
snuyanzin
(flink) branch release-2.3 updated (f01cf8cd6b7 -> 61060af3d7d)
snuyanzin
(flink) 02/05: [FLINK-40285][table] `MLPredictSemanticTests` fails because of `ON CONFLICT`
snuyanzin
(flink) 03/05: [FLINK-40317][tests] Make DeletesByKeySemanticTests more stable
snuyanzin
(flink) 01/05: [FLINK-40307][table] `RestoreTestCompleteness` was never executed in CI
snuyanzin
(flink) 04/05: [FLINK-40284][tests] Make tests ending with `Tests` executing in CI
snuyanzin
(flink) 05/05: [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements
snuyanzin
(flink) branch master updated: [FLINK-18476][python] `PythonEnvUtils#testStartPythonProcess` might fail
snuyanzin
(flink) branch master updated: [FLINK-40324][table] Append-only should stay unmaterialized without an ON CONFLICT clause
gustavodemorais
(flink-cdc) branch master updated: [FLINK-40239][runtime] Support additional Flink SQL regular expression functions in YAML Transform (#4491)
kunni
(flink-agents) branch main updated: [api][yaml] Add aliases for six unaliased resource implementations (#962)
wenjin
(flink-kubernetes-operator) branch main updated: [FLINK-40164] Complete the suspend when the cancellation is observed (#1168)
gyfora
(flink-agents) branch main updated: [infra] Surface the ASF generative-AI disclosure in the PR template (#933)
wenjin
(flink) branch release-1.20 updated: [FLINK-40322][python] Fix Array/Multiset from_sql_type to decode elements (#28912)
dianfu
(flink) branch release-2.2 updated: [FLINK-40322][python] Fix Array/Multiset from_sql_type to decode elements (#28912)
dianfu
(flink) branch release-2.3 updated: [FLINK-40322][python] Fix Array/Multiset from_sql_type to decode elements (#28912)
dianfu
(flink) branch master updated: [FLINK-40322][python] Fix Array/Multiset from_sql_type to decode elements (#28912)
dianfu
(flink) branch release-2.1 updated (b60607179c7 -> 903b3424ae3)
snuyanzin
(flink) 02/05: [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterTest`
snuyanzin
(flink) 04/05: [FLINK-40284][tests] Make tests ending with `Tests` executing in CI
snuyanzin
(flink) 05/05: [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements
snuyanzin
(flink) 03/05: [FLINK-40307][table] was never executed in CI
snuyanzin
(flink) 01/05: [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest`
snuyanzin
(flink) branch master updated (6d8ce98dd3e -> 3c8740f3f24)
roman
(flink-cdc) branch master updated: [FLINK-40274][cdc-cli] Remove unsupported kubernetes-session from target option help message (#4493)
yux
(flink-agents) branch main updated: [infra] Add a Python-Java bridge review guide (#957)
wenjin
(flink) branch release-2.3 updated (64d92834966 -> 5e5e73d0966)
fanrui
(flink) 01/02: [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase
fanrui
(flink) 02/02: [FLINK-40269][runtime] Fix channel state assignment for duplicate connections
fanrui
(flink) branch release-2.2 updated (aa28ac2d581 -> f66c02ef10f)
fanrui
(flink) 01/02: [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase
fanrui
(flink) 02/02: [FLINK-40269][runtime] Fix channel state assignment for duplicate connections
fanrui
(flink) branch release-2.0 updated (143acd3d9b7 -> 654354dcdab)
fanrui
(flink) 02/02: [FLINK-40269][runtime] Fix channel state assignment for duplicate connections
fanrui
(flink) 01/02: [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase
fanrui
(flink) branch release-2.1 updated (3b4f2fecf55 -> b60607179c7)
fanrui
(flink) 01/02: [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase
fanrui
(flink) 02/02: [FLINK-40269][runtime] Fix channel state assignment for duplicate connections
fanrui
(flink) branch release-1.20 updated (952f34bfa49 -> 59f2705f245)
fanrui
(flink) 01/02: [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase
fanrui
(flink) 02/02: [FLINK-40269][runtime] Fix channel state assignment for duplicate connections
fanrui
(flink-agents) branch dependabot/maven/e2e-test/org.apache.logging.log4j-log4j-core-2.25.4 created (now 0eba74ac)
github-bot
(flink-agents) branch main updated: [dist][runtime] Use Flink-provided Log4j dependencies (#954)
wenjin
(flink-agents) branch main updated: [docs] Correct the documented provider for the azure YAML alias (#963)
wenjin
(flink-agents) branch main updated: [hotfix][java][python] Release skill repositories on any load failure and remove dead code (#951)
wenjin
(flink-agents) branch main updated: [integrations][java][python] Apply Azure OpenAI native structured output (#930)
wenjin
(flink-kubernetes-operator) branch main updated: [FLINK-39953] Fix cluster deletion timeout silently swallowed during upgrade (#1138)
gyfora
(flink) branch release-2.3 updated: [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest`
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40283][tests] Rename `CorrelateITCase2` to `Correlate2ITCase` to make executing while CI/local tests
snuyanzin
(flink) branch release-2.3 updated: [FLINK-40283][tests] Rename `CorrelateITCase2` to `Correlate2ITCase` to make executing while CI/local tests
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40283][tests] Rename `CorrelateITCase2` to `Correlate2ITCase` to make executing while CI/local tests
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest`
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest`
snuyanzin
(flink) branch release-2.3 updated: [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterITCase`
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterITCase`
snuyanzin
(flink-agents) branch main updated: [integration][gemini] Synthesize a tool-call id when the API omits functionCall.id (#960)
wenjin
(flink-cdc) branch master updated: [FLINK-40007][connect/postgres] Fix snapshot fetch size conf does not take effect (#4453)
yux
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-086ee281ad created (now ffad1bef861)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/ip-address-10.4.0 created (now b081d5cb7e0)
github-bot
(flink) branch master updated (17c70e8f7ba -> 6d8ce98dd3e)
snuyanzin
(flink) 03/05: [FLINK-40307][table] `RestoreTestCompleteness` was never executed in CI
snuyanzin
(flink) 02/05: [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterTest`
snuyanzin
(flink) 01/05: [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest`
snuyanzin
(flink) 05/05: [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements
snuyanzin
(flink) 04/05: [FLINK-40284][tests] Make tests ending with `Tests` executing in CI
snuyanzin
(flink) branch master updated: [hotfix][ci] Add ignore pattern in case of Azure
snuyanzin
(flink) branch master updated (12197ea92a5 -> ae9449e6bb5)
snuyanzin
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f81135e8b5 deleted (was e4112c97c56)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-a19ccc8885 created (now e575974c023)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-21.2.19 created (now a1a5a7ea863)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f81135e8b5 created (now e4112c97c56)
github-bot
(flink) branch master updated: [FLINK-40285][table] `MLPredictSemanticTests` fails because of `ON CONFLICT`
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40236][python] Fix _infer_type inferring array element type with a leading None (#28819)
dianfu
(flink) branch release-2.3 updated: [FLINK-40236][python] Fix _infer_type inferring array element type with a leading None (#28819)
dianfu
(flink) branch master updated: [FLINK-40236][python] Fix _infer_type inferring array element type with a leading None (#28819)
dianfu
(flink) branch dependabot/uv/flink-python/docs/soupsieve-2.8.4 deleted (was 1361abb3c19)
github-bot
(flink) branch master updated: [hotfix][python] Bump soupsieve from 2.8.3 to 2.8.4 (#28812)
dianfu
(flink) branch master updated: [FLINK-40256][docs] Include sub-package config options in the configuration reference
roman
(flink) branch master updated: [FLINK-40288][table] Use correct type in `ExprCodeGenerator#visitFieldAccess`
snuyanzin
(flink) branch master updated: [FLINK-40283][tests] Rename `CorrelateITCase2` to `Correlate2ITCase` to make executing while CI/local tests
snuyanzin
(flink) branch master updated: [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests`
snuyanzin
(flink-kubernetes-operator) branch main updated: [FLINK-40162] Handle UpgradeFailureException in FlinkSessionJobController (#1166)
gyfora
(flink-agents) branch main updated: [hotfix] Ignore the local directories check-license.sh creates (#934)
wenjin
(flink-agents) branch main updated: [python] warn when an action declares a return value (#835)
wenjin
(flink) branch master updated: [FLINK-40187][python] Introduce DataType class in DataFrame API (#28843)
dianfu
(flink) branch master updated: [FLINK-40168][table] Thread the EARLY_FIRE hint into the interval join
panyuepeng
(flink) branch release-2.2 updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink) branch release-2.0 updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink) branch release-2.1 updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink) branch release-2.3 updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink-agents) branch main updated: [docs] Use a current GA API version in the Azure OpenAI examples (#935)
wenjin
(flink-agents) branch main updated: [integrations][openai] Apply OpenAI native structured output (#919)
wenjin
(flink) branch master updated (e19fd025372 -> 9f867dace15)
fanrui
(flink-web) branch asf-site updated: [hotfix] Fix broken links and markup in website source
fanrui
(flink) branch master updated: [FLINK-39984][runtime] Dispatch thread dump to ioExecutor
tangyun
(flink) branch master updated: [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE
arvid
(flink) branch master updated: [FLINK-40272][build] Add cache file for checkstyle
snuyanzin
(flink) branch master updated: FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch
snuyanzin
(flink) branch master updated: Revert "[FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads (#28373)"
snuyanzin
(flink) branch master updated: [FLINK-39490][web] Improve feedback when cluster is unreachable (#27971)
panyuepeng
(flink) branch master updated: [FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads (#28373)
zakelly
(flink) branch master updated (43bb871e5d1 -> 2779964b596)
roman
(flink) 01/02: [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment
roman
(flink) 02/02: [FLINK-40208] Add Logging Context (MDC) operational docs
roman
(flink) branch release-2.2 updated: [FLINK-40227][core] Use `readFully` to read `Variant` value/metadata in `VariantSerializer.deserialize`
fcsaky
(flink) branch release-2.3 updated: [FLINK-40227][core] Use `readFully` to read `Variant` value/metadata in `VariantSerializer.deserialize`
fcsaky
(flink) branch master updated: [FLINK-40227][core] Use `readFully` to read `Variant` value/metadata in `VariantSerializer.deserialize`
fcsaky
(flink-cdc) branch master updated: [FLINK-39732][cdc-base] Introduce ObjectIdDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) (#4409)
hongshun
(flink) branch master updated: [hotfix][docs] Make the `Generated-by:` line visible in the PR template
snuyanzin
(flink) branch master updated: [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint
snuyanzin
(flink) branch release-2.3 updated (a1147e44ba1 -> 5bf06e59bab)
snuyanzin
(flink) 02/02: [FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint
snuyanzin
(flink) 01/02: [hotfix][tests] Fix SavepointDeepCopyTest checking the source directory twice
snuyanzin
(flink) branch release-2.2 updated (8ee99d59759 -> 3647b98eabc)
snuyanzin
(flink) 01/02: [hotfix][tests] Fix SavepointDeepCopyTest checking the source directory twice
snuyanzin
(flink) 02/02: [FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint
snuyanzin
(flink) branch master updated (3d23bdfbda2 -> 755671fd2ba)
roman
(flink) 02/02: Revert "[FLINK-40208] Add Logging Context (MDC) operational docs"
roman
(flink) 01/02: Revert "Revert "Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment"""
roman
(flink) branch master updated (ef6633fe31f -> 3d23bdfbda2)
roman
(flink) 02/02: Revert "Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment""
roman
(flink) 01/02: Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment"
roman
(flink) branch master updated (0ecc34d3bb5 -> ef6633fe31f)
roman
(flink) 01/02: [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment
roman
(flink) 02/02: [FLINK-40208] Add Logging Context (MDC) operational docs
roman
(flink-agents) branch release-0.3 updated: [test][python] Fix Action deserialize tests on release branch (#940)
wenjin
(flink) branch master updated: [FLINK-33186][tests] Fix flakiness in CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished (#28800)
snuyanzin
(flink) branch master updated: [FLINK-39110][s3] Add CRT support in native-s3-fs
gaborgsomogyi
(flink) branch master updated: [hotfix][ci] Bump stale action to v11
snuyanzin
(flink) branch master updated: [FLINK-40214][table] Preserve JSON_OBJECTAGG key when wrapping value (#28795)
xuyangzhong
(flink) branch master updated: [FLINK-40147][s3] Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation
gaborgsomogyi
(flink-connector-jdbc) branch main updated: [hotfix] Remove unused JUnit 4 dependencies
snuyanzin
(flink-connector-jdbc) branch main updated (b01299a8 -> 2159f8c3)
snuyanzin
(flink-connector-jdbc) 02/03: [hotfix][ci] Bump setup-java action to v5
snuyanzin
(flink-connector-jdbc) 03/03: [hotfix][ci] Bump stale action to v11
snuyanzin
(flink-connector-jdbc) 01/03: [hotfix][ci] Bump checkout action to v7
snuyanzin
(flink) branch master updated: [FLINK-40022][table] Fix TableResult.await() hang on empty SELECT result
twalthr
(flink) branch master updated (9542791071b -> 69cdb54e953)
snuyanzin
(flink) 01/02: [FLINK-40255][table-planner] Remove duplicate TRY_PARSE_JSON registration
snuyanzin
(flink) 02/02: [FLINK-40255][table-planner] Fix compiled plan serde for VARIANT type
snuyanzin
(flink) branch master updated: [FLINK-37686] Do not fail on NOT_OWNED deleted files (#28801)
zakelly
(flink) branch release-2.3 updated (3024cb24f91 -> a1147e44ba1)
mapohl
(flink) 02/04: [FLINK-40010][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange
mapohl
(flink) 01/04: [FLINK-40009][tests] Enforce timeout in RescaleTimelineITCase wait helper
mapohl
(flink) 04/04: [FLINK-40067][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished
mapohl
(flink) 03/04: [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause
mapohl
(flink) branch master updated (07bcbd9f1be -> da4a182934f)
fanrui
(flink) 01/02: [FLINK-39835][runtime] Add SupportsChainAvailability and chain-level availability plumbing
fanrui
(flink) 02/02: [FLINK-39835][streaming-java] AsyncWaitOperator implements SupportsChainAvailability
fanrui
(flink) branch master updated (04bfaff82c4 -> 07bcbd9f1be)
roman
(flink) 01/02: [hotfix][tests] Fix SavepointDeepCopyTest checking the source directory twice
roman
(flink) 02/02: [FLINK-39964][state] Fix unrestorable checkpoint after CLAIM restore from native savepoint
roman
(flink) branch master updated: [FLINK-40250][table] Throw ValidationException for non-orderable types used as keys
gustavodemorais
(flink) branch master updated (12bd86b104c -> b9cadc24b7d)
fanrui
(flink) 04/04: [FLINK-39523][test] Restore during-recovery flag randomization; re-enable filtering ITCase
fanrui
(flink) 01/04: [FLINK-39523][checkpoint] RecoveryCheckpointTrigger with NOT_READY/NO_OP and a barrier-inserting in-memory implementation
fanrui
(flink) 03/04: [FLINK-39523] Thread the trigger through barrier-handler construction and the StreamTask lifecycle
fanrui
(flink) 02/04: [FLINK-39523][checkpoint] ChannelState: dispatch checkpoint start through the recovery trigger
fanrui
Earlier messages