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)

  at 
org.apache.samza.container.SamzaContainer$$anonfun$13.apply(SamzaContainer.scala:223)

  at 
org.apache.samza.container.SamzaContainer$$anonfun$13.apply(SamzaContainer.scala:220)

  at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)

  at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)

  at scala.collection.immutable.Map$Map3.foreach(Map.scala:161)

  at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)

  at scala.collection.AbstractTraversable.map(Traversable.scala:104)

  at 
org.apache.samza.container.SamzaContainer$.apply(SamzaContainer.scala:220)

  at org.apache.samza.container.SamzaContainer.apply(SamzaContainer.scala)

  at 
org.apache.samza.processor.StreamProcessor.createSamzaContainer(StreamProcessor.java:198)

  at 
org.apache.samza.processor.StreamProcessor$1.onNewJobModel(StreamProcessor.java:290)

  at 
org.apache.samza.zk.ZkJobCoordinator.onNewJobModelConfirmed(ZkJobCoordinator.java:304)

  at 
org.apache.samza.zk.ZkJobCoordinator$ZkBarrierListenerImpl.lambda$onBarrierStateChanged$1(ZkJobCoordinator.java:394)

  at 
org.apache.samza.zk.ScheduleAfterDebounceTime.lambda$getScheduleableAction$0(ScheduleAfterDebounceTime.java:163)

  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

  at java.util.concurrent.FutureTask.run(FutureTask.java:266)

  at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)

  at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)

  at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

  at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

  at java.lang.Thread.run(Thread.java:748)

2019-01-04 21:39:11 ERROR SamzaContainer$:86 - Failed to create a producer for 
0-KafkaIO_Read_Read_KafkaUnboundedSource__out__PCollection_, so skipping.

java.lang.UnsupportedOperationException: Cannot create a producer for an input 
system

  at 
org.apache.beam.runners.samza.adapter.UnboundedSourceSystem$Factory.getProducer(UnboundedSourceSystem.java:452)

  at 
org.apache.samza.container.SamzaContainer$$anonfun$13.apply(SamzaContainer.scala:223)

  at 
org.apache.samza.container.SamzaContainer$$anonfun$13.apply(SamzaContainer.scala:220)

  at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)

  at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)

  at scala.collection.immutable.Map$Map3.foreach(Map.scala:161)

  at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)

  at scala.collection.AbstractTraversable.map(Traversable.scala:104)

  at 
org.apache.samza.container.SamzaContainer$.apply(SamzaContainer.scala:220)

  at org.apache.samza.container.SamzaContainer.apply(SamzaContainer.scala)

  at 
org.apache.samza.processor.StreamProcessor.createSamzaContainer(StreamProcessor.java:198)

  at 
org.apache.samza.processor.StreamProcessor$1.onNewJobModel(StreamProcessor.java:290)

  at 
org.apache.samza.zk.ZkJobCoordinator.onNewJobModelConfirmed(ZkJobCoordinator.java:304)

  at 
org.apache.samza.zk.ZkJobCoordinator$ZkBarrierListenerImpl.lambda$onBarrierStateChanged$1(ZkJobCoordinator.java:394)

  at 
org.apache.samza.zk.ScheduleAfterDebounceTime.lambda$getScheduleableAction$0(ScheduleAfterDebounceTime.java:163)

  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

  at java.util.concurrent.FutureTask.run(FutureTask.java:266)

  at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)

  at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)

  at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

  at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

  at java.lang.Thread.run(Thread.java:748)

This exception does not stop the execution, however I would like to understand 
the reason for this and possible resolution.

Thanks,
Omkar Deshpande

[GitHub] samza pull request #870: SamzaSQL: Documentation Enhancement (fix broken sam...

2019-01-04 Thread asfgit 
Github user asfgit closed the pull request at:

https://github.com/apache/samza/pull/870


---

[GitHub] samza pull request #870: SamzaSQL: Documentation Enhancement (fix broken sam...

2019-01-04 Thread shenodaguirguis 
GitHub user shenodaguirguis opened a pull request:

https://github.com/apache/samza/pull/870

SamzaSQL: Documentation Enhancement (fix broken same-page links)



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/shenodaguirguis/samza docfix

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/samza/pull/870.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #870


commit 86825a01224114a8794ec6a7bac2129563d4a020
Author: Shenoda Guirguis 
Date:   2018-12-20T18:59:51Z

SamzaSQL: Documentation Enhancement (fix broken same-page links)




---