pyflink问题求助（入门级）

[洗你的头]

尊敬的开发者您好：

我在新使用pyflink时，跑通了简单的单词统计的例子，但是在运行求和的例子时报错了，我不知道如何解决

具体内容为：

代码见图1.png，错误信息见图2.jpg，当我按照网上的解决方案添加了被注释掉的两行代码时，会出现如图3.png的新错误。

我该如何解决呢？（或者您可以推荐几个我在中国国内比较活跃的答疑社区吗？）

因这种可能较简单的问题打扰到您，万分歉意，祝您工作愉快，身体健康！

[Xingbo Huang]

Hi,
你似乎没有把你的3个图给成功贴上来。如果是之前你抛出来的那个代码和错误的话，就像hailong解释的，是你的读入的csv数据源的数据的第一列数据有的不是Long导致的，你需要检查一下你的数据内容。还有你那个arrow的batchsize设置成2也太小了点，默认情况下是10000，其实大部分情况你是不需要去设置这个值的。
，
Best,
Xingbo

[洗你的头]

感谢您的解答，很有帮助，我大概知道自己应该如何去做了。
（贴图的问题是由于我之前没有按照官网的操作来做，batchsize的设置经由您的解答我也知道了）
很感谢！




------------------ 原始邮件 ------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年10月26日(星期一) 上午9:53
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: pyflink问题求助（入门级）



Hi,
你似乎没有把你的3个图给成功贴上来。如果是之前你抛出来的那个代码和错误的话，就像hailong解释的，是你的读入的csv数据源的数据的第一列数据有的不是Long导致的，你需要检查一下你的数据内容。还有你那个arrow的batchsize设置成2也太小了点，默认情况下是10000，其实大部分情况你是不需要去设置这个值的。
，
Best,
Xingbo