SELECT class_no, collect(info)
FROM (
SELECT class_no, ROW(student_no, name, age) AS info
FROM source_table
)
GROUP BY class_no;
从SQL层面想到比较接近的方法，但multiset无法转array
从你的需求描述看，mongodb目标表的这种班级设计平时可能不太需要，如果是为了查某个班所有的学生的话，在查询的时候加个where条件即可，没有必要把明细数据再放到一个数组里面
感觉可能是你定义表结构和实际使用方面的问题，可以换个角度思考下
在
Thanks for starting this discussion Yingjie,
How will our tests be affected by these changes? Will Flink require more
resources and, thus, will it risk destabilizing our testing infrastructure?
I would propose to create a FLIP for these changes since you propose to
change the default behaviour.
看报错和log4j 文件格式有关，log4j.properties的文件改为log4j2.xml 试一下
发件人: summer
发送时间: 2021年12月2日 11:32
收件人: user-zh@flink.apache.org
主题: ERROR org.apache.flink.shaded.curator4.org.apache.curator.ConnectionState -
Authentication failed
退订发送到 user-zh-unsubscr...@flink.apache.org
发件人: ™薇维苿尉℃
发送时间: 2021年12月3日 17:34
收件人: user-zh
主题: 退订
退订
Hi dev & users,
We propose to change some default values of blocking shuffle to improve the
user out-of-box experience (not influence streaming). The default values we
want to change are as follows:
1. Data compression
(taskmanager.network.blocking-shuffle.compression.enabled): Currently, the
