Reproducing FLINK-10774
This project goes through the detail of reproducing the connection leak issue raised by FlinkKafkaConsumer objects. The PartitionDiscoverer inside the FlinkKafkaConsumer failed to close the connection when exception is thrown and causing connection leak.
Launch on Chameleon
Launching this artifact will open it within Chameleon’s shared Jupyter experiment environment, which is accessible to all Chameleon users with an active allocation.
Download ArchiveDownload an archive containing the files of this artifact.