Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2659#discussion_r185929506
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -533,11 +533,11 @@ private static StormBase make(TopologyStatus status) {
private static <T extends AutoCloseable> TimeCacheMap<String, T>
fileCacheMap(Map<String, Object> conf) {
return new
TimeCacheMap<>(ObjectReader.getInt(conf.get(DaemonConfig.NIMBUS_FILE_COPY_EXPIRATION_SECS),
600),
(id, stream) -> {
- try {
- stream.close();
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
+ try {
--- End diff --
The format seems off
---
