[APEXMALHAR-1643] FileSplitter recovery fails

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Component/s: adapters other
• Assignee: Chandni Singh
• Reporter: Chandni Singh
• Created: 22/Jan/15 07:51
• Updated: 03/Jan/16 10:01
• Resolved: 22/Jan/15 23:53

Description

Serialization trace:
storageAgent (com.datatorrent.lib.io.IdempotentStorageManager$FSIdempotentStorageManager)
idempotentStorageManager (com.datatorrent.lib.io.fs.FileSplitter)
at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy$2.newInstance(Kryo.java:1218)
at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1061)
at com.esotericsoftware.kryo.serializers.FieldSerializer.create(FieldSerializer.java:547)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:523)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:679)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:679)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:761)
at com.datatorrent.lib.util.FSStorageAgent.retrieve(FSStorageAgent.java:164)
at com.datatorrent.lib.util.FSStorageAgent.load(FSStorageAgent.java:109)
at com.datatorrent.stram.engine.StreamingContainer.deployNodes(StreamingContainer.java:820)
at com.datatorrent.stram.engine.StreamingContainer.deploy(StreamingContainer.java:768)
at com.datatorrent.stram.engine.StreamingContainer.processHeartbeatResponse(StreamingContainer.java:724)
... 2 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy$2.newInstance(Kryo.java:1216)
... 17 more
Caused by: java.lang.IllegalArgumentException: Can not create a Path from a null string
at org.apache.hadoop.fs.Path.checkPathArg(Path.java:123)
at org.apache.hadoop.fs.Path.<init>(Path.java:135)
at com.datatorrent.lib.util.FSStorageAgent.<init>(FSStorageAgent.java:55)
at com.datatorrent.lib.util.FSStorageAgent.<init>(FSStorageAgent.java:47)