I want to Write SequcenFile from TypedPipe

88 views
Skip to first unread message

jihoon Kang

unread,
Apr 14, 2014, 12:38:30 AM4/14/14
to cascadi...@googlegroups.com
I want to write SequcenFile from TypedPipe.

so.


val c:TypedPipe[(String, CustomClass)]  = cload()

c.write(TypedSink(SequenceFile(output)))

Caused by: com.esotericsoftware.kryo.KryoException: Error constructing instance of class: cascading.scheme.hadoop.SequenceFile
Serialization trace:
scheme (cascading.tap.hadoop.Hfs)
sinks (cascading.flow.FlowDef)

error occurred

How can i deal this problem?

Miguel Ping

unread,
Apr 15, 2014, 5:53:16 AM4/15/14
to cascadi...@googlegroups.com
Can you post complete stack trace?

Oscar Boykin

unread,
Apr 15, 2014, 12:19:11 PM4/15/14
to cascadi...@googlegroups.com
Take a look at the serialization FAQ:


This appears to me to be an issue with something being captured inside a closure (quick explanation here:




--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cascading-use...@googlegroups.com.
To post to this group, send email to cascadi...@googlegroups.com.
Visit this group at http://groups.google.com/group/cascading-user.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/73b2ea46-9e5a-432e-aaa9-cf9b1fe85d3a%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.



--
Oscar Boykin :: @posco :: http://twitter.com/posco
Reply all
Reply to author
Forward
0 new messages