[jira] [Created] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

[Shang Yuanchun (Jira)]

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)