Re: kafka sink

Hi nick, Is there any error log? That may help to analyze the root cause. On Sun, Jul 23, 2023 at 9:53 PM nick toker wrote: > hello > > > we replaced deprecated kafka producer with kafka sink > and from time to time when we submit a job he stack for 5 min in > inisazaing ( on sink operators) >

Re: Set processing time in the past

Hi, Eugenio Can you describe the requirements in more detail? Best, Ron Shammon FY 于2023年7月17日周一 09:10写道： > Hi Eugenio, > > I cannot catch it clearly, could you describe it in more detail? > > Best, > Shammon FY > > On Sat, Jul 15, 2023 at 5:14 PM Eugenio Marotti < >

Re: flink1.17.1版本 MiniCluster is not yet running or has already been shut down.

Hi, 运行的是哪个例子？从错误上看是在从MiniCluster获取结果的时候，MiniCluster被关闭了 Best, Shammon FY On Sat, Jul 22, 2023 at 3:25 PM guanyq wrote: > 本地IDEA运行 MiniCluster is not yet running or has already been shut down. > 请问是什么原因，如何处理 > > > > > 15:19:27,511 INFO >

RE: TCP server socket with Kubernetes Cluster

Hello Community, Please share views for below mail. Rgds, Kamal From: Kamal Mittal via user Sent: 21 July 2023 02:02 PM To: user@flink.apache.org Subject: TCP server socket with Kubernetes Cluster Hello, Created a TCP server socket single source function and it is opened on a single POD

kafka sink

hello we replaced deprecated kafka producer with kafka sink and from time to time when we submit a job he stack for 5 min in inisazaing ( on sink operators) we verify the the transaction prefix is unique it's not happened when we use kafka producer What can be the reason?

退订

退订