commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink-agents) branch main updated: [hotfix][runtime][python] Close every component when an earlier close fails (#987)
wenjin
(flink) branch master updated: [FLINK-40482][runtime] Abort checkpoint unless all tasks are RUNNING or FINISHED
fanrui
(flink) branch master updated: [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler
fanrui
(flink-kubernetes-operator) annotated tag release-1.16.0-rc2 deleted (was 117200be)
gyfora
svn commit: r87029 - in dev/flink: flink-kubernetes-operator-1.16.0-rc2 flink-kubernetes-operator-1.16.0-rc3
gyfora
(flink-kubernetes-operator) annotated tag release-1.16.0-rc3 updated (b395d61c -> c60ffc3f)
gyfora
(flink) branch fhueske-FLINK-39780-Make-TABLE-keyword-optional-in-LATERAL-context deleted (was d20007f73cb)
fhueske
(flink) branch fhueske-FLINK-39780-Make-TABLE-keyword-optional-in-LATERAL-context updated (4e197512dea -> d20007f73cb)
fhueske
(flink) 02/02: [FLINK-39780][docs] Use implicit LATERAL form in the LATERAL SNAPSHOT join docs
fhueske
(flink) 01/02: [FLINK-39780][table] Align implicit-LATERAL grammar with Calcite CALCITE-7183
fhueske
(flink-kubernetes-operator) branch release-1.16 updated (f4f45824 -> 17a29a75)
gyfora
(flink-kubernetes-operator) 02/03: [FLINK-40465] Add version-independent classes to parse job config (#1193)
gyfora
(flink-kubernetes-operator) 03/03: [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs (#1195)
gyfora
(flink-kubernetes-operator) 01/03: [FLINK-38290][operator] Keep terminal job state when job is not found
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs (#1195)
gyfora
(flink) branch master updated: [FLINK-40194][python] Add drop_duplicates to the DataFrame API (#29022)
dianfu
(flink-kubernetes-operator) branch main updated: [FLINK-40465] Add version-independent classes to parse job config (#1193)
gyfora
(flink) branch fhueske-FLINK-39780-Make-TABLE-keyword-optional-in-LATERAL-context created (now 4e197512dea)
fhueske
(flink) 02/04: [FLINK-39780][docs] Adjust documentation to implicit LATERAL table function calls
fhueske
(flink) 04/04: [FLINK-39780][docs] Adjust documentation to implicit LATERAL table function calls
fhueske
(flink) 01/04: [FLINK-39780][table] Make TABLE keyword optional in LATERAL context
fhueske
(flink) 03/04: [FLINK-39780][table] Make TABLE keyword optional in LATERAL context
fhueske
(flink-kubernetes-operator) branch main updated (91f543f0 -> 4a4b85d1)
gyfora
(flink-connector-elasticsearch) branch main updated: [FLINK-40381] Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close (#162)
wenjin
(flink-agents) branch main updated: [python][test] Fix OpenAI E2E model configuration (#1053)
wenjin
(flink) branch master updated: [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator (#28952)
panyuepeng
(flink-agents) branch main updated: [python] Reject unknown constructor arguments on chat model connections/setups (#1051)
wenjin
(flink-shaded) branch master updated: [FLINK-40459][Build/Shaded] Bump Maven from 3.8.6 to 3.9.16
martijnvisser
(flink-agents) branch main updated: [Bug] Recovered Durable ActionState for keys owned by other subtasks is never pruned (#1024)
wenjin
(flink) branch master updated: [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream
gaborgsomogyi
(flink-agents) branch main updated: [api][runtime] Replay newObject memory updates as object creations during durable recovery (#1030)
wenjin
(flink-agents) branch main updated: [tools][test][e2e] Make the bats suite fail on assertions that stop holding (#1043)
wenjin
(flink) branch master updated (f84ba2d8714 -> 122203561e9)
snuyanzin
(flink-agents) branch main updated: [runtime] Resolve relative file: URLs when loading classpath skills (#966) (#1033)
wenjin
(flink-agents) branch main updated: [python] Pin googleapis common protos below 1.72.1 (#1052)
wenjin
(flink) branch master updated: [FLINK-39889][table] Thread USING CONNECTION clause into CatalogTable and CreateTableOperation (#28385)
lihaosky
(flink) branch master updated: [FLINK-37977][table] Support `VARIANT` in user-defined functions and process table functions
snuyanzin
(flink-agents) branch main updated: [hotfix][vector-store][java] Update Elasticsearch filters documentation (#997)
wenjin
(flink-cdc) branch master updated: [FLINK-40453][postgres] Not load table schema when initializing record emitter (#4513)
hongshun
(flink) branch release-2.3 updated: [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses (#29014)
dianfu
(flink) branch master updated: [FLINK-39578][python] Include py.typed in PyFlink distribution (#28068)
dianfu
(flink) branch master updated: [FLINK-40417][python] Add with_columns/drop_columns/rename_columns to DataFrame API (#29002)
dianfu
(flink) branch master updated: [FLINK-40462][ci] Fix Build Python Wheels for GHA
snuyanzin
(flink) branch master updated: [FLINK-40457][rpc] Bump Pekko to 1.7.0
snuyanzin
(flink) branch master updated: [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry
snuyanzin
(flink) branch release-1.20 updated: [FLINK-25802][FLINK-30499][table] Fix TIMESTAMP codegen for `RANGE OVER` window bounds
snuyanzin
(flink) branch master updated: [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot (#28880)
panyuepeng
(flink) branch master updated: [FLINK-37925][table] Define `CAST` and `TRY_CAST` from `VARIANT` to scalar types
snuyanzin
(flink-agents) branch main updated: [java][python] IBM watsonx.ai chat model integration (#922)
wenjin
(flink-agents) branch main updated: [runtime][python] Refresh imports for new dependency generations (#943)
wenjin
svn commit: r86945 - dev/flink/flink-shaded-22.0-rc1
snuyanzin
(flink-shaded) annotated tag release-22.0-rc1 updated (d0c2705 -> bcdb7d7)
snuyanzin
(flink) branch master updated (6282650a754 -> d28f941743b)
gyfora
(flink) 05/06: [FLINK-40177][state-processor-api] Flattened keyed state table mapping and implementation
gyfora
(flink) 01/06: [FLINK-40176][state-processor-api] Introduce basic StateCatalog functionality
gyfora
(flink) 02/06: [FLINK-40177][state-processor-api] State table utils and type inference for keyed state
gyfora
(flink) 03/06: [FLINK-40177][state-processor-api] Serializer and runtime changes for type inference
gyfora
(flink) 06/06: [FLINK-40178][state-processor-api] Keyed state reading integration tests
gyfora
(flink-shaded) branch master updated: [hotfix] Update to 22.0 version
snuyanzin
(flink-shaded) branch master updated: [hotfix][ci] Bump setup maven action to v5
snuyanzin
(flink-shaded) branch master updated: [hotfix][ci] Bump checkout action to v7
snuyanzin
(flink-agents) branch main updated: [hotfix][e2e] Derive recovery test version from project (#1041)
wenjin
(flink) branch master updated: [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics (#28878)
panyuepeng
(flink) branch master updated (2245026dff5 -> 2624803120f)
snuyanzin
(flink) 01/02: [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes
snuyanzin
(flink) 02/02: [FLINK-40451][ci] Rebalance E2E tests between groups 2 and 3
snuyanzin
(flink) branch master updated (2624803120f -> c9be954ace0)
snuyanzin
(flink-kubernetes-operator) annotated tag release-1.16.0-rc2 updated (d6f8e843 -> 117200be)
gyfora
(flink-kubernetes-operator) annotated tag release-1.16.0-rc1 deleted (was 47af2dfc)
gyfora
svn commit: r86913 - in dev/flink: flink-kubernetes-operator-1.16.0-rc1 flink-kubernetes-operator-1.16.0-rc2
gyfora
(flink-kubernetes-operator) branch release-1.16 updated (747273b2 -> f4f45824)
gyfora
(flink-kubernetes-operator) 04/07: [FLINK-40400] Harden job artifact fetching in kubernetes operator (#1180)
gyfora
(flink-kubernetes-operator) 06/07: [FLINK-40443] Harden autoscaler metrics name parsing against complex regex (#1187)
gyfora
(flink-kubernetes-operator) 02/07: [FLINK-40413] Autoscaling example classes leak into the operator javadoc site (#1183)
gyfora
(flink-kubernetes-operator) 07/07: [FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion (#1186)
gyfora
(flink-kubernetes-operator) 05/07: [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input (#1184)
gyfora
(flink-kubernetes-operator) 03/07: [FLINK-40408] Fix NOTICE files to match dependencies (#1182)
gyfora
(flink-kubernetes-operator) 01/07: [FLINK-40401] Harden autoscaler state deserialization in kubernetes operator. Bound decompressed data size. (#1181)
gyfora
(flink) branch master updated: [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed
gustavodemorais
(flink-shaded) branch master updated: [FLINK-39570] Update dependencies to latest versions
fcsaky
(flink-agents) branch main updated: [hotfix][tools] Report RAT validation dependencies correctly (#996)
wenjin
(flink-agents) branch main updated: [runtime][python] Use descriptive thread names for the async executors (#1028)
wenjin
(flink-kubernetes-operator) branch main updated: [FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion (#1186)
rmetzger
(flink-agents) branch main updated: [integrations][java][python] Apply Anthropic native structured output (#965)
wenjin
(flink-agents) branch main updated: [infra] Add a dist and dependency review guide (#1022)
wenjin
(flink-agents) branch main updated: [plan] Map long/float and other numeric tool parameters to proper JSON Schema types (#1027)
wenjin
(flink-agents) branch main updated: [docs] Improve the documentation index page and build instructions (#1018)
wenjin
(flink-agents) branch main updated: [docs] Document preview status and security risks (#1023)
wenjin
(flink-cdc) branch master updated: [FLINK-40340][mysql] Fix schema change exception when parsing MySQL zerofill data types without unsigned keyword (#4500)
kunni
(flink) branch master updated: [FLINK-40390][table] Optimised JSON_LENGTH codegen
gustavodemorais
(flink-kubernetes-operator) branch main updated: [FLINK-40443] Harden autoscaler metrics name parsing against complex regex (#1187)
gyfora
(flink) branch master updated: [FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state
fanrui
(flink) branch master updated (a55e73d9f34 -> 80a5b18ee6a)
davidrad
(flink-agents) branch main updated: [integration][ollama] Tolerate tool schemas without a 'required' key (#1026)
wenjin
(flink-agents) branch main updated: [python] Fix jar URI construction in execution_environment.py (#1025)
wenjin
(flink-shaded) branch release-20.0 updated: [FLINK-39570] Bump Netty to 4.1.135.Final (release-20.0)
rmetzger
(flink-cdc) branch master updated: [hotfix][runtime] Respect UDF precedence during type validation (#4505)
kunni
(flink) branch master updated: [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools (#28992)
dianfu
(flink) branch master updated: [FLINK-40428][table] Drop Calcite's `LogicalSnapshot`
snuyanzin
(flink-shaded) branch release-20.0 updated: [FLINK-39570] Bump Jackson to 2.18.10 (release-20.0) (#166)
rmetzger
(flink) branch master updated: [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure (#28951)
rmetzger
(flink) branch master updated: [FLINK-40410][table-planner] Exclude VARIANT from constant folding
gustavodemorais
(flink) branch master updated: [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
gaborgsomogyi
(flink-cdc) branch master updated: [FLINK-40441][pipeline-connector][postgres] Fix HikariCP class conflict in Flink CDC Postgres connector (#4511)
kunni
(flink-kubernetes-operator) branch main updated: [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input (#1184)
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-40400] Harden job artifact fetching in kubernetes operator (#1180)
rmetzger
(flink-kubernetes-operator) branch main updated: [FLINK-40408] Fix NOTICE files to match dependencies (#1182)
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-40413] Autoscaling example classes leak into the operator javadoc site (#1183)
gyfora
(flink-kubernetes-operator) branch main updated (bf50b35d -> 82b0562b)
rmetzger
(flink-cdc) branch master updated: [FLINK-40409][runtime] CDC YAML supports inline Python UDF definition (#4501)
kunni
(flink) branch dependabot/maven/flink-python/io.opentelemetry-opentelemetry-api-1.62.0 deleted (was ab5d84512cc)
github-bot
(flink) branch master updated: [hotfix][python] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 (#28983)
dianfu
(flink) branch release-1.20 updated: [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer
fcsaky
(flink) branch release-2.3 updated: [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer
fcsaky
(flink) branch release-2.2 updated: [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer
fcsaky
(flink) branch master updated: [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer
fcsaky
(flink-cdc) branch master updated: [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits (#4503)
kunni
(flink-agents) branch main updated: [docs] Document Action trigger conditions (#977)
wenjin
(flink) branch master updated: [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker
gaborgsomogyi
(flink) branch dependabot/maven/flink-python/io.opentelemetry-opentelemetry-api-1.62.0 updated (5b011d754d3 -> ab5d84512cc)
dianfu
(flink) branch 28983 deleted (was ab5d84512cc)
dianfu
(flink) branch 28983 created (now ab5d84512cc)
dianfu
(flink) 01/01: relocate opentelemetry
dianfu
(flink) branch master updated: [FLINK-40300][python] Fix literal expression in Python Table API (#28924)
dianfu
(flink-cdc) branch master updated: [FLINK-40411][runtime] Introduce OpenAI-compatible model client (#4507)
yux
退订
Jacky Lau
退订
Jacky Lau
(flink) branch master updated: [FLINK-40190][python] Introduce PyFlink DataFrame creation and conversion APIs (#28934)
dianfu
(flink-connector-kafka) branch main updated: [FLINK-39888][Kafka] Allow configuring offset reset strategy independently (#267)
bli
(flink) branch dependabot/maven/flink-python/io.opentelemetry-opentelemetry-api-1.62.0 created (now 5b011d754d3)
github-bot
(flink) branch master updated: [FLINK-38469][python] Bump Apache Beam to 2.75 (#28059)
dianfu
(flink-agents) branch main updated: [infra] Derive and validate the Flink versions tools/ut.sh uses (#1007)
wenjin
(flink-agents) branch main updated: [integrations][openai] Let provider exceptions reach the caller unwrapped (#989)
wenjin
(flink) branch master updated (02a61e6af2a -> 696e6b2c63e)
dianfu
(flink-kubernetes-operator) annotated tag release-1.16.0-rc1 updated (86846f89 -> 47af2dfc)
gyfora
svn commit: r86813 - dev/flink/flink-kubernetes-operator-1.16.0-rc1
gyfora
(flink-agents) branch main updated: [integrations][azureai] Remove the deprecated Azure AI Inference integration (#988)
wenjin
(flink) branch release-2.3 updated: [FLINK-40391][table] PTF with non default convertion-class of table arg might fail
snuyanzin
(flink) branch release-2.2 updated: [FLINK-25802][FLINK-30499][table] Fix TIMESTAMP codegen for `RANGE OVER` window bounds
snuyanzin
(flink) branch release-2.3 updated: [FLINK-25802][FLINK-30499][table] Fix TIMESTAMP codegen for `RANGE OVER` window bounds
snuyanzin
(flink) branch master updated: [hotfix][ci] Bump `github-script` to v9 in `action.yml`
snuyanzin
(flink) branch master updated: [FLINK-40391][table] PTF with non default convertion-class of table arg might fail
snuyanzin
(flink-connector-kudu) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 deleted (was a32d9f1)
fcsaky
(flink-connector-kudu) branch main updated: Bump org.apache.logging.log4j:log4j-api from 2.25.4 to 2.25.5
fcsaky
(flink-kubernetes-operator) branch main updated (c305a7ce -> bf50b35d)
gyfora
(flink-kubernetes-operator) 02/02: [release] doc updates
gyfora
(flink-kubernetes-operator) 01/02: [release] Update version to 1.17-SNAPSHOT
gyfora
(flink-connector-kafka) branch main updated: [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable (#292)
rmetzger
(flink-kubernetes-operator) branch release-1.16 created (now 747273b2)
gyfora
(flink-kubernetes-operator) 01/01: [release] Docs updates
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-40389] Source parallelism is not capped at the partition count (#1179)
gyfora
(flink-agents) branch main updated: [test][python] Assert long-term memory content instead of an exact LLM item count (#984)
wenjin
(flink) branch master updated: [FLINK-40268][table] Add new JSON_TYPE built-in function
gustavodemorais
(flink-agents) branch main updated: [hotfix] Add help handling to build script (#995)
wenjin
(flink-agents) branch main updated: [ci] Name the tools script test job after the command it runs (#1000)
wenjin
(flink-agents) branch main updated: [ci][integrations] Enable Elasticsearch vector-store tests (#1011)
wenjin
(flink) branch master updated: [hotfix][docs] Add feature-flag review guidelines to AGENTS.md
roman
(flink-cdc) branch master updated: [FLINK-40313][runtime] Support nested collection functions in Transforms (#4496)
yux
(flink) branch master updated: [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager (#27579)
rmetzger
(flink) branch master updated: [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses (#28947)
dianfu
(flink) branch master updated: [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API (#28937)
dianfu
(flink-agents) branch main updated: [integrations][vector-store][java] Apply Elasticsearch KNN filters before selecting neighbors (#1001)
wenjin
(flink-agents) branch dependabot/maven/e2e-test/org.apache.logging.log4j-log4j-api-2.25.5 deleted (was 90bf30de)
github-bot
(flink) branch master updated (d9f5e05ea7a -> 2f3c205e926)
fanrui
(flink) 02/02: [FLINK-40081][test] Add CdrRecoveryRaceITCase for the non-source recovery race
fanrui
(flink) 01/02: [FLINK-40081] Harden RecordFilterContext for minimal and batch environments
fanrui
(flink) branch master updated (41f2cdb8864 -> d9f5e05ea7a)
fanrui
(flink) 04/04: [FLINK-40080][network] Remove the unbounded heap fallback from RecoveredInputChannel#requestBufferBlocking
fanrui
(flink) 01/04: [FLINK-40080][checkpoint] ChannelStateWriter#addInputDataFromSpill: replay spilled segments into the checkpoint
fanrui
(flink) 03/04: [FLINK-40080] Switch flag-on recovery to fetch->drain; retire the in-memory backend
fanrui
(flink) 02/04: [FLINK-40080][checkpoint] FetchedChannelStateDrainer: incremental drain with atomic snapshot-and-insert
fanrui
(flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now f36a9a4e)
github-bot
(flink-connector-kudu) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now a32d9f1)
github-bot
(flink-agents) branch dependabot/maven/e2e-test/org.apache.logging.log4j-log4j-api-2.25.5 created (now 90bf30de)
github-bot
(flink-connector-opensearch) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now f7c79d5)
github-bot
(flink-connector-pulsar) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now e5f9363)
github-bot
(flink-connector-jdbc) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 created (now 965f32e8)
github-bot
(flink-connector-opensearch) branch dependabot/maven/flink-connector-opensearch3/org.apache.httpcomponents.client5-httpclient5-5.6.1 deleted (was 250874a)
github-bot
(flink-connector-opensearch) branch dependabot/maven/flink-connector-opensearch3/org.apache.httpcomponents.client5-httpclient5-5.6.3 created (now f8623c3)
github-bot
(flink-connector-prometheus) branch dependabot/maven/org.apache.httpcomponents.client5-httpclient5-5.6.3 created (now 533e5e9)
github-bot
(flink-connector-opensearch) branch dependabot/maven/org.apache.httpcomponents.core5-httpcore5-h2-5.4.3 created (now 61acc80)
github-bot
(flink) branch master updated (0c576881a7d -> 41f2cdb8864)
fanrui
(flink-kubernetes-operator) branch main updated: [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 (#1170)
rmetzger
(flink) branch master updated: [FLINK-40376][formats] Support `VARIANT` type in `flink-json` converters
fcsaky
(flink-cdc) branch master updated: [FLINK-39568][runtime] Introduce AI model client function API (#4504)
yux
(flink) branch master updated: [FLINK-40271][table] Fix SQL serialization of Table API group window properties
twalthr
(flink-shaded) branch release-20.0 created (now 8b3972e)
rmetzger
(flink) branch release-2.3 updated: [FLINK-40334][table] Insert-only input should stay unmaterialized under FORCE
gustavodemorais
(flink-kubernetes-operator) branch main updated: [FLINK-40380] Document the runtime configuration and stop jobs from overriding operator config through it (#1178)
gyfora
(flink) branch master updated: [FLINK-25802][FLINK-30499][table] Fix TIMESTAMP codegen for `RANGE OVER` window bounds
snuyanzin
(flink-kubernetes-operator) branch main updated: [FLINK-40374] Fix redeploy-from-savepoint for suspended jobs (#1176)
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-40375] Fix kube-apiserver and mock-server tests silently skipped (#1177)
gyfora
(flink) branch dependabot/maven/org.apache.avro-avro-1.11.5 deleted (was fd8568ca11b)
github-bot
(flink) branch master updated: [FLINK-40056][python][docs] Upgrade Sphinx to 7.4 for flink-python docs
dianfu
(flink-connector-opensearch) branch dependabot/maven/org.apache.httpcomponents.core5-httpcore5-5.4.3 created (now 65b42d8)
github-bot
(flink-connector-prometheus) branch dependabot/maven/org.apache.httpcomponents.core5-httpcore5-5.4.3 created (now f5042a7)
github-bot
(flink) branch master updated: [FLINK-40334][table] Insert-only input should stay unmaterialized under FORCE
gustavodemorais
(flink) branch master updated (de793af8458 -> 1aaf0f26486)
snuyanzin
(flink) 01/02: [FLINK-40377][table] `MatchRecognize` fails with Unsupported `RelDataType`: `UNKNOWN` while json plan generation
snuyanzin
(flink) 02/02: [hotfix][ci] Add parallel execution to Maven compile options
snuyanzin
Earlier messages
Later messages