>From what I understood, in your case you might solve your issue by using >specific key classes instead of Strings.
Maybe you could create key classes that have a user-specified hashcode that could take the previous key's hashcode as a value. That way your data shouldn't be sent over the wire and stay in the same partition thus on the same taskmanager..
