[jira] [Created] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21

Mason Chen created FLINK-35247: -- Summary: Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21 Key: FLINK-35247 URL: https://issues.apache.org/jira/browse/FLINK-35247 Project

[jira] [Created] (FLINK-35122) Implement Watermark Alignment for DynamicKafkaSource

Mason Chen created FLINK-35122: -- Summary: Implement Watermark Alignment for DynamicKafkaSource Key: FLINK-35122 URL: https://issues.apache.org/jira/browse/FLINK-35122 Project: Flink Issue Type:

[jira] [Created] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

Mason Chen created FLINK-34445: -- Summary: Integrate new endpoint with Flink UI metrics section Key: FLINK-34445 URL: https://issues.apache.org/jira/browse/FLINK-34445 Project: Flink Issue Type:

[jira] [Created] (FLINK-34444) Add new endpoint handler to flink

Mason Chen created FLINK-3: -- Summary: Add new endpoint handler to flink Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34327) Use maven wrapper in operator build

Mason Chen created FLINK-34327: -- Summary: Use maven wrapper in operator build Key: FLINK-34327 URL: https://issues.apache.org/jira/browse/FLINK-34327 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34127) Kafka connector repo runs a duplicate of `IntegrationTests` framework tests

Mason Chen created FLINK-34127: -- Summary: Kafka connector repo runs a duplicate of `IntegrationTests` framework tests Key: FLINK-34127 URL: https://issues.apache.org/jira/browse/FLINK-34127 Project: Flin

[jira] [Created] (FLINK-34064) Expose JobManagerOperatorMetrics via REST API

Mason Chen created FLINK-34064: -- Summary: Expose JobManagerOperatorMetrics via REST API Key: FLINK-34064 URL: https://issues.apache.org/jira/browse/FLINK-34064 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

Mason Chen created FLINK-33575: -- Summary: FLIP-394: Add Metrics for Connector Agnostic Autoscaling Key: FLINK-33575 URL: https://issues.apache.org/jira/browse/FLINK-33575 Project: Flink Issue Ty

[jira] [Created] (FLINK-32893) Make client.id configurable from KafkaSource

Mason Chen created FLINK-32893: -- Summary: Make client.id configurable from KafkaSource Key: FLINK-32893 URL: https://issues.apache.org/jira/browse/FLINK-32893 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-32892) Upgrade kafka-clients dependency to 3.4.x

Mason Chen created FLINK-32892: -- Summary: Upgrade kafka-clients dependency to 3.4.x Key: FLINK-32892 URL: https://issues.apache.org/jira/browse/FLINK-32892 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32507) Document KafkaSink SinkWriterMetricGroup metrics

Mason Chen created FLINK-32507: -- Summary: Document KafkaSink SinkWriterMetricGroup metrics Key: FLINK-32507 URL: https://issues.apache.org/jira/browse/FLINK-32507 Project: Flink Issue Type: Tech

[jira] [Created] (FLINK-32452) Refactor SQL Client E2E Test to Remove Kafka SQL Connector Dependency

Mason Chen created FLINK-32452: -- Summary: Refactor SQL Client E2E Test to Remove Kafka SQL Connector Dependency Key: FLINK-32452 URL: https://issues.apache.org/jira/browse/FLINK-32452 Project: Flink

[jira] [Created] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency

Mason Chen created FLINK-32451: -- Summary: Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Key: FLINK-32451 URL: https://issues.apache.org/jira/browse/FLINK-32451 Project

[jira] [Created] (FLINK-32449) Refactor state machine examples to remove Kafka dependency

Mason Chen created FLINK-32449: -- Summary: Refactor state machine examples to remove Kafka dependency Key: FLINK-32449 URL: https://issues.apache.org/jira/browse/FLINK-32449 Project: Flink Issue

[jira] [Created] (FLINK-32417) DynamicKafkaSource User Documentation

Mason Chen created FLINK-32417: -- Summary: DynamicKafkaSource User Documentation Key: FLINK-32417 URL: https://issues.apache.org/jira/browse/FLINK-32417 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32416) Initial DynamicKafkaSource Implementation

Mason Chen created FLINK-32416: -- Summary: Initial DynamicKafkaSource Implementation Key: FLINK-32416 URL: https://issues.apache.org/jira/browse/FLINK-32416 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32197) FLIP 246: Multi Cluster Kafka Source

Mason Chen created FLINK-32197: -- Summary: FLIP 246: Multi Cluster Kafka Source Key: FLINK-32197 URL: https://issues.apache.org/jira/browse/FLINK-32197 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-31747) Externalize debezium from flink-json

