Re: Testing RichAsyncFunction with TestHarness
Posted by
KristoffSC on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Testing-RichAsyncFunction-with-TestHarness-tp33947p33948.html
I've debug it a little bit and I found that it fails in
InstantiationUtil.readObjectFromConfig method when we execute
byte[] bytes = config.getBytes(key, (byte[])null); This returns null.
The key that it is looking for is "edgesInOrder". In the config map, there
are only two entries though.
For "checkpointing -> {Boolean@6347} true" and "operatorID ->
{byte[16]@6351} "
--
Sent from:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/