issues  

Messages by Thread

• [jira] [Commented] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort superseded precommitted transactions on recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort superseded precommitted transactions on recovery [flink-connector-kafka] via GitHub
• [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-40551) FileMergingChannelStateITCase is very flaky Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
• [jira] [Commented] (FLINK-37291) Weekly Kafka CI detects producer leaks Sylwester Lachiewicz (Jira)
• [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• [jira] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint Martijn Visser (Jira)
• [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• Re: [PR] [FLINK-33466][Connectors/Kafka]: Bounded Kafka source never finishes after restore from savepoint [flink-connector-kafka] via GitHub
• [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40625][docs] Add AGENTS.md and PR template with AI disclosure [flink-connector-kafka] via GitHub
• [jira] [Closed] (FLINK-29674) Apache Kafka Connector‘s “ setBounded” not valid Martijn Visser (Jira)
• [jira] [Closed] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint Martijn Visser (Jira)
• [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
  • [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
• [PR] [FLINK-40234][runtime] Exclude synchronous downstream processing from source idleness accounting [flink] via GitHub
  • Re: [PR] [FLINK-40234][runtime] Exclude synchronous downstream processing from source idleness accounting [flink] via GitHub
  • Re: [PR] [FLINK-40234][runtime] Exclude synchronous downstream processing from source idleness accounting [flink] via GitHub
  • Re: [PR] [FLINK-40234][runtime] Exclude synchronous downstream processing from source idleness accounting [flink] via GitHub
• [jira] [Commented] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Sylwester Lachiewicz (Jira)
• [PR] [FLINK-40556][table] Support UUID value literals backed by byte[] values [flink] via GitHub
  • Re: [PR] [FLINK-40556][table] Support UUID value literals backed by byte[] values [flink] via GitHub
• [jira] [Created] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
• [jira] [Updated] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
• [PR] [BP-3.4][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-3.4][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• [PR] [BP-5.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-5.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" Martijn Visser (Jira)
• [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
  • Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
• [jira] [Updated] (FLINK-40489) Add UUID_V4() & UUID_V7() functions ASF GitHub Bot (Jira)
• [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40585][Connectors/Kafka] Wait for the last stable offset before draining committed records [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink] via GitHub
• [jira] [Closed] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) Timo Walther (Jira)
• [jira] [Resolved] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Sergey Nuyanzin (Jira)
• [jira] [Closed] (FLINK-40464) [CI][Release][Python] Bump cibuildwheel to 4.2.0 Dian Fu (Jira)
• [jira] [Updated] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Sylwester Lachiewicz (Jira)
  • [jira] [Updated] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Sylwester Lachiewicz (Jira)
  • [jira] [Updated] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-40464) [CI][Release][Python] Bump cibuildwheel to 4.2.0 Dian Fu (Jira)
  • [jira] [Commented] (FLINK-40464) [CI][Release][Python] Bump cibuildwheel to 4.2.0 Dian Fu (Jira)
  • [jira] [Commented] (FLINK-40464) [CI][Release][Python] Bump cibuildwheel to 4.2.0 Dian Fu (Jira)
• [jira] [Created] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Sylwester Lachiewicz (Jira)
• [jira] [Updated] (FLINK-40464) [CI][Release][Python] Bump cibuildwheel to 4.2.0 Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 Dian Fu (Jira)
• [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
  • Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• [PR] [FLINK-40622][Connectors/Kafka] Stop readers recreating the deleted topic in SourceTopicIntegrityTest [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40622][Connectors/Kafka] Stop readers recreating the deleted topic in SourceTopicIntegrityTest [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40625) Create AGENTS.md for Flink Kafka connector and update the PR description to track AI usage ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" Sylwester Lachiewicz (Jira)
  • [jira] [Commented] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" Sylwester Lachiewicz (Jira)
• [jira] [Resolved] (FLINK-40618) Connectors/Kafka: Run SourceTopicIntegrity test in the integration-test phase Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40586) DynamicKafkaSourceEnumerator re-signals NoMoreSplits to already-finished readers on every reader registration, causing "OperatorEvent lost" task failover Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40618) Connectors/Kafka: Run SourceTopicIntegrity test in the integration-test phase Martijn Visser (Jira)
• [jira] [Created] (FLINK-40625) Create AGENTS.md for Flink Kafka connector and update the PR description to track AI usage Martijn Visser (Jira)
• [jira] [Commented] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation david radley (Jira)
• Re: [PR] [FLINK-35321][runtime] Ensure pendingCommitables metric is not re-registered while copying CommittableCollector [flink] via GitHub
• [jira] [Created] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Sylwester Lachiewicz (Jira)
• [jira] [Assigned] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Robert Metzger (Jira)
• [jira] [Resolved] (FLINK-40478)  HistoryServer should log its effective configuration at startup Robert Metzger (Jira)
• [jira] [Assigned] (FLINK-40478)  HistoryServer should log its effective configuration at startup Robert Metzger (Jira)
• [jira] [Resolved] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Robert Metzger (Jira)
• [jira] [Updated] (FLINK-31931) Exception history page should not link to a non-existent TM log page. Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-31931) Exception history page should not link to a non-existent TM log page. Junrui Lee (Jira)
• [jira] [Assigned] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled Leonard Xu (Jira)
• [jira] [Updated] (FLINK-40556) Support UUID value literals in the Table API Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40556) Support UUID value literals in the Table API ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40556) Support UUID value literals in the Table API Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40488) Comparison and ordering for UUID Timo Walther (Jira)
• [jira] [Closed] (FLINK-40616) Make BITMAP and VARIANT conversion handling consistent and remove redundant checks Timo Walther (Jira)
• [jira] [Created] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40556) Support UUID value literals in the Table API Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-40489) Add UUID_V4() & UUID_V7() functions Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) Ramin Gharib (Jira)
• [jira] [Resolved] (FLINK-40137) Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40615) KafkaSourceEnumerator assigns duplicate splits when partition discovery interval is shorter than split initialization time Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness Martijn Visser (Jira)
• [jira] [Created] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start wglbd12 (Jira)
• [jira] [Updated] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-40137) Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator Martijn Visser (Jira)
• Re: [PR] [FLINK-35276][table] Fix incorrect sort order for floating-point negative zero in generated comparators [flink] via GitHub
• Re: [PR] [FLINK-39654][build] Add JDK 25 CI test lane (non-blocking) [flink] via GitHub
  • Re: [PR] [FLINK-39654][build] Add JDK 25 CI test lane (non-blocking) [flink] via GitHub
