Sunil,
For key based partitioning, the getPartition method is supposed to return a
consistent integer representing the key for partitioning. Typically the
java hashCode of the key. The tuples are then routed based on the integer
and looking at its lower bits on the mask (number of lower bits)
Hi Team,
Can you please let me know the reason, when we will get this kind of
exception. In my application containers getting killled with below
excpetion.
java.lang.RuntimeException: java.io.IOException: All datanodes
