A partitionmapper can get infinite=true, this is not handled yet in the InputImpl.
The implementation will do a kind of polling until it gets data.