Unable to pull output file if the file already exists in the working dir

[activeeon-bot]

Original issue created by Vladimir Bodnartchouk on 25, Feb 2014 at 20:12 PM - PRC-2

---

On Windows, this errors occurs sometimes not always: Warning, error occurred when trying to pull file ...

Code to reproduce the issue:

write('ola', 'file1')
write('ola', 'file2')
library("PARConnector")
PAConnect(url='http://localhost:8080/rest/rest', login='demo', pwd='demo');
tasks <- PA( function(x) {},
1:2,
input.files="file%1%",
output.files="file%1%")
PADebug(TRUE)
jobResult = PASolve(tasks)
val = PAWaitFor(jobResult)

t1 :
(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) Working directory is : C:/Users/vbodnart/AppData/Local/Temp/PA_JVM1265514695/f756528/25/-726375099"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) Working directory content :"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "1342196410"

(link: [email protected].;19:42:19) "file1"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) Environment :"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "args"

(link: [email protected].;19:42:19) "globalspace"

(link: [email protected].;19:42:19) "inputspace"

(link: [email protected].;19:42:19) "jTaskProgress"

(link: [email protected].;19:42:19) (link: 5)

(link: [email protected].;19:42:19) "localspace"

(link: [email protected].;19:42:19) "outputspace"

(link: [email protected].;19:42:19) "PASolveCall"

(link: [email protected].;19:42:19) "results"

(link: [email protected].;19:42:19) (link: 9)

(link: [email protected].;19:42:19) "set_progress"

(link: [email protected].;19:42:19) "userspace"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) PASolveCall :"

(link: [email protected].;19:42:19) (function (x)

(link: [email protected].;19:42:19) {

(link: [email protected].;19:42:19) })(1L)

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) Result :"

(link: [email protected].;19:42:19) NULL

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "(link: DEBUG) Working directory content after script execution:"

(link: [email protected].;19:42:19) (link: 1)

(link: [email protected].;19:42:19) "1342196410"

(link: [email protected].;19:42:19) "file1"

(link: 1) "Java Error in :"
23: tryCatchOne(expr, names, parentenv, handlers(link: [1L]))
22: tryCatchList(expr, classes, parentenv, handlers)
21: tryCatch({
return({
pulled <- J(client, "pullFile", .getSpaceName(space),
pathname, outputFile)
.nb.tries <- 0
})
}, Exception = function(e) {
if (is.null(function(e, .print.stack) {
.nb.tries <<- .nb.tries - 1
if (.nb.tries <= 0) {
if (.print.stack) {
print(str_c("Error in PAPullFile(", space, ",",
pathname, ",", outputFile, ") : ", e$jobj$getMessage()))
}
PAHandler(e, .print.stack)
}
})) {
PAHandler(e, .print.stack = .print.stack)
}
else {
(function(e, .print.stack) {
.nb.tries <<- .nb.tries - 1
if (.nb.tries <= 0) {
if (.print.stack) {
print(str_c("Error in PAPullFile(", space,
",", pathname, ",", outputFile, ") : ", e$jobj$getMessage()))
}
PAHandler(e, .print.stack)
}
})(e, .print.stack = .print.stack)
}
})
20: eval(expr, envir, enclos)
19: eval(tmp, parent.frame())
18: j_try_catch({
pulled <- J(client, "pullFile", .getSpaceName(space), pathname,
outputFile)
.nb.tries <- 0
}, .handler = function(e, .print.stack) {
.nb.tries <<- .nb.tries - 1
if (.nb.tries <= 0) {
if (.print.stack) {
print(str_c("Error in PAPullFile(", space, ",", pathname,
",", outputFile, ") : ", e$jobj$getMessage()))
}
PAHandler(e, .print.stack)
}
}, .print.stack = .print.stack) at PAPullFile.r#35
17: PAPullFile(toupper(object@space), pathname, filepath, .print.stack = FALSE)
16: doTryCatch(return(expr), name, parentenv, handler)
15: tryCatchOne(expr, names, parentenv, handlers(link: [1L]))
14: tryCatchList(expr, classes, parentenv, handlers)
13: tryCatch(return(PAPullFile(toupper(object@space), pathname, filepath,
.print.stack = FALSE)), Exception = function(e) {
print(str_c("Warning, error occurred when trying to pull file ",
toupper(object@space), ":", pathname, " -> ", filepath))
}) at PAFile.r#107
12: .local(object, ...)
11: pullFile(pafile, client = paresult@client) at pa_inline_functions.r#224
10: pullFile(pafile, client = paresult@client) at PAJobResult.r#72
9: .getRResultFromJavaResult(paresult, tresult, i, callback) at PAJobResult.r#118
8: .getAvailableResults(paresult, callback) at PAJobResult.r#160
7: .local(paresult, ...)
6: PAWaitFor(jobResult) at pa_inline_functions.r#184
5: PAWaitFor(jobResult) at testFileIndex.r#62
4: eval(expr, envir, enclos)
3: eval(ei, envir)
2: withVisible(eval(ei, envir))
1: source("functionalTests/testFileIndex.r")
java.lang.reflect.UndeclaredThrowableException
at com.sun.proxy.$Proxy0.pullFile(Unknown Source)
at sun.reflect.GeneratedMethodAccessor101.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at RJavaTools.invokeMethod(RJavaTools.java:386)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedMethodAccessor102.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.ow2.proactive.scheduler.rest.SessionHandler.invoke(SessionHandler.java:58)
... 5 more
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Cannot delete the already exisiting output file: C:/workdir/matlab_scilab_connector/r/PARConnector/file1
at org.ow2.proactive.scheduler.rest.ExceptionUtility.throwNCE(ExceptionUtility.java:64)
at org.ow2.proactive.scheduler.rest.ExceptionUtility.throwNCEOrPE(ExceptionUtility.java:73)
at org.ow2.proactive.scheduler.rest.SchedulerClient.pullFile(SchedulerClient.java:782)
... 9 more
Caused by: java.lang.RuntimeException: Cannot delete the already exisiting output file: C:/workdir/matlab_scilab_connector/r/PARConnector/file1
at org.ow2.proactive.scheduler.rest.SchedulerClient.prepareToWrite(SchedulerClient.java:827)
at org.ow2.proactive.scheduler.rest.SchedulerClient.pullFile(SchedulerClient.java:777)
... 9 more
(link: 1) "Warning, error occurred when trying to pull file USER:/file1 -> C:/workdir/matlab_scilab_connector/r/PARConnector/file1"