Re: Pyflink tutorial output

2021-03-24 Thread Robert Cullen
Ah, there they are. Thanks! On Tue, Mar 23, 2021 at 10:26 PM Dian Fu wrote: > How did you check the output when submitting to the kubernetes session > cluster? I ask this because the output should be written to the local > directory “/tmp/output” on the TaskManagers where the jobs are running o

Re: Pyflink tutorial output

2021-03-23 Thread Dian Fu
How did you check the output when submitting to the kubernetes session cluster? I ask this because the output should be written to the local directory “/tmp/output” on the TaskManagers where the jobs are running on. Regards, Dian > 2021年3月24日 上午2:40,Robert Cullen 写道: > > I’m running this scr

Re: Pyflink tutorial output

2021-03-23 Thread Shuiqiang Chen
Hi Robert, Have you tried exploring the /tmp/output directory in the task manager pods on you kubernetes cluster? The StreamingFileSink will create the output directory on the host of task manager in which the sink tasks are executed. Best, Shuiqiang Robert Cullen 于2021年3月24日周三 上午2:48写道: > I’m