Messages by Thread
-
-
[jira] [Commented] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Dmitriy Linevich (Jira)
-
[jira] [Updated] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish
Matthias Pohl (Jira)
-
[jira] [Updated] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish
Matthias Pohl (Jira)
-
[jira] [Resolved] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows
Zakelly Lan (Jira)
-
[jira] [Closed] (FLINK-39220) Add tests for ConditionsUtils
Gyula Fora (Jira)
-
Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39412) AddColumnEvent fails with duplicate field names when schema change events are replayed after failover
kianwee (Jira)
-
[jira] [Created] (FLINK-39412) AddColumnEvent fails with duplicate field names when schema change events are replayed after failover
kianwee (Jira)
-
[PR] [FLINK-xxxxx][cdc-common] Skip duplicate columns in AddColumnEvent to ensure idempotency [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39151][metrics] Hide warning about UnixOperatingSystemMXBean missing on Windows [flink]
via GitHub
-
Re: [PR] [hotfix] Fix invalid comments in Committer [flink]
via GitHub
-
Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams]
via GitHub
-
[PR] [docs] Document durable reconciler usage [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-39411) PTF code generation uses wrong type for table arguments — METADATA VIRTUAL columns inaccessible
Natea Eshetu Beshada (Jira)
-
[PR] [FLINK-39111][filesystem] Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations [flink]
via GitHub
-
[PR] [hotfix] Fix the value of the document parameter `IsStable`. [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-38544) Filtering record before processing with spilling strategy
ASF GitHub Bot (Jira)
-
[PR] [FLINK-38544] Add spill-to-disk for channel state recovery with filtering [flink]
via GitHub
-
[jira] [Commented] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema
Avi Sanwal (Jira)
-
Re: [PR] [FLINK-38788] [cdc connector mysql]: Fix silent failure during reconnection after credential rotation [flink-cdc]
via GitHub
-
[PR] [FLINK-39410] The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-39411) PTF code generation uses wrong type for table arguments — METADATA VIRTUAL columns inaccessible
Natea Eshetu Beshada (Jira)
-
[jira] [Resolved] (FLINK-39408) TestNameProvider broken after JUnit 5 migration
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-39111) Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-39410) The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x.
peiyu (Jira)
-
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-39410) The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x.
peiyu (Jira)
-
[jira] [Closed] (FLINK-39399) Integer overflow in HyperLogLogPlusPlus.query() causes APPROX_COUNT_DISTINCT undercount at high cardinality
Timo Walther (Jira)
-
[jira] [Updated] (FLINK-39114) Add configurable timeout
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39114][filesystem] Support configurable timeout in native-s3-fs [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39347) Flink otel reporter doesnt report any metrics
Robert Metzger (Jira)
-
[jira] [Comment Edited] (FLINK-39347) Flink otel reporter doesnt report any metrics
Paras Negi (Jira)
-
[jira] [Commented] (FLINK-39347) Flink otel reporter doesnt report any metrics
Paras Negi (Jira)
-
[jira] [Updated] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-38894][runtime/rest] Introduce the /jobs/:jobid/rescales/history endpoint in the REST API [flink]
via GitHub
-
[jira] [Resolved] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API
Yuepeng Pan (Jira)
-
[PR] Add test proving backoffLimit=-1 (unlimited retries) bug in FlinkStat… [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-39349) Support TO_CHANGELOG retract/upsert stream to upsert stream with deletion flag (4.2.2.1)
Gustavo de Morais (Jira)
-
[jira] [Commented] (FLINK-39356) FlinkStateSnapshot cleanup fails with NPE when status is null, permanently blocking CR and namespace deletion
Santwana Verma (Jira)
-
Re: [PR] [FLINK-38541][checkpoint] Expose checkpointing during recovery config option in documentation [flink]
via GitHub
-
Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
via GitHub
-
Re: [I] [Feature] Support FileEventLog to be stored by default in the FLINK_LOG_DIR directory [flink-agents]
via GitHub
-
[PR] [hotfix][docs] Add SlotSharingGroupId to OpenAPI spec generator ID schema overrides [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add SlotSharingGroupId to OpenAPI spec generator ID schema overrides [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add SlotSharingGroupId to OpenAPI spec generator ID schema overrides [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add SlotSharingGroupId to OpenAPI spec generator ID schema overrides [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-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-38895][runtime] Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API [flink]
via GitHub
-
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub