Spring Cloud Data Flow for Apache YARN Memory leak

[mixergit]

Use a period of time yarnModuleDeployerTaskExecutor thread resource occupancy will be ascribed, resulting in memory overflow

[mixergit]

private synchronized YarnCloudAppServiceApplication getApp(String appVersion, String dataflowVersion, CloudAppType cloudAppType,
		List<String> contextRunArgs) {
	contextRunArgs = processContextRunArgs(contextRunArgs);
	String cacheKey = cloudAppType + appVersion + StringUtils.collectionToCommaDelimitedString(contextRunArgs);
	YarnCloudAppServiceApplication app = appCache.get(cacheKey);
	logger.info("Cachekey {} found YarnCloudAppServiceApplication {}", cacheKey, app);
	if (app == null) {
		Properties configFileProperties = new Properties();
		if (StringUtils.hasText(appVersion)) {
			configFileProperties.setProperty("spring.yarn.applicationVersion", appVersion);
		}
		if (StringUtils.hasText(dataflowVersion)) {
			configFileProperties.setProperty("spring.cloud.deployer.yarn.version", dataflowVersion);
		}

		logger.info("Bootsrapping YarnCloudAppServiceApplication with {}", cloudAppType.toString().toLowerCase());
		ArrayList<String> runArgs = new ArrayList<String>();
		runArgs.add("--spring.config.name=" + cloudAppType.toString().toLowerCase());
		runArgs.add("--spring.jmx.enabled=false");

		if (!ObjectUtils.isEmpty(contextRunArgs)) {
			runArgs.addAll(contextRunArgs);
		}

		app = new YarnCloudAppServiceApplication(appVersion, dataflowVersion, "application.properties", configFileProperties,
				runArgs.toArray(new String[0]), initializers);
		try {
			app.afterPropertiesSet();
		} catch (Exception e) {
			throw new RuntimeException("Error initializing YarnCloudAppServiceApplication", e);
		}
		logger.info("Set cache with key {} and YarnCloudAppServiceApplication {}", cacheKey, app);
		appCache.put(cacheKey, app);
	}
	return app;
}

Two issues：
One, appCache not Recycling resources.
Two, YarnCloudAppServiceApplication context not destroy.