issues  

Messages by Thread

• • Re: [PR] [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only [flink] via GitHub
• [jira] [Commented] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Yahya Kisana (Jira)
  • [jira] [Commented] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41096) Wrong result when a Table with a non-equi correlated scalar subquery is used twice in one query Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll Aaron He (Jira)
• [PR] [FLINK-41092][state/rocksdb] Restore KEY_VALUE_V2 keyed-state metadata in RocksDB [flink] via GitHub
  • Re: [PR] [FLINK-41092][state/rocksdb] Restore KEY_VALUE_V2 keyed-state metadata in RocksDB [flink] via GitHub
• [jira] [Created] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads Aaron He (Jira)
• [jira] [Created] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors Aaron He (Jira)
• [jira] [Created] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll Aaron He (Jira)
• [jira] [Updated] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt Aaron He (Jira)
• [jira] [Updated] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll ASF GitHub Bot (Jira)
• [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
  • Re: [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
  • Re: [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• [jira] [Updated] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
  • [jira] [Updated] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Martijn Visser (Jira)
• [jira] [Created] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
• [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE ASF GitHub Bot (Jira)
• [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
  • Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
• [jira] [Updated] (FLINK-41089) Make cleanup of docker image parallel ASF GitHub Bot (Jira)
• [PR] [FLINK-41089][ci] Make cleanup of docker image parallel [flink] via GitHub
  • Re: [PR] [FLINK-41089][ci] Make cleanup of docker image parallel [flink] via GitHub
  • Re: [PR] [FLINK-41089][ci] Make cleanup of docker image in parallel [flink] via GitHub
• [jira] [Created] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
  • Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• Re: [PR] [FLINK-37244] Added scylladb tests, documentation and README [flink-connector-cassandra] via GitHub
• [jira] [Updated] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store ASF GitHub Bot (Jira)
• [jira] [Comment Edited] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Shrey Bansal (Jira)
• [jira] [Resolved] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Martijn Visser (Jira)
• Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
• [jira] [Assigned] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• Re: [I] [Feature][chat-models] Support multimodal tool results in model provider adapters [flink-agents] via GitHub
  • Re: [I] [Feature][chat-models] Support multimodal tool results in model provider adapters [flink-agents] via GitHub
• [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs ASF GitHub Bot (Jira)
• [PR] [FLINK-40874][table] MiniBatch joins fix: join key-only deletes of suppressed pairs with the stored record [flink] via GitHub
  • Re: [PR] [FLINK-40874][table] MiniBatch joins fix: join key-only deletes of suppressed pairs with the stored record [flink] via GitHub
• [jira] [Updated] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Shrey Bansal (Jira)
• [jira] [Updated] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting for 'group-offsets' startup mode Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Martijn Visser (Jira)
• Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] 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-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
  • 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-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
  • 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-34468][Connector/Cassandra] Adding support for Flink 1.20 [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-34468][Connector/Cassandra] Adding support for Flink 1.20 [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-34468][Connector/Cassandra] Adding support for Flink 1.20 [flink-connector-cassandra] via GitHub
• [jira] [Assigned] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
  • [jira] [Assigned] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-41067) Window and interval joins store rows whose join key can never match Gustavo de Morais (Jira)
• [jira] [Assigned] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Assigned] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Assigned] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Gustavo de Morais (Jira)
• [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• [jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs ASF GitHub Bot (Jira)
• [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
  • 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
  • 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
  • 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
  • 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
  • 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-38323) Global Scale Factor Mode ASF GitHub Bot (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
  • 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
  • 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

• Earlier messages
• Later messages