Re: pyflink1.11 udf计算结果打印问题 Task Off-Heap Memory 0 bytes is less than the least required Python worker Memory 79 mb

2021-02-02 文章 Xingbo Huang
Hi, 报错信息说了最少需要79m,我看你代码配成0m,当然还是继续报错呀 Best, Xingbo 肖越 <18242988...@163.com> 于2021年2月3日周三 上午10:24写道: > pyflink1.11 测试udf函数,将表格定义的一列Double类型输入,计算这一列数值的累乘积, > 结果返回一个Double类型数值,已经配置了taskmanager.memory.task.off-heap.size,但没什么用。 > 结果print报错: > Traceback (most recent call last): > File

pyflink1.11 udf计算结果打印问题 Task Off-Heap Memory 0 bytes is less than the least required Python worker Memory 79 mb

2021-02-02 文章 肖越
pyflink1.11 测试udf函数,将表格定义的一列Double类型输入,计算这一列数值的累乘积, 结果返回一个Double类型数值,已经配置了taskmanager.memory.task.off-heap.size,但没什么用。 结果print报错: Traceback (most recent call last): File "C:*/udtf_test.py", line 42, in env.execute_sql('INSERT INTO print_result SELECT multi_production(YLDRATE) FROM