This might have been https://issues.apache.org/jira/browse/BEAM-103 ?
But if so, the good news it was fixed four days ago ;-) On Mon, May 9, 2016 at 3:11 PM, amir bahmanyari <[email protected]> wrote: > Hi Colleagues, > I get this exception at runtime... > Any ideas pls? > Thanks > > > java.lang.UnsupportedOperationException: The transform KafkaIO.Read > [KafkaIO.TypedWithoutMetadata] is currently not supported. > at > org.apache.beam.runners.flink.translation.FlinkStreamingPipelineTranslator.visitTransform(FlinkStreamingPipelineTranslator.java:106) > >
