[FLINK-25948] KDS / KDF Sink should call .close() to clean up resources

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Duplicate
• Fix Version/s: 1.15.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available test-stability
• Assignee: Ahmed Hamdy
• Reporter: Zichen Liu
• Created: 03/Feb/22 11:59
• Updated: 23/Feb/22 08:52
• Resolved: 23/Feb/22 08:52

Description

Add .close() both the KDS/KDF AsyncClient and the underlying HTTPClient

maintain a reference to the HTTPClient at all times in order to close it

need to find an appropriate time in the Sink/SinkWriter

Issue Links

• duplicates: FLINK-25977 Close sink client and sink http client for KDS/KDF Sinks
• is a clone of: FLINK-25924 KDF Integration tests intermittently fails