Hi,
As a platform user, I want to integrate Flink SQL with the platform. The usage
scenario is：users register table/udf to catalog service, and then write SQL
scripts like: "insert into xxx select from xxx" through Web SQLEditor, the
platform need to validate the SQL script after each time the
可以用 flink 提供的 Restful API 接口，upload 上传 jar 包然后 run。
参考：
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html#jars-upload
和 https://files.alicdn.com/tpsservice/a8d224d6a3b8b82d03aa84e370c008cc.pdf
文档的介绍
文报 <1010467...@qq.com> 于2019年3月28日周四 下午9:06写道：
> 各位好！
>
>
>
Hi，
I encountered an error while running the kafka sink demo in IDEA.
This is the complete code:
import java.util.Properties
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.runtime.state.filesystem.FsStateBackend
import
I think this is not the root cause of job failure, this task is caused by
other tasks failing. You can check the log of the first failed task.
2017-03-10 12:25 GMT+08:00 Govindarajan Srinivasaraghavan <
govindragh...@gmail.com>:
> Hi All,
>
> I see the below error after running my streaming job
