Re: Beam Samza Runner - java.lang.UnsupportedOperationException: Cannot create a producer for an input system

2019-01-07 Thread Prateek Maheshwari
+ Xinyu > On Jan 4, 2019, at 9:58 PM, Deshpande, Omkar > wrote: > > Hello, > > I am getting following exception while running Beam Samza Runner – > > java.lang.UnsupportedOperationException: Cannot create a produce

Beam Samza Runner - java.lang.UnsupportedOperationException: Cannot create a producer for an input system

2019-01-04 Thread Deshpande, Omkar
Hello, I am getting following exception while running Beam Samza Runner – java.lang.UnsupportedOperationException: Cannot create a producer for an input system at org.apache.beam.runners.samza.adapter.BoundedSourceSystem$Factory.getProducer(BoundedSourceSystem.java:411