diff options
| author | gujinkai <[email protected]> | 2024-03-08 11:49:38 +0800 |
|---|---|---|
| committer | gujinkai <[email protected]> | 2024-03-08 11:49:38 +0800 |
| commit | 6c65d10e05c827c4924f40029ee703c8e35d6115 (patch) | |
| tree | 3fbcecca27077341915707dc039faa094e6162fa | |
| parent | 73252744ca7304460c1457aeed29cc999e8340df (diff) | |
perf: add gc after cache close24.03
| -rw-r--r-- | platform-etl/src/main/java/com/zdjizhi/etl/operator/EtlProcessFunc.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/platform-etl/src/main/java/com/zdjizhi/etl/operator/EtlProcessFunc.java b/platform-etl/src/main/java/com/zdjizhi/etl/operator/EtlProcessFunc.java index 1d27358..f8004db 100644 --- a/platform-etl/src/main/java/com/zdjizhi/etl/operator/EtlProcessFunc.java +++ b/platform-etl/src/main/java/com/zdjizhi/etl/operator/EtlProcessFunc.java @@ -78,5 +78,6 @@ public class EtlProcessFunc extends ProcessFunction<String, CnRecordLog> { super.close(); LOG.warn("close EtlProcessFunc"); MetadataListenerUtils.close(); + System.gc(); } } |
