Messages by Thread
-
[jira] [Commented] (FLINK-35853) Regression in checkpoint size when performing full checkpointing in RocksDB
ari (Jira)
-
[PR] [fix][improvement] Propagate nullability of the column alongside with the AlterColumnTypeEvent [flink-cdc]
via GitHub
-
[jira] [Comment Edited] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish
Mukul Gupta (Jira)
-
[jira] [Commented] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish
Mukul Gupta (Jira)
-
[PR] [hotfix][test] Move some auto-closable variables into try-block to manage the closing of objects for MassiveStringSorting.java [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed
Mika Naylor (Jira)
-
[jira] [Commented] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed
Mika Naylor (Jira)
-
[jira] [Commented] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility
Robert Metzger (Jira)
-
[PR] [Backport][FLINK-39015][table] Fix key extractor for multi join by changing GenericRowData to BinaryRowData [flink]
via GitHub
-
[PR] [FLINK-38916][FLINK-38417][FLINK-38445][FLINK-39015][table] Backport MultiJoin fixes to 2.1 [flink]
via GitHub
-
Re: [PR] [FLINK-36659][docs] Update Kafka connector docs for 4.0.0 [flink]
via GitHub
-
[jira] [Commented] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete
Taranpreet Kaur (Jira)
-
Re: [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink]
via GitHub
-
[jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Liu (Jira)
-
Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-jdbc]
via GitHub
-
Re: [PR] Bump org.assertj:assertj-core from 3.24.2 to 3.27.7 [flink-connector-jdbc]
via GitHub
-
Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc]
via GitHub
-
[jira] [Updated] (FLINK-39415) [flink-cdc-postgres] TIMESTAMPTZ type mapping causes NumberFormatException in Pipeline connector with Iceberg sink
Avichay Marciano (Jira)
-
[jira] [Comment Edited] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Dmitriy Linevich (Jira)
-
[PR] [FLINK-39415][postgres] Fix TIMESTAMPTZ type mapping in pipeline connector [flink-cdc]
via GitHub
-
Re: [PR] Cross Language Unified Event [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39415) [flink-cdc-postgres] TIMESTAMPTZ type mapping causes NumberFormatException in Pipeline connector with Iceberg sink
Avichay Marciano (Jira)
-
[jira] [Updated] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39293][table-planner] Fix MATCH_RECOGNIZE uses through view [flink]
via GitHub
-
[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)
-
[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
-
[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
-
[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
-
Re: [PR] [FLINK-38541][checkpoint] Expose checkpointing during recovery config option in documentation [flink]
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-20090][rest] Expose slot sharing group info in REST API [flink]
via GitHub
-
[jira] [Closed] (FLINK-39402) Fix LIKE quick path ignoring default escape character '\'
Timo Walther (Jira)
-
[PR] [hotfix] Fix issue with the Pull Request Labeler not finding closed PRs [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-38507][tests] Fix the failed OpenTelemetryTraceReporterITCase [flink]
via GitHub
-
[jira] [Assigned] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-38716) Describe the impact of slot.request.max-interval on balanced tasks scheduling.
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39409) Support tables without primary key for incremental snapshot
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39409][connect/postgres] Support tables without primary key for incremental snapshot [flink-cdc]
via GitHub