[jira] [Created] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

Youjun Yuan created FLINK-9630: -- Summary: Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException Key: FLINK-9630 URL: https://issues.apache.org/jira/browse/FLINK-9630 Project: Fl

[jira] [Created] (FLINK-10381) concurrent submit job get ProgramAbortException

Youjun Yuan created FLINK-10381: --- Summary: concurrent submit job get ProgramAbortException Key: FLINK-10381 URL: https://issues.apache.org/jira/browse/FLINK-10381 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23874) JM did not store latest checkpiont id into Zookeeper, silently

Youjun Yuan created FLINK-23874: --- Summary: JM did not store latest checkpiont id into Zookeeper, silently Key: FLINK-23874 URL: https://issues.apache.org/jira/browse/FLINK-23874 Project: Flink

[jira] [Created] (FLINK-24187) Could not commit s3 file after JM restart during state initialization

Youjun Yuan created FLINK-24187: --- Summary: Could not commit s3 file after JM restart during state initialization Key: FLINK-24187 URL: https://issues.apache.org/jira/browse/FLINK-24187 Project: Flink

[jira] [Created] (FLINK-37684) ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySele

Youjun Yuan created FLINK-37684: --- Summary: ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySelector Key: FLINK-376

[jira] [Created] (FLINK-37742) POJO type expected but was: GenericType when resume from savepoint

Youjun Yuan created FLINK-37742: --- Summary: POJO type expected but was: GenericType when resume from savepoint Key: FLINK-37742 URL: https://issues.apache.org/jira/browse/FLINK-37742 Project: Flink