Re: FileSystemTableSink支持自定义分隔符写入

2021-03-24 文章 easonliu30624700
通过设置properties(csv.field-delimiter)可以指定分隔符。不过只能指定单字符。多字符分割不支持。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink-1.11.2版本,客户端如何设置dynamic properties

2021-03-23 文章 easonliu30624700
看FlinkYarnSessionCli代码: final Configuration configuration = applyCommandLineOptionsToConfiguration(cmd); final ClusterClientFactory yarnClusterClientFactory = clusterClientServiceLoader.getClusterClientFactory(configuration);