[Swift-user] determining unmapped paths
Mihael Hategan
hategan at mcs.anl.gov
Thu Mar 24 20:32:16 CDT 2011
This looks like an internal problem. Mappers should be two way
functions, so they should be able to map all things returned by
existing(). If you call D the subset of the set of swift data for a
mapper and F corresponding subset of filesystem objects, map is a
function from D to F, while existing returns a collection of objects in
D. So theoretically map on each element of that collection should work.
In this case the object in D is [3], which indicates that we are
probably talking about an array mapper. Could you tell me which one it
is? And also what files you are trying to map with it.
Mihael
On Thu, 2011-03-24 at 16:28 -0500, Allan Espinosa wrote:
> I'm trying figure out where in my workflow is causing this problem:
>
> 2011-03-24 16:23:50,485-0500 WARN FlowNode Ex098
> java.lang.IllegalStateException: mapper.existing() returned a path [3]
> that it cannot subsequently map
> at org.griphyn.vdl.mapping.RootDataNode.checkInputs(RootDataNode.java:129)
> at org.griphyn.vdl.mapping.RootArrayDataNode.checkInputs(RootArrayDataNode.java:67)
> at org.griphyn.vdl.mapping.RootArrayDataNode.innerInit(RootArrayDataNode.java:53)
> at org.griphyn.vdl.mapping.RootArrayDataNode.handleClosed(RootArrayDataNode.java:80)
> at org.griphyn.vdl.mapping.AbstractDataNode.notifyListeners(AbstractDataNode.java:583)
> at org.griphyn.vdl.mapping.AbstractDataNode.closeShallow(AbstractDataNode.java:396)
> at org.griphyn.vdl.mapping.ArrayDataNode.closeDeep(ArrayDataNode.java:51)
> at org.griphyn.vdl.karajan.lib.PartialCloseDataset.function(PartialCloseDataset.java:79)
> at org.griphyn.vdl.karajan.lib.VDLFunction.post(VDLFunction.java:68)
> at org.globus.cog.karajan.workflow.nodes.Sequential.startNext(Sequential.java:29)
> at org.globus.cog.karajan.workflow.nodes.Sequential.executeChildren(Sequential.java:20)
> at org.globus.cog.karajan.workflow.nodes.FlowContainer.execute(FlowContainer.java:63)
> at org.globus.cog.karajan.workflow.nodes.FlowNode.restart(FlowNode.java:139)
> at org.globus.cog.karajan.workflow.nodes.FlowNode.start(FlowNode.java:197)
> at org.globus.cog.karajan.workflow.events.EventBus.start(EventBus.java:104)
> at org.globus.cog.karajan.workflow.events.EventTargetPair.run(EventTargetPair.java:40)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
>
> It doesn't specify which data object it crashes on so i'm quite
> clueless at this point.
>
> I'm using the latest trunk
>
> any particular log4j class i should be enabling to debug?
>
>
> Thanks,
> -Allan
>
More information about the Swift-user
mailing list