flink 1.11.2 fileSystem source table 读取 fileSystem sink table 分区错误问题

1.问题描述 基于flink filesystem connect 创建create table source_test(id string,name string dayno sring,`hour` string) partitioned (dayno ,`hour`) with('connector'='filesystm',path='x/data/') 报错堆栈如下： | ava.lang.reflect.InvocationTargetException at

加载外部配置文件

哪位大佬用过typeSafe config，flink 如何把外部.conf 配置文件，在main函数中，通过全局配置的方式，传递给function 在open函数里调用 | | 范未太 | | 邮箱：fwt_...@163.com | 签名由 网易邮箱大师 定制