• Re: [PR] [FLINK-32940] [SQL] Unnest projection and filter pushdown [flink] via GitHub
  • Re: [PR] [FLINK-32940] [SQL] Unnest projection and filter pushdown [flink] via GitHub
• Re: [PR] [FLINK-38987] Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-38987] Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem [flink] via GitHub
• Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] via GitHub
  • Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] via GitHub
• [jira] [Closed] (FLINK-40421) Add sorting support in DataFrame API Dian Fu (Jira)
• [jira] [Commented] (FLINK-40418) Support attribute-based column access on DataFrame Dian Fu (Jira)
  • [jira] [Commented] (FLINK-40418) Support attribute-based column access on DataFrame Liu Liu (Jira)
  • [jira] [Commented] (FLINK-40418) Support attribute-based column access on DataFrame Bettle (Jira)
  • [jira] [Commented] (FLINK-40418) Support attribute-based column access on DataFrame Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40418) Support attribute-based column access on DataFrame Dian Fu (Jira)
• [jira] [Closed] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Dian Fu (Jira)
• [PR] [FLINK-20986][table-planner] Avoid cross-job RAW type cache reuse [flink] via GitHub
  • Re: [PR] [FLINK-20986][table-planner] Avoid cross-job RAW type cache reuse [flink] via GitHub
  • Re: [PR] [FLINK-20986][table-planner] Avoid cross-job RAW type cache reuse [flink] via GitHub
• [jira] [Closed] (FLINK-23758) PyFlink __invert__ has wrong semantics Dian Fu (Jira)
• [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• [PR] [integrations][java][python] Preserve Watsonx finish_reason in extra_args [flink-agents] via GitHub
  • Re: [PR] [integrations][java][python] Preserve Watsonx finish_reason in extra_args [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40586) DynamicKafkaSourceEnumerator re-signals NoMoreSplits to already-finished readers on every reader registration, causing "OperatorEvent lost" task failover ASF GitHub Bot (Jira)
• [PR] [FLINK-40586][Connectors/Kafka] Signal no more splits to each reader once per registration [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40586][Connectors/Kafka] Signal no more splits to each reader once per registration [flink-connector-kafka] via GitHub

• Earlier messages
• Later messages