Maximilian Michels created FLINK-16573:
------------------------------------------
Summary: Kinesis consumer does not properly shutdown RecordFetcher
threads
Key: FLINK-16573
URL: https://issues.apache.org/jira/browse/FLINK-16573
Project: Flink
Issue Type: Bug
Components: Connectors / Kinesis
Affects Versions: 1.10.0, 1.9.2, 1.8.3
Reporter: Maximilian Michels
Assignee: Maximilian Michels
Fix For: 1.11.0
The threads may not shut down correctly because they do not check for the
running flag in the inner loops. The threads also do not get interrupted
because they are not connected to the main task thread.
These threads keep lingering around after the job has shut down:
{noformat}
Thread 23168: (state = BLOCKED)
- java.lang.Object.wait(long) @bci=0 (Compiled frame; information may be
imprecise)
-
org.apache.flink.streaming.connectors.kinesis.util.RecordEmitter.emitRecords()
@bci=140, line=209 (Compiled frame)
- org.apache.flink.streaming.connectors.kinesis.util.RecordEmitter.run()
@bci=18, line=177 (Interpreted frame)
- java.lang.Thread.run() @bci=11, line=748 (Compiled frame)
{noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
