Re: Beam stuck when trying to run on remote Flink cluster

2021-02-08 Thread Joseph Zack
ror or > anything. How can I debug this? > > Thanks! > Nir > -- Joseph Zack Software Engineer | Information Security Group | Symantec Enterprise Division Broadcom mobile: 407.920.4930 joseph.z...@broadcom.com | broadcom.com -- This electronic communication and the inform

Re: Streaming Beam jobs keep restarting on Spark/Kubernetes?

2020-06-12 Thread Joseph Zack
com/GoogleCloudPlatform/spark-on-k8s-operator> * The driver spins up and creates executors * It connects to a Kafka topic * Job completes and shuts down Am I missing something? Is this what is supposed to happen? [image: image.png] On Mon, Jun 8, 2020 at 4:56 PM Joseph Zack wrote: > I'm submitti

Re: Streaming Beam jobs keep restarting on Spark/Kubernetes?

2020-06-08 Thread Joseph Zack
you provide more information about how you're running the job? > > On Mon, Jun 8, 2020 at 1:50 PM Joseph Zack > wrote: > >> Anybody out there running Beam on Spark? >> >> I am pulling data from a Kafka topic with KafkaIO, but the job keeps >> restart

Streaming Beam jobs keep restarting on Spark/Kubernetes?

2020-06-08 Thread Joseph Zack
ks for your consideration! -- Joseph Zack Software Engineer | Information Security Group | Symantec Enterprise Division Broadcom mobile: 407.920.4930 joseph.z...@broadcom.com | broadcom.com smime.p7s Description: S/MIME Cryptographic Signature