Messages by Thread
-
-
[PR] [api][plan][python] Add Python CEL Action condition filtering [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint [flink]
via GitHub
-
[jira] [Resolved] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based)
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint
Rui Fan (Jira)
-
[jira] [Assigned] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-40175) FLIP-599: State Catalog
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40175][State Catalog] State Catalog initial catalog functionality and keyed state support [flink]
via GitHub
-
[jira] [Updated] (FLINK-40233) JSON functions return NULL when sharing a parsed input
ASF GitHub Bot (Jira)
-
[PR] [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 [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint
Roman Khachatryan (Jira)
-
[jira] [Closed] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint
Aleksandr Savonin (Jira)
-
Re: [PR] [FLINK-40022][table] Fix TableResult.await() hang on empty SELECT result [flink]
via GitHub
-
[jira] [Closed] (FLINK-40186) Support the basic functionality of DataFrame API
Dian Fu (Jira)
-
[jira] [Assigned] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file
wenhao.yu (Jira)
-
Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39354] Fix case-insensitive existing-column lookup in SchemaUtils.applyAddColumnEvent [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector
Han You (Jira)
-
[jira] [Commented] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause
Iman Rastkhadiv (Jira)
-
[jira] [Commented] (FLINK-37297) Either type Pojo deserialization fails with NPE
Iman Rastkhadiv (Jira)
-
[jira] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39771) [JUnit5 Migration] Module: flink-cep
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
-
[jira] [Updated] (FLINK-39876) [JUnit5 Migration] Migrate flink-streaming-java assertions to AssertJ
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
-
[jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant
Jinkun Liu (Jira)
-
[jira] [Updated] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40250][table] Throw ValidationException for non-orderable types used as keys [flink]
via GitHub
-
[jira] [Created] (FLINK-40252) Graceful TaskManager termination on Kubernetes
Gangadharayya Hiremath (Jira)
-
[PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink]
via GitHub
-
[jira] [Updated] (FLINK-40251) Support Process Table Function (PTF) in Python Table API
Wang Chengyu (Jira)
-
[jira] [Created] (FLINK-40251) Support Process Table Function (PTF) in Python Table API
Wang Chengyu (Jira)
-
[PR] [FLINK-39904][table] Add GeoParquet-compatible GEOGRAPHY Parquet support [flink]
via GitHub
-
[jira] [Updated] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException
Gustavo de Morais (Jira)
-
[jira] [Assigned] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Yuepeng Pan (Jira)
-
[PR] [FLINK-40248][ci] Add nightly snapshot publishing to GHA pipeline [flink]
via GitHub
-
[jira] [Updated] (FLINK-40248) Move publishing nightly snapshots from AZP to GHA
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40248) Move publishing nightly snapshots from AZP to GHA
Dale Lane (Jira)
-
[PR] [WIP][FLINK-XXXXX][python] Add Process Table Function APIs to PyFlink [flink]
via GitHub
-
[jira] [Created] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh (Jira)
-
[jira] [Commented] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder
Nikita Singhvi (Jira)
-
[jira] [Created] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225)
Yishai Greenberg (Jira)
-
[jira] [Created] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder
Nikita Singhvi (Jira)
-
[jira] [Updated] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder
Nikita Singhvi (Jira)
-
[PR] [hotfix] Bump Flink and PostgreSQL JDBC driver to latest patch versions [flink-connector-jdbc]
via GitHub
-
[jira] [Commented] (FLINK-40244) Support YashanDB in flink-connector-jdbc
Linsert (Jira)
-
[jira] [Created] (FLINK-40244) Support YashanDB in flink-connector-jdbc
Linsert (Jira)
-
[PR] [hotfix] Remove unused JUnit 4 dependencies [flink-connector-jdbc]
via GitHub
-
Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
-
Re: [PR] [FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor` [flink]
via GitHub
-
Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink]
via GitHub
-
[jira] [Updated] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40243] Bump postgresql jdbc driver from 42.5.6 to 42.7.13 [flink-kubernetes-operator]
via GitHub
-
[jira] [Commented] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-XXXXX] add GROUP BY <int literal> [flink]
via GitHub
-
[I] [Tech Debt] Non-happy-path response handling diverges between Java and Python in OpenAI-family connections [flink-agents]
via GitHub
-
[PR] [docs] Use a current GA API version in the Azure OpenAI examples [flink-agents]
via GitHub
-
[PR] [hotfix] Ignore the local directories check-license.sh creates [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13
Siddharth R (Jira)
-
[PR] [infra] Surface the ASF generative-AI disclosure in the PR template [flink-agents]
via GitHub
-
[I] [Tech Debt] Surface the ASF generative-AI disclosure in the PR template [flink-agents]
via GitHub
-
[PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc]
via GitHub
-
[I] [integrations] Azure AI Inference SDK is deprecated and retires on 2026-08-26 [flink-agents]
via GitHub
-
Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents]
via GitHub
-
[PR] [integrations][java][python] Apply Azure OpenAI native structured output [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-34486) Add documentation on how to add the shared utils as a submodule to the connector repo
ASF GitHub Bot (Jira)
-
[PR] [FLINK-34486] Add submodule setup instructions to README [flink-connector-shared-utils]
via GitHub
-
[PR] FLINK-XXXXX: add ORDER BY ALL support [flink]
via GitHub
-
[jira] [Commented] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries
Michael (Jira)
-
[jira] [Updated] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries
Michael (Jira)
-
[jira] [Created] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries
Michael (Jira)
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
[jira] [Updated] (FLINK-40241) Support VARIANT as column type in the 'raw' format
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-40241) Support VARIANT as column type in the 'raw' format
Ramin Gharib (Jira)
-
[PR] [FLINK-40239][runtime] Support additional Flink SQL regular expression functions in YAML Transform [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40222][table] Fix precision loss for INTERVAL literals [flink]
via GitHub
-
[jira] [Updated] (FLINK-40240) Support TRY_CAST, IFNULL and NULLIF in YAML Transform
Mao Jiayi (Jira)
-
[jira] [Updated] (FLINK-40240) Support TRY_CAST, IFNULL and NULLIF in Flink CDC YAML Transform
Mao Jiayi (Jira)
-
[jira] [Commented] (FLINK-39615) Translate documentation in changelog.md to chinese
Arvind Kandpal (Jira)
-
[jira] [Commented] (FLINK-37502) Translate documentation for Disaggregated State Management into Chinese
Arvind Kandpal (Jira)
-
Re: [PR] [FLINK-39215] [python] Clean up PythonDriver tmp dir on launch failure [flink]
via GitHub
-
Re: [PR] [FLINK-36744][docs] Document operator's FlinkVersion compatibility policy [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink]
via GitHub
-
Re: [PR] apache/flink-statefun-playground:3.3.0 stil doesn't exist on docker hub [flink-statefun-playground]
via GitHub
-
Re: [PR] [FLINK-39539][table] Document changelog processing in AGENTS.md [flink]
via GitHub
-
Re: [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
Re: [PR] [FLINK-37431]We should use guava Lists instead of curator shade Lists… [flink]
via GitHub
-
[jira] [Commented] (FLINK-40230) StringToBinary and RawToBinary cast rules might generate runtime code with useless array copy
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40230) StringToBinary and RawToBinary cast rules might generate runtime code with useless array copy
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40231) HistoryServerArchiveFetcherTest.testArchiveStateTransition is flaky in CI
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40231) HistoryServerArchiveFetcherTest.testArchiveStateTransition is flaky in CI
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40240) Support additional Flink SQL regular expression functions in YAML Transform
Mao Jiayi (Jira)
-
[jira] [Created] (FLINK-40239) Support additional Flink SQL regular expression functions in YAML Transform
Mao Jiayi (Jira)
-
[PR] [FLINK-40169][table] Add target option to the EARLY_FIRE hint [flink]
via GitHub
-
[jira] [Updated] (FLINK-40238) Expose numberOfConsecutiveFailedCheckpoints as a JobManager-level gauge
Yang Li (Jira)
-
[jira] [Created] (FLINK-40238) Expose numberOfConsecutiveFailedCheckpoints as a JobManager-level gauge
Yang Li (Jira)
-
[D] [Discuss][Observability] OpenTelemetry GenAI export for Agent Traces (follow-up to #900) [flink-agents]
via GitHub
-
[PR] [hotfix][docs] Fix temporal table function expression examples [flink]
via GitHub
-
[I] [Feature] Add VLLM_CONNECTION to the ChatModel out-of-the-box [flink-agents]
via GitHub
-
[PR] [hotfix][docs] Fix FileSource monitor_continuously spelling [flink]
via GitHub
-
Re: [PR] [FLINK-34195][python] Use python3 as the default Python executable [flink]
via GitHub
-
[PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-table/flink-sql-client [flink]
via GitHub
-
[PR] [hotfix][ci] Do not run GHA if only azure pipelines are changed [flink]
via GitHub
-
Re: [PR] [FLINK-39490][runtime-web] Improve feedback when cluster is unreachable [flink]
via GitHub