退订

[zenglong chen]

退订

flink kafka consumer部分消息未消费

[zenglong chen]

一个test topic，手动往里面添加消息，flink消费后print输出，发现会漏掉部分添加的消息，问题可能出在哪里？前辈有人遇到过类似问题吗？

Re: flink batch python api的脚本print标准输出看不到

[zenglong chen]

本地cluster的确重启后有在out文件看到print了，多谢解答！

Jimmy  于2019年7月15日周一 上午11:11写道：

> 你需要重启 Flink，log/ 下才会有 out 文件，仅仅重新执行任务没有用的
>
>
> | |
> Jimmy
> |
> |
> wangzmk...@163.com
> |
> 签名由网易邮箱大师定制
>
>
> 在2019年07月11日 11:03，zenglong chen 写道：
>
> 本地我尝试删除log/所有东西，然后执行任务，完成，再看log/目录，只有client。log文件（里面没有print输出内容），没有其他standalone或taskexecute的out或者log，
>
> Jeff Zhang  于2019年7月11日周四 上午10:34写道：
>
> 那你需要在TM的log里才能看到output
>
> zenglong chen  于2019年7月11日周四 上午10:20写道：
>
> 我的flink是本地standlone集群，TM端应该就是本地吧。
>
> Jeff Zhang  于2019年7月10日周三 下午7:10写道：
>
> batch的print是print在TM端，不是client端
>
> zenglong chen  于2019年7月10日周三 下午6:10写道：
>
> 大家好，请教一下，flink batch python
> api的脚本，我想用print判断一下是否获取到数据了，但我在client端看不到输出，只看到Program execution
> finished，log/目录下也没有out文件（我先删除了所有log），有什么解决办法吗？
> 此外，我尝试在map函数里面raise
> exception，程序还是执行成功了，标记finished！！！这个是bug吗？flink捕捉不了python的异常信息吗？
>
>
>
> --
> Best Regards
>
> Jeff Zhang
>
>
>
>
> --
> Best Regards
>
> Jeff Zhang
>
>

pyflink detached mode

[zenglong chen]

Hi,alls:
How to use bin/pyflink.sh xxx.py in detached mode?
Thanks for answer.

Re: flink batch python api的脚本print标准输出看不到

[zenglong chen]

本地我尝试删除log/所有东西，然后执行任务，完成，再看log/目录，只有client。log文件（里面没有print输出内容），没有其他standalone或taskexecute的out或者log，

Jeff Zhang  于2019年7月11日周四 上午10:34写道：

> 那你需要在TM的log里才能看到output
>
> zenglong chen  于2019年7月11日周四 上午10:20写道：
>
> > 我的flink是本地standlone集群，TM端应该就是本地吧。
> >
> > Jeff Zhang  于2019年7月10日周三 下午7:10写道：
> >
> > > batch的print是print在TM端，不是client端
> > >
> > > zenglong chen  于2019年7月10日周三 下午6:10写道：
> > >
> > > > 大家好，请教一下，flink batch python
> > > > api的脚本，我想用print判断一下是否获取到数据了，但我在client端看不到输出，只看到Program execution
> > > > finished，log/目录下也没有out文件（我先删除了所有log），有什么解决办法吗？
> > > > 此外，我尝试在map函数里面raise
> > > > exception，程序还是执行成功了，标记finished！！！这个是bug吗？flink捕捉不了python的异常信息吗？
> > > >
> > >
> > >
> > > --
> > > Best Regards
> > >
> > > Jeff Zhang
> > >
> >
>
>
> --
> Best Regards
>
> Jeff Zhang
>

Question about flink batch python api's print

[zenglong chen]

Hello,guys.
I use python print in flink map function to see whether i get the data,but
i didn't see anything in client or path log/***.out,just Program execution
finished.
Is there any way to solve this and see print?
Besides,I try to use raise Exception in Map() and flink still complete as
finished!!!Is it a bug?Can flink catch python's error message?