??????flinksql ????collect??????????????????Multiset????????java udf????????????????????????????????

hello , listagg, ---- ??: "Mr.S"

回复: Flink on Native K8S作业节点调度问题

您好： 这个需求是可以实现的，您可以在启动脚本中指定创建k8s pod的模板：-Dkubernetes.pod-template-file=./pod-template.yaml，在模板中您需要使用nodeSelector来指定该容器部署到哪些节点，节点需要打上label，完整模板如下： ``` apiVersion: v1 kind: Pod metadata: name: flink-pod-template spec: nodeSelector: disktype: "ssd" containers: # Do not change

Flink机器学习扩展文档在哪？

以前Flink官方有个机器学习库的文档，新版文档我发现已经没了 https://github.com/apache/flink-ml

flink ????checkpoint????

:flink1.14.0 : flink 1.14.0??jdk1.7??yarn??checkpoint,IN_PROGRESS : ./bin/flinksql-submit.sh \ --sql sqlserver-cdc-to-kafka.sql \ -m yarn-cluster \ -ynm sqlserverTOkafka \ -ys 2 \ -yjm 1024 \ -ytm 1024 \ -yid

Flink on Native K8S作业节点调度问题

k8s集群有2个节点配置了SSD盘，其他节点是普通硬盘，希望实现配置了rocksdb状态后端类型的作业部署到这2个ssd节点，同时希望其他非rocksdb状态后端作业不会被调度到这2个ssd节点 请问：flink 1.13.2有办法实现吗？如果能实现的话，具体应该怎么操作呢？最好给个具体例子，谢谢！