是 compile 遇到 beyond 64k 异常了?
可以考虑使用 1.14 及以上版本, 引入了自动的 code splitting:
https://issues.apache.org/jira/browse/FLINK-23007
Best,
Lincoln Lee
godfrey he 于2022年5月26日周四 23:29写道：
> 确认一下是sql文本超过64k？具体的异常是什么？
>
> Yun Tang 于2022年5月26日周四 10:06写道：
> >
> > Hi
> >
> >
把异常栈也发出来吧
zhangbin 于2022年5月26日周四 22:54写道：
DataStream skuDataStream = stream.map(
(MapFunction) s -> {
DataSource ret = JSONObject.parseObject(s,
DataSource.class);
ret.setEvent_ts(dateTime.parse(ret.getLog_creation_time(),
pattern).getMillis());
return
重发下图
https://sm.ms/image/12XQHAOZdYoqraC
https://sm.ms/image/zJ2gfmxvSc85Xl7
lxk7...@163.com
发件人： lxk7...@163.com
发送时间： 2022-05-26 20:54
收件人： user-zh
主题： Flink异步IO使用问题
我在程序里使用了异步IO,但是好像识别不了这个list类型的数据
lxk7...@163.com
我在程序里使用了异步IO,但是好像识别不了这个list类型的数据
lxk7...@163.com
比如对于 1.13.6
把flink下面的/lib/flink-table_2.11-1.13.6.jar给删掉
Best,
Jingsong
On Thu, May 26, 2022 at 2:54 PM hdxg1101300...@163.com <
hdxg1101300...@163.com> wrote:
> 好的，知道了，以后用这个中文邮件！
> flink-table-legacy 这个模块应该没用，但是我也没找到他在那，是一个独立的模块吗？
>
> --
> hdxg1101300...@163.com
>
Please send to user-zh@flink.apache.org
Best,
Jingsong
On Thu, May 26, 2022 at 2:20 PM Jingsong Li wrote:
> 如果flink-table-legacy包没用到，把它删掉即可修复你的问题
>
> Best,
> Jingsong
>
> On Thu, May 26, 2022 at 2:16 PM hdxg1101300...@163.com <
> hdxg1101300...@163.com> wrote:
>
>> 你好：
>>