Mason Chen created FLINK-31747: -- Summary: Externalize debezium from flink-json Key: FLINK-31747 URL: https://issues.apache.org/jira/browse/FLINK-31747 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

Mason Chen created FLINK-31305: -- Summary: KafkaWriter doesn't wait for errors for in-flight records before completing flush Key: FLINK-31305 URL: https://issues.apache.org/jira/browse/FLINK-31305 Project

[jira] [Created] (FLINK-30932) Enabling producer metrics for KafkaSink is not documented

Mason Chen created FLINK-30932: -- Summary: Enabling producer metrics for KafkaSink is not documented Key: FLINK-30932 URL: https://issues.apache.org/jira/browse/FLINK-30932 Project: Flink Issue T

[jira] [Created] (FLINK-30859) Remove flink-connector-kafka rom master branch

Mason Chen created FLINK-30859: -- Summary: Remove flink-connector-kafka rom master branch Key: FLINK-30859 URL: https://issues.apache.org/jira/browse/FLINK-30859 Project: Flink Issue Type: Techni

[jira] [Created] (FLINK-30833) MetricListener supports closing metric groups

Mason Chen created FLINK-30833: -- Summary: MetricListener supports closing metric groups Key: FLINK-30833 URL: https://issues.apache.org/jira/browse/FLINK-30833 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-30409) Support reopening closed metric groups

Mason Chen created FLINK-30409: -- Summary: Support reopening closed metric groups Key: FLINK-30409 URL: https://issues.apache.org/jira/browse/FLINK-30409 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30200) TimestampOffsetsInitializer allows configurable OffsetResetStrategy

Mason Chen created FLINK-30200: -- Summary: TimestampOffsetsInitializer allows configurable OffsetResetStrategy Key: FLINK-30200 URL: https://issues.apache.org/jira/browse/FLINK-30200 Project: Flink

[jira] [Created] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint

Mason Chen created FLINK-29856: -- Summary: Triggering savepoint does not trigger source operator checkpoint Key: FLINK-29856 URL: https://issues.apache.org/jira/browse/FLINK-29856 Project: Flink

[jira] [Created] (FLINK-29515) Document KafkaSource behavior with deleted topics

Mason Chen created FLINK-29515: -- Summary: Document KafkaSource behavior with deleted topics Key: FLINK-29515 URL: https://issues.apache.org/jira/browse/FLINK-29515 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

Mason Chen created FLINK-28722: -- Summary: Hybrid Source should use .equals() for Integer comparison Key: FLINK-28722 URL: https://issues.apache.org/jira/browse/FLINK-28722 Project: Flink Issue T

[jira] [Created] (FLINK-27479) HybridSource refreshes availability future

Mason Chen created FLINK-27479: -- Summary: HybridSource refreshes availability future Key: FLINK-27479 URL: https://issues.apache.org/jira/browse/FLINK-27479 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

Mason Chen created FLINK-27195: -- Summary: KafkaSourceReader offsetsToCommit should be mutable Key: FLINK-27195 URL: https://issues.apache.org/jira/browse/FLINK-27195 Project: Flink Issue Type: B

[jira] [Created] (FLINK-25697) Support HTTPS for Prometheus Push Gateway

Mason Chen created FLINK-25697: -- Summary: Support HTTPS for Prometheus Push Gateway Key: FLINK-25697 URL: https://issues.apache.org/jira/browse/FLINK-25697 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24805) Metrics documentation missing numBytes metrics reported by tasks

Mason Chen created FLINK-24805: -- Summary: Metrics documentation missing numBytes metrics reported by tasks Key: FLINK-24805 URL: https://issues.apache.org/jira/browse/FLINK-24805 Project: Flink

[jira] [Created] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

Mason Chen created FLINK-24660: -- Summary: Allow setting KafkaSubscriber in KafkaSourceBuilder Key: FLINK-24660 URL: https://issues.apache.org/jira/browse/FLINK-24660 Project: Flink Issue Type: I

[jira] [Created] (FLINK-24622) Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync()

Mason Chen created FLINK-24622: -- Summary: Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync() Key: FLINK-24622 URL: https://issues.apache.org/jira/browse/FLINK-24622 Pr

[jira] [Created] (FLINK-23519) Aggregate State Backend Latency by State Level

Mason Chen created FLINK-23519: -- Summary: Aggregate State Backend Latency by State Level Key: FLINK-23519 URL: https://issues.apache.org/jira/browse/FLINK-23519 Project: Flink Issue Type: Improv