durixu2007

最新版本读取kafka数据sink到ES，如果kafka数据是嵌套json，字段值在es中为null

2

1、kafka中的数据格式为： { "distinct_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd", "lib": { "$lib": "js", "$lib_method": "code", "$lib_version": "1.14.2" } } 2、sink到ES中的数据为 { "_index": "flink2es", "_type": "mytype_1", "_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd", "_score": 1, "_source": { "lib": null, "distinct_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd"...

能否把source、sink插件放到共享存储，此共享存储可以被所有节点访问，然后使用remoteSqlPluginPath来指定这个地址

1

能否把source、sink插件放到共享存储，此共享存储可以被所有节点访问，然后使用remoteSqlPluginPath来指定这个地址？ 例如：plugins在oss的地址是：http://oss-aly-bj.com/plugins 在提交任务的时候配置参数 -remoteSqlPluginPath http://oss-aly-bj.com/plugins