I think the following is the interesting part of the stack-trace:
|Causedby:java.lang.RuntimeException:Failedto copy object.at
org.apache.flink.storm.api.FlinkTopology.copyObject(FlinkTopology.java:145)at
org.apache.flink.storm.api.FlinkTopology.getPrivateField(FlinkTopology.java:132)at
org.apache.flink.storm.api.FlinkTopology.<init>(FlinkTopology.java:89)at
org.apache.flink.storm.api.FlinkTopology.createTopology(FlinkTopology.java:105)at
stormWorldCount.WordCountTopology.buildTopology(WordCountTopology.java:96)|
relevant method:
private <T> T copyObject(T object) {
try {
return InstantiationUtil.deserializeObject(
InstantiationUtil.serializeObject(object),
getClass().getClassLoader()
);
} catch (IOException | ClassNotFoundException e) {
throw new RuntimeException("Failed to copy object.");
}
}
sadly another case where we just swallow the exception cause.
On 13.04.2016 14:35, Chesnay Schepler wrote:
http://stackoverflow.com/questions/36584784/issues-while-submitting-a-topology-to-apache-flink-using-the-flink-api
On 13.04.2016 14:28, Till Rohrmann wrote:
Hi jstar,
what's exactly the problem you're observing?
Cheers,
Till
On Wed, Apr 13, 2016 at 2:23 PM, star jlong <jlongs...@yahoo.fr.invalid>
wrote:
Hi there,
I'm jstar. I have been playing around with flink. I'm very much
interested
in submitting a topoloy to flink using its api. As indicated
on stackoverflow, that is the try that I have given. But I was stuck
with
some exception. Please any help will be welcoming.
Thanks.
jstar
