Messages by Thread
-
-
Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink]
via GitHub
-
[jira] [Updated] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-39271] Harden session job deletion flow [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-38345][flink-connector-base] Added previousEnumerator resolution for HybridSource during checkpoint recovery [flink]
via GitHub
-
[PR] [FLINK-39438][MaxCompute] Add support for sink operation types in MaxCompute options [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39438) Add configurable sink operation (upsert/append) for MaxCompute sink in Flink CDC
Dion Ricky Saputra (Jira)
-
[jira] [Created] (FLINK-39438) Add configurable sink operation (upsert/append) for MaxCompute sink in Flink CDC
Dion Ricky Saputra (Jira)
-
[jira] [Commented] (FLINK-35104) Add kafka pipeline data source connector
dyp (Jira)
-
Re: [D] [Feature] Durable Execution Reconcile [flink-agents]
via GitHub
-
[PR] [Issue39414] TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-39422] [REST][docs] Fix OpenAPI spec for `SlotSharingGroupId`, `MetricCollectionResponseBody`, and `SerializedThrowable` custom serializers [flink]
via GitHub
-
Re: [PR] [FLINK-38893][runtime/rest] Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API [flink]
via GitHub
-
Re: [PR] [test] Avoid Chroma model download in memory test [flink-agents]
via GitHub
-
Re: [PR] Implement comma-separated parsing for chunk key columns [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39394][web] Fix job overview metrics broken when a vertex is finished [flink]
via GitHub
-
[PR] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-39256) Support ORDER BY clause in PTFs
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39256][table] Support ORDER BY clause in Process Table Functions [flink]
via GitHub
-
[jira] [Commented] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads
Martijn Visser (Jira)
-
Re: [PR] [FLINK-33100] Implement YarnJobListFetcher [flink-kubernetes-operator]
via GitHub
-
[PR] [api][runtime] Support Mem0 based Long-Term Memory in Python. [flink-agents]
via GitHub
-
Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink]
via GitHub
-
[PR] [FLINK-39377][table] Add initial implementation of ProcessTableFunctionTestHarness [flink]
via GitHub
-
[jira] [Updated] (FLINK-39377) Initial ProcessTableFunctionTestHarness implementation
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-39420] Reject temporal joins in batch mode with a clear error [flink]
via GitHub
-
[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)
Feifan Wang (Jira)
-
Re: [I] [Feature] Add Amazon Bedrock integration for chat models and embedding models [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39437) Support interruptible timers in PTFs
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39436) Allow late data to enter PTF
Timo Walther (Jira)
-
[PR] Add April 2026 Flink community update blog post [flink-web]
via GitHub
-
[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python thread mode
ASF GitHub Bot (Jira)
-
[PR] [FLINK-35180][python] Fix embedded (thread-mode) type converters [flink]
via GitHub