Skip to content

Commit

Permalink
[FLINK-5328] [logging] Add Thread name to FileSystem disposeFileSyste…
Browse files Browse the repository at this point in the history
…mCloseableRegistryForTask

Adding this to the FileSystem dispose call in order to help debugging FLINK-5328
when it occurs again. After the initial skim over the logs it looks like the
streams are closed to early for the failed task.
  • Loading branch information
uce authored and static-max committed Dec 13, 2016
1 parent 6ead74b commit ed38849
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -83,7 +83,7 @@ public static void createFileSystemCloseableRegistryForTask() {
public static void disposeFileSystemCloseableRegistryForTask() {
SafetyNetCloseableRegistry registry = REGISTRIES.get();
if (null != registry) {
LOG.info("Ensuring all FileSystem streams are closed");
LOG.info("Ensuring all FileSystem streams are closed for {}", Thread.currentThread().getName());
REGISTRIES.remove();
IOUtils.closeQuietly(registry);
}
Expand Down

0 comments on commit ed38849

Please sign in to comment.