In a previous thread <https://mail-archives.apache.org/mod_mbox/beam-user/201604.mbox/%[email protected]%3E> JB said that DirectPipelineRunner was fixed to work with Unbounded. I was using the DirectPipelineRunner with KafkaIO and it still gave the error about not supporting unbounded. I'm using commit e20dbc1/Jun 7 to run against. Was it fixed or was this a regression?
Thanks, Jesse
