We're working on moving the DirectPipelineRunner out of the Core SDK and updating the default to what is currently called the InProcessPipelineRunner. Until that occurs, you can instead use the InProcessPipelineRunner, part of the org.apache.beam:beam-runners-direct-java artifact.
On Wed, Jun 8, 2016 at 10:37 AM, Jesse Anderson <[email protected]> wrote: > 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 >
