V2 Flink: * Flink QuickStart 写的不清楚,跟着执行都走不下去 https://github.com/InterestingLab/waterdrop-docs/blob/master/zh-cn/v2/flink/quick-start.md 比如:wd下载地址仅指向了一个固定版本是个问题;已经启动了fake,为什么还要执行nc ?,webui去哪里看,是否需要提前启动好flink集群(应该分为本地试用/提交到flink standalone/提交到yarn)?flink看起来不能以local模式的方式启动(Flink 叫Local Setup,使用方式可以直接贴链接:https://ci.apache.org/projects/flink/flink-docs-stable/getting-started/tutorials/local_setup.html)。 * WD Flink 的Deploy方式,例如如何提交到yarn上? * Source 文档,`format` 改为 `format.type`,增加了avro格式。 * bin/start-waterdrop-flink.sh 可以兼容/bin/fink 的所有参数吗?start-waterdrop-flink.sh 的时候,应该把官方链接也贴出来:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/cli.html * 新增章节:Waterdrop Flink Job的管理(提交、启动、停止),可参照官方文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/cli.html * 插件开发文档 * flink 配置中,缺少一个像spark那样的`完整配置案例`。 * Flink 统一增加关于Format,数据源格式的介绍
V2 Flink:
Flink QuickStart 写的不清楚,跟着执行都走不下去
https://github.com/InterestingLab/waterdrop-docs/blob/master/zh-cn/v2/flink/quick-start.md
比如:wd下载地址仅指向了一个固定版本是个问题;已经启动了fake,为什么还要执行nc ?,webui去哪里看,是否需要提前启动好flink集群(应该分为本地试用/提交到flink standalone/提交到yarn)?flink看起来不能以local模式的方式启动(Flink 叫Local Setup,使用方式可以直接贴链接:https://ci.apache.org/projects/flink/flink-docs-stable/getting-started/tutorials/local_setup.html)。
WD Flink 的Deploy方式,例如如何提交到yarn上?
Source 文档,
format改为format.type,增加了avro格式。bin/start-waterdrop-flink.sh 可以兼容/bin/fink 的所有参数吗?start-waterdrop-flink.sh 的时候,应该把官方链接也贴出来:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/cli.html
新增章节:Waterdrop Flink Job的管理(提交、启动、停止),可参照官方文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/cli.html
插件开发文档
flink 配置中,缺少一个像spark那样的
完整配置案例。Flink 统一增加关于Format,数据源格式的介绍