[jira] [Created] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

Leo zhang created FLINK-29128: - Summary: Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader Key: FLINK-29128 URL: https://issues.apache.org/jira/browse/FLINK-29128

[jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero

Leo zhang created FLINK-28475: - Summary: kafka connector won't stop when the stopping offset is zero Key: FLINK-28475 URL: https://issues.apache.org/jira/browse/FLINK-28475 Project: Flink Issue

[jira] [Created] (FLINK-14729) Multi-topics consuming from KafkaTableSource

Leo Zhang created FLINK-14729: - Summary: Multi-topics consuming from KafkaTableSource Key: FLINK-14729 URL: https://issues.apache.org/jira/browse/FLINK-14729 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

Leo Zhang created FLINK-14319: - Summary: Register user jar files in {Stream}ExecutionEnvironment Key: FLINK-14319 URL: https://issues.apache.org/jira/browse/FLINK-14319 Project: Flink Issue Type