Hi ,

AthenaX looks like a perfect fit for our usage, we are in the process of building a platform where in users can submit jobs , aggregate and perform sinks. Sadly the docs are not helping, can u share a sample docs which helps understand on how kafka works and sink with es Some of the docs are not relevant with class files not found

FAQ 1. Waterdrop开发者自己开发插件时，是否需要了解Waterdrop代码，是否需要把代码写到Waterdrop项目里？

开发者开发的插件，与waterdrop项目可以完全没有关系，不需要把你的插件代码写到waterdrop项目里面。
插件可以是一个完全独立的项目，在里面你用java，scala，maven，sbt，gradle，都随你。
这也是我们建议开发者开发插件的方式。

FAQ 2. 以集群模式(cluster)运行waterdrop，提示找不到：plugins.tar.gz

使用cluster模式提交前，需要您先执行如下命令：

# 备注： 预计下一个版本发布时，v1.2.3 我们会支持插件目录自动打包，无需再执行此命令。
tar zcvf plugins.tar.gz plugins

将插件目

1. 安装linkis jobtypes
   按照官方安装文档进行自动化安装，执行sh install.sh最后一步报错：{"error":"Missing required parameter 'execid'."}。并没有看到文档中所说的“如果安装成功最后会打印：{"status":"success"}”，但是能在azkaban的/plugins/jobtypes目录下看到已经安装好的linkis任务插件。通过排查在安装脚本最后一步会去调用"curl http://azkaban_ip:executor_port/executor?action=reloadJobTypePlugins"进行插件的刷新。重启azkaban executor日志中看到已经加载了插件的信息 `INFO [JobTypeManager][Azkaban] Loaded jobtype linkis

See https://github.com/tensorflow/transform/blob/master/tensorflow_transform/mappers.py#L374

As a follow up of #235 , we would like to extend the getting started templates with an example of a project that uses multiple runtimes (e.g. Akka-streams + Spark or Akka-streams+ Flink).

It should show the multi-project setup in the build and the suggested directory organization per runtime.