phet commented on code in PR #3931:
URL: https://github.com/apache/gobblin/pull/3931#discussion_r1578888790
##########
gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java:
##########
@@ -884,7 +884,8 @@ private AbstractTokenRefresher buildTokenRefreshManager()
throws IOException {
@VisibleForTesting
void cleanUpAppWorkDirectory(ApplicationId applicationId) throws IOException
{
- FileSystem fs =
GobblinClusterUtils.buildNewInstanceFileSystem(this.config,
this.yarnConfiguration);
+ // Create a new filesystem as this.fs may have been closed by the Yarn
Application, and FS.get() will return a cached instance of the closed FS
Review Comment:
bingo! glad to preserve this hard-won understanding
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
