As Prateek mentioned, I also double checked the exception, which comes from a class (ApplicationUtil.java) that only exists in Samza 1.0. Please remove any Samza 1.0 dependency since Beam api currently works with Samza 0.14.1.
Your config looks mostly correct to me. The following is not needed: job.factory.class=org.apache.samza.job.local.ProcessJobFactory And you probably need to config this for any data repartitioning: job.default.system=kafka Thanks, Xinyu On Thu, Jan 3, 2019 at 10:03 AM Prateek Maheshwari <prateek...@gmail.com> wrote: > Hi Omkar, > > I think it's only possible to get that exception with Samza 1.0. Can > you verify that the deployment is indeed using samza 0.14.1? > > Thanks, > Prateek > > On Wed, Jan 2, 2019 at 11:40 PM Deshpande, Omkar > <omkar_deshpa...@intuit.com> wrote: > > > > Hello, > > > > I have been able to execute my Samza-Beam application in Local mode. And > now I am trying to run a Samza-Beam application in Standalone mode. > > > > Here is my configFile config.properties: > > > > app.name=test-app > > job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory > > job.coordinator.zk.connect=localhost:2181 > > job.coordinator.system=kafka > > job.factory.class=org.apache.samza.job.local.ProcessJobFactory > > # Kafka System > > > systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory > > systems.kafka.consumer.zookeeper.connect=localhost:2181 > > systems.kafka.producer.bootstrap.servers=localhost:9092 > > systems.kafka.default.stream.replication.factor=1 > > > > I am getting following exception: > > > > org.apache.samza.config.ConfigException: Legacy task applications must > set a non-empty task.class in configuration. > > > > at > org.apache.samza.application.ApplicationUtil.fromConfig(ApplicationUtil.java:58) > > > > at > org.apache.samza.runtime.LocalContainerRunner.main(LocalContainerRunner.java:87) > > > > Versions: > > <beam.version>2.9.0</beam.version> > > <samza.version>0.14.1</samza.version> > > > > As per my understanding, I shouldn’t have to create implementation of > StreamApplication or StreamTask while using Beam SDK. > > > > An example of configFile for Samza-Beam Standalone application would be > helpful. > > > > Regards, > > Omkar Deshpande >
