Messages by Thread
-
-
[I] [Feature] [Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-39653) [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix build issue
Taranpreet Kaur (Jira)
-
Re: [I] [api][java] Support Agent Skill in java [flink-agents]
via GitHub
-
Re: [I] [Feature] Separate messages and arguments for prompt of chat method in BaseChatModelSetup [flink-agents]
via GitHub
-
[I] [doc] Add doc and example for introducing YAML API [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Xiqian Yu (Jira)
-
[jira] [Resolved] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Xiqian Yu (Jira)
-
[I] [Tech Debt] Update flink version after 1.20.5 & 2.1.3 release. [flink-agents]
via GitHub
-
[PR] [FLINK-XXXXX][python] Add type hints and fix docstrings in datastream/functions.py [flink]
via GitHub
-
[jira] [Commented] (FLINK-39496) Azure nightly doesn't run for newer commits for release 2.0
Hao Li (Jira)
-
[jira] [Created] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode
Yaoxuan Wu (Jira)
-
[PR] [FLINK-39714][docs] Backport AGENTS.md [flink]
via GitHub
-
[PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink]
via GitHub
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Sergey Nuyanzin (Jira)
-
[PR] FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink]
via GitHub
-
[PR] Bump idna from 3.11 to 3.15 in /flink-python/docs [flink]
via GitHub
-
[jira] [Created] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2
Mingliang Liu (Jira)
-
Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Arvind Kandpal (Jira)
-
[jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed
Arvind Kandpal (Jira)
-
[jira] [Assigned] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-39692) Several catch blocks log the message but discard the captured exception
Pavel Zeger (Jira)
-
[jira] [Created] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters
Aleksandr Savonin (Jira)
-
[PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink]
via GitHub
-
[jira] [Resolved] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs
Rui Fan (Jira)
-
[jira] [Assigned] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion
Prashant Bhardwaj (Jira)
-
[jira] [Commented] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion
Prashant Bhardwaj (Jira)
-
[jira] [Comment Edited] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Prashant Bhardwaj (Jira)
-
[jira] [Closed] (FLINK-39464) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Yuepeng Pan (Jira)
-
[jira] [Created] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Yuepeng Pan (Jira)
-
[jira] [Closed] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable
Aleksandr Savonin (Jira)
-
[jira] [Commented] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable
Aleksandr Savonin (Jira)
-
[jira] [Resolved] (FLINK-39699) Kafka connector CI failed on the main branch
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-39709) Update documentation for native-s3-fs
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39709][s3]Update documentation for native-s3 Implementation [flink]
via GitHub
-
[jira] [Created] (FLINK-39709) Update documentation for native-s3-fs
Samrat Deb (Jira)
-
[jira] [Commented] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed
Arvind Kandpal (Jira)
-
[PR] [hotfix] Fix nested-types (array, map, row, variant) coercions [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink]
via GitHub
-
[jira] [Updated] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch]
via GitHub
-
[jira] [Created] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36736][table] Fix target columns for row-level updates [flink]
via GitHub
-
[I] [Feature] Kafka ActionStateStore should tombstone pruned ActionState records after checkpoint completion [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0
Mukul Gupta (Jira)
-
[jira] [Resolved] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options
Dennis-Mircea Ciupitu (Jira)
-
[PR] [api][java] Introduce YAML API for declaring agents [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39218) Introduce Flink-Kafka Transactions Management Tool
Aleksandr Savonin (Jira)
-
[jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Arvind Kandpal (Jira)
-
[jira] [Commented] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Arvind Kandpal (Jira)
-
[PR] [FLINK-39691][operator] Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules [flink-kubernetes-operator]
via GitHub
-
[PR] [hotfix] Fix typo in upload artifact condition [flink]
via GitHub
-
[jira] [Commented] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Arvind Kandpal (Jira)
-
[jira] [Updated] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Prashant Bhardwaj (Jira)
-
[PR] [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Matthias Pohl (Jira)
-
[jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg
Arvind Kandpal (Jira)
-
[PR] [FLINK-38192][table] Improve DynamicSourceUtils exception message [flink]
via GitHub