issues  

Messages by Thread

• • Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
  • Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• [PR] [FLINK-40634][ci] Reuse mirror list to prepare faster image [flink] via GitHub
  • Re: [PR] [FLINK-40634][ci] Reuse mirror list to prepare faster image [flink] via GitHub
• [PR] [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY [flink-cdc] via GitHub
  • Re: [PR] [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40634) E2E are extremely slow in Azure ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Bob Thomson (Jira)
• Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
  • Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
• [jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases Avi Sanwal (Jira)
• 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] [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events [flink-cdc] via GitHub
  • Re: [PR] [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events [flink-cdc] via GitHub
• Re: [I] [Feature] Add OpenAI embedding model (Java) [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled VISHAL B (Jira)
  • [jira] [Commented] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled yongfu.gao (Jira)
• Re: [I] [Feature] Add PostgreSQL pgvector vector store (Java) [flink-agents] 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
• [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
• Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
  • Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
  • Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
  • Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
  • Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
  • Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
• Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs Martijn Visser (Jira)
• Re: [PR] [FLINK-40600][runtime-web] Add missing web dashboard specs and tighten thin ones [flink] via GitHub
  • Re: [PR] [FLINK-40600][runtime-web] Add missing web dashboard specs and tighten thin ones [flink] via GitHub
  • Re: [PR] [FLINK-40600][runtime-web] Add missing web dashboard specs and tighten thin ones [flink] via GitHub
• [jira] [Assigned] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs Martijn Visser (Jira)
• Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents] via GitHub
  • Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents] via GitHub
  • Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents] via GitHub
• Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-40588) DynamicKafkaSourceReaderTest.testNotifyNoMoreSplits is flaky Bhanu Chander Vallabaneni (Jira)
  • [jira] [Commented] (FLINK-40588) DynamicKafkaSourceReaderTest.testNotifyNoMoreSplits is flaky Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Bhanu Chander Vallabaneni (Jira)
  • [jira] [Commented] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Sylwester Lachiewicz (Jira)
• Re: [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
  • Re: [PR] [FLINK-40586][Connectors/Kafka] Signal no more splits to each reader once per registration [flink-connector-kafka] via GitHub
• [jira] [Comment Edited] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Han You (Jira)
• Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Han You (Jira)
• [jira] [Commented] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer Chanhae Oh (Jira)
• [jira] [Comment Edited] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
  • [jira] [Comment Edited] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Sylwester Lachiewicz (Jira)
• [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
• Re: [PR] [FLINK-39765][cdc-pipeline/mysql] Implement lineage (FLIP-314) support for mysql source connectors [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) ASF GitHub Bot (Jira)
• [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
• Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
• Re: [PR] [FLINK-40547][docs] Add page on interpreting Flink's changelog [flink] via GitHub
  • Re: [PR] [FLINK-40547][docs] Add page on interpreting Flink's changelog [flink] via GitHub
  • Re: [PR] [FLINK-40547][docs] Add page on interpreting Flink's changelog [flink] via GitHub
• [jira] [Created] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Purushottam Sinha (Jira)
• 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
• [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
• [jira] [Updated] (FLINK-40629) Bump the build/enforced Maven version from 3.8.6 to 3.9.16 in flink-connector-kafka ASF GitHub Bot (Jira)
• [PR] [FLINK-40629][build] Bump Maven from 3.8.6 to 3.9.16 [flink-connector-kafka] via GitHub
• [PR] [BP-4.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-4.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
• [jira] [Created] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-40629) Bump the build/enforced Maven version from 3.8.6 to 3.9.16 in flink-connector-kafka Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40593) Add batch recursive S3 deletes to native S3 connector Samrat Deb (Jira)
• Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
  • Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
  • Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
  • Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
• [jira] [Commented] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint Martijn Visser (Jira)
• 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
  • 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
  • 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
  • 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
• Re: [PR] [FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
  • Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
  • Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
  • Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
• [jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
• [jira] [Updated] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Weicheng Ji (Jira)
  • [jira] [Updated] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-40493) VARIANT CAST for UUID (code 20) ASF GitHub Bot (Jira)
• [jira] [Assigned] (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)
• [jira] [Assigned] (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 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] [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)
• 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-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [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

• Later messages