issues  

Messages by Thread

• • Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
  • Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
  • Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• [jira] [Updated] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Martijn Visser (Jira)
• [jira] [Updated] (FLINK-30932) Enabling producer metrics for KafkaSink is not documented Martijn Visser (Jira)
• [jira] [Updated] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Martijn Visser (Jira)
• [jira] [Updated] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39792) Add multi-headers metadata key to Kafka connector Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Martijn Visser (Jira)
• [jira] [Commented] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Martijn Visser (Jira)
• [PR] [runtime] Bound continuation inputs and prioritize queued async work by record start order [flink-agents] via GitHub
  • Re: [PR] [runtime] Bound continuation inputs and prioritize queued async work by record start order [flink-agents] via GitHub
• [jira] [Updated] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match ASF GitHub Bot (Jira)
• [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
  • Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• [jira] [Assigned] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [jira] [Updated] (FLINK-40582) Add SCHEMA_OF_VARIANT and SCHEMA_OF_VARIANT_AGG built-in functions Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Gustavo de Morais (Jira)
• Re: [PR] [hotfix] Fix 8 subject-verb agreement errors in Javadoc comments [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] Fix 8 subject-verb agreement errors in Javadoc comments [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• [jira] [Updated] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source ASF GitHub Bot (Jira)
• [PR] [FLINK-41054][metrics] Add exclude filter for the metric query service [flink] via GitHub
  • Re: [PR] [FLINK-41054][metrics] Add exclude filter for the metric query service [flink] via GitHub
  • Re: [PR] [FLINK-41054][metrics] Add exclude filter for the metric query service [flink] via GitHub
• [PR] [docs] Clarify shared action scope and complete agent documentation [flink-agents] via GitHub
  • Re: [PR] [docs] Clarify shared action scope and complete agent documentation [flink-agents] via GitHub
• [jira] [Created] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• [PR] [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) [flink-shaded] via GitHub
• [jira] [Updated] (FLINK-41076) Bump Netty, Jackson and ZooKeeper in flink-shaded release-21.0 Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.19.Final and Jackson to 2.21.8 in flink-shaded release-21.0 Purushottam Sinha (Jira)
• [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• [jira] [Updated] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() ASF GitHub Bot (Jira)
• [PR] [FLINK-41059][runtime] Schedule slot manager work on the main thread [flink] via GitHub
  • Re: [PR] [FLINK-41059][runtime] Schedule slot manager work on the main thread [flink] via GitHub
• [jira] [Updated] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task ASF GitHub Bot (Jira)
• [PR] [FLINK-41077][rpc] Rethrow scheduled task failures in the main thread [flink] via GitHub
  • Re: [PR] [FLINK-41077][rpc] Rethrow scheduled task failures in the main thread [flink] via GitHub
• [jira] [Created] (FLINK-41080) [UMBRELLA] Polish Flink CDC docs and enrich contents Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41085) AppendOnlyTopNFunction emits an inconsistent changelog after cache eviction when sorting on NaN Bettle (Jira)
• [jira] [Updated] (FLINK-40318) Add a validation entry point for a VARIANT binary Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join ChenZhuo (Jira)
• Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
  • Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
• [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
  • Re: [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
  • [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
  • Re: [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
• Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
  • Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
• Re: [I] [Bug][runtime] Awaiting an internal sub-agent can deadlock by holding a shared async-pool worker [flink-agents] via GitHub
• [PR] [api][integrations][java][python] Reject a blank model in chat model setups [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Reject a blank model in chat model setups [flink-agents] via GitHub
• [PR] [docs][python] Fix setup, Quickstart and scalar Table output [flink-agents] via GitHub
  • Re: [PR] [docs][python] Fix setup, Quickstart and scalar Table output [flink-agents] via GitHub
• [PR] [runtime] Enforce continuation input limits and prioritize earlier runs [flink-agents] via GitHub
  • Re: [PR] [runtime] Enforce continuation input limits and prioritize earlier runs [flink-agents] via GitHub
• [jira] [Updated] (FLINK-41082) Polish Flink CDC docs and fix format issues ASF GitHub Bot (Jira)
• [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
• [jira] [Created] (FLINK-41084) Common & Source-Specific Metrics sukang (Jira)
• [jira] [Resolved] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• [PR] Flink 34224 [flink] via GitHub
  • Re: [PR] Flink 34224 [flink] via GitHub
• [jira] [Created] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41082) Polish Flink CDC docs and fix format issues Xiqian Yu (Jira)
• [jira] [Created] (FLINK-41081) Provide EN / ZH bilingual docs for Flink CDC Xiqian Yu (Jira)
• [PR] [runtime][python] Handle missing long-term memory IDs [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Handle missing long-term memory IDs [flink-agents] via GitHub
• [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
• [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• Re: [PR] [FLINK-40717][connectors/mongodb] Add AGENTS.md and PR template with AI disclosure [flink-connector-mongodb] via GitHub
• [PR] [runtime] Process the input queued behind an input that triggers no Actions [flink-agents] via GitHub
  • Re: [PR] [runtime] Process the input queued behind an input that triggers no Actions [flink-agents] via GitHub
• [jira] [Created] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 ASF GitHub Bot (Jira)
• [PR] [FLINK-41076] Bump Jackson to 2.21.5 (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump Jackson to 2.21.8 (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump Jackson to 2.21.8 (release-21.0) [flink-shaded] via GitHub
• [jira] [Updated] (FLINK-41067) Window and interval joins store rows whose join key can never match ASF GitHub Bot (Jira)
• [PR] [FLINK-41078][runtime] Complete slot manager debounce futures on failure [flink] via GitHub
  • Re: [PR] [FLINK-41078][runtime] Complete slot manager debounce futures on failure [flink] via GitHub
• [jira] [Updated] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-34589) FineGrainedSlotManager doesn't handle errors in the resource reconcilliation step Martijn Visser (Jira)
• [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
  • Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
  • Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
  • Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
  • Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• [jira] [Assigned] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
  • Re: [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
  • Re: [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
• [jira] [Created] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
• [jira] [Created] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final and Jackson to 2.21.5 in flink-shaded release-21.0 Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final and Jackson to 2.21.5 in flink-shaded release-21.0 Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-41076] Bump Netty to 4.2.17.Final (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump Netty to 4.2.19.Final (release-21.0) [flink-shaded] via GitHub
• [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Mika Naylor (Jira)
• [jira] [Updated] (FLINK-41075) Kill each e2e timeout watchdog when its command ends ASF GitHub Bot (Jira)
• [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
  • Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
  • Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
  • Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
• [jira] [Created] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision Luca Castelli (Jira)
• [PR] [FLINK-41074] Fence blue/green readiness to candidate generations [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents Ramin Gharib (Jira)
• [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
  • Re: [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
  • Re: [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
• [jira] [Resolved] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests Martijn Visser (Jira)
• [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-40098][test-utils] Add FailingCheckpointedSource for exactly-once source tests [flink] via GitHub
• [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
• [jira] [Updated] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Mika Naylor (Jira)
• [jira] [Assigned] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Mika Naylor (Jira)
• [jira] [Assigned] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
  • [jira] [Assigned] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
• [jira] [Resolved] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) sepuri sai krishna (Jira)
  • [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Mika Naylor (Jira)
  • [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) sepuri sai krishna (Jira)
• [jira] [Commented] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing Martijn Visser (Jira)
• [jira] [Created] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub

• Earlier messages
• Later messages