Till Rohrmann created FLINK-5241: ------------------------------------ Summary: Introduce AbstractStreamOperator get CloseableRegistry Key: FLINK-5241 URL: https://issues.apache.org/jira/browse/FLINK-5241 Project: Flink Issue Type: Improvement Components: State Backends, Checkpointing Affects Versions: 1.2.0 Reporter: Till Rohrmann Priority: Minor Fix For: 1.2.0
At the moment, all {{AbstractStreamOperator}} register their {{Closeables}} at the containing {{StreamTask's}} {{CloseableRegistry}}. In order to separate the closing of stream operator specific {{Closeables}} it might make sense to instantiate a {{CloseableRegistry}} for each {{AbstractStreamOperator}} and registering this registry at the {{StreamTask's}} registry. That way the {{AbstractStreamOperator}} can close it's own {{Closeables}} without affecting other {{AbstractStreamOperators}} and not having to wait for the {{StreamTask}} to close by closing its own {{CloseableRegistry}}. -- This message was sent by Atlassian JIRA (v6.3.4#6332)