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.

17 5 6 2 Mar. 7, 2023, 11:32 PM

Authors

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 Archive

Download an archive containing the files of this artifact.

Version Stats

17 5 5