This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5bc3951 [FLINK-24760][docs] Update user document for batch window tvf
(#17670)
add 0be100b [FLINK-24294][refactor][core] Created AutoCloseableRegistry
as alternative of CloseableRegistry only for AutoCloseable
add 06b6078 [FLINK-24294][streaming] Register all stream task resources
to one closer in order to avoid the resources leak
add 249683b [refactor][core] Removed unused method addCloseableInternal
in AbstractAutoCloseableRegistry
No new revisions were added by this update.
Summary of changes:
...bleRegistry.java => AutoCloseableRegistry.java} | 33 ++--
.../apache/flink/core/fs/CloseableRegistry.java | 23 ++-
.../flink/core/fs/SafetyNetCloseableRegistry.java | 19 +-
...try.java => AbstractAutoCloseableRegistry.java} | 50 +++--
.../main/java/org/apache/flink/util/IOUtils.java | 23 ++-
...java => AbstractAutoCloseableRegistryTest.java} | 23 ++-
.../flink/core/fs/AutoCloseableRegistryTest.java | 74 ++++++++
.../flink/core/fs/CloseableRegistryTest.java | 15 +-
.../core/fs/SafetyNetCloseableRegistryTest.java | 23 ++-
.../flink/streaming/runtime/tasks/StreamTask.java | 208 +++++++++++----------
.../streaming/runtime/tasks/StreamTaskTest.java | 12 ++
11 files changed, 316 insertions(+), 187 deletions(-)
copy flink-core/src/main/java/org/apache/flink/core/fs/{CloseableRegistry.java
=> AutoCloseableRegistry.java} (59%)
rename
flink-core/src/main/java/org/apache/flink/util/{AbstractCloseableRegistry.java
=> AbstractAutoCloseableRegistry.java} (76%)
rename
flink-core/src/test/java/org/apache/flink/core/fs/{AbstractCloseableRegistryTest.java
=> AbstractAutoCloseableRegistryTest.java} (90%)
create mode 100644
flink-core/src/test/java/org/apache/flink/core/fs/AutoCloseableRegistryTest.java